io.druid.query.select

Class SelectResultValueBuilder

java.lang.Object

io.druid.query.select.SelectResultValueBuilder

Direct Known Subclasses:

SelectResultValueBuilder.MergeBuilder

public class SelectResultValueBuilder
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SelectResultValueBuilder.MergeBuilder

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	descending
protected Set<String>	dimensions
protected Set<String>	metrics
protected Map<String,Integer>	pagingIdentifiers
protected PagingSpec	pagingSpec
protected Queue<EventHolder>	pQueue
protected org.joda.time.DateTime	timestamp

Constructor Summary

Constructors

Constructor and Description
SelectResultValueBuilder(org.joda.time.DateTime timestamp, PagingSpec pagingSpec, boolean descending)

Method Summary

Modifier and Type	Method and Description
void	addDimension(String dimension)
void	addDimensions(Set<String> dimensions)
void	addEntry(EventHolder event)
void	addMetric(String metric)
void	addMetrics(Set<String> metrics)
Result<SelectResultValue>	build()
void	finished(String segmentId, int lastOffset)
protected List<EventHolder>	getEventHolders()
protected Queue<EventHolder>	instantiatePQueue()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

timestamp

protected final org.joda.time.DateTime timestamp

pagingSpec

protected final PagingSpec pagingSpec

descending

protected final boolean descending

dimensions

protected Set<String> dimensions

metrics

protected Set<String> metrics

pQueue

protected final Queue<EventHolder> pQueue

pagingIdentifiers

protected final Map<String,Integer> pagingIdentifiers

Constructor Detail

SelectResultValueBuilder

public SelectResultValueBuilder(org.joda.time.DateTime timestamp,
                                PagingSpec pagingSpec,
                                boolean descending)

Method Detail

addEntry

public void addEntry(EventHolder event)

finished

public void finished(String segmentId,
                     int lastOffset)

addDimension

public void addDimension(String dimension)

addDimensions

public void addDimensions(Set<String> dimensions)

addMetric

public void addMetric(String metric)

addMetrics

public void addMetrics(Set<String> metrics)

build

public Result<SelectResultValue> build()

getEventHolders

protected List<EventHolder> getEventHolders()

instantiatePQueue

protected Queue<EventHolder> instantiatePQueue()