io.druid.query.groupby

Class GroupByQuery

java.lang.Object

io.druid.query.BaseQuery<Row>

io.druid.query.groupby.GroupByQuery

All Implemented Interfaces:

Query<Row>

public class GroupByQuery
extends BaseQuery<Row>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GroupByQuery.Builder

Field Summary

Fields

Modifier and Type	Field and Description
static String	CTX_KEY_SORT_BY_DIMS_FIRST

Fields inherited from class io.druid.query.BaseQuery

QUERYID

Fields inherited from interface io.druid.query.Query

DATASOURCE_METADATA, GROUP_BY, SEARCH, SEGMENT_METADATA, SELECT, TIME_BOUNDARY, TIMESERIES, TOPN

Constructor Summary

Constructors

Constructor and Description
GroupByQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, VirtualColumns virtualColumns, DimFilter dimFilter, Granularity granularity, List<DimensionSpec> dimensions, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs, HavingSpec havingSpec, LimitSpec limitSpec, Map<String,Object> context)

Method Summary

Modifier and Type	Method and Description
Sequence<Row>	applyLimit(Sequence<Row> results) Apply the havingSpec and limitSpec.
static GroupByQuery.Builder	builder()
boolean	equals(Object o)
List<AggregatorFactory>	getAggregatorSpecs()
boolean	getContextSortByDimsFirst()
List<DimensionSpec>	getDimensions()
DimFilter	getDimFilter()
DimFilter	getFilter()
Granularity	getGranularity()
HavingSpec	getHavingSpec()
LimitSpec	getLimitSpec()
List<PostAggregator>	getPostAggregatorSpecs()
com.google.common.collect.Ordering	getResultOrdering()
com.google.common.collect.Ordering<Row>	getRowOrdering(boolean granular)
String	getType()
VirtualColumns	getVirtualColumns()
boolean	hasFilters()
int	hashCode()
String	toString()
GroupByQuery	withAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs)
Query<Row>	withDataSource(DataSource dataSource)
GroupByQuery	withDimensionSpecs(List<DimensionSpec> dimensionSpecs)
GroupByQuery	withDimFilter(DimFilter dimFilter)
GroupByQuery	withLimitSpec(LimitSpec limitSpec)
GroupByQuery	withOverriddenContext(Map<String,Object> contextOverride)
GroupByQuery	withPostAggregatorSpecs(List<PostAggregator> postAggregatorSpecs)
GroupByQuery	withQuerySegmentSpec(QuerySegmentSpec spec)

Methods inherited from class io.druid.query.BaseQuery

computeOverridenContext, getContext, getContextBoolean, getContextBySegment, getContextFinalize, getContextPopulateCache, getContextPriority, getContextUncoveredIntervalsLimit, getContextUseCache, getContextValue, getContextValue, getDataSource, getDuration, getId, getIntervals, getQuerySegmentSpec, isDescending, run, run, withId

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

CTX_KEY_SORT_BY_DIMS_FIRST

public static final String CTX_KEY_SORT_BY_DIMS_FIRST

See Also:

Constant Field Values

Constructor Detail

GroupByQuery

public GroupByQuery(DataSource dataSource,
                    QuerySegmentSpec querySegmentSpec,
                    VirtualColumns virtualColumns,
                    DimFilter dimFilter,
                    Granularity granularity,
                    List<DimensionSpec> dimensions,
                    List<AggregatorFactory> aggregatorSpecs,
                    List<PostAggregator> postAggregatorSpecs,
                    HavingSpec havingSpec,
                    LimitSpec limitSpec,
                    Map<String,Object> context)

Method Detail

builder

public static GroupByQuery.Builder builder()

getVirtualColumns

public VirtualColumns getVirtualColumns()

getDimFilter

public DimFilter getDimFilter()

getGranularity

public Granularity getGranularity()

getDimensions

public List<DimensionSpec> getDimensions()

getAggregatorSpecs

public List<AggregatorFactory> getAggregatorSpecs()

getPostAggregatorSpecs

public List<PostAggregator> getPostAggregatorSpecs()

getHavingSpec

public HavingSpec getHavingSpec()

getLimitSpec

public LimitSpec getLimitSpec()

hasFilters

public boolean hasFilters()

getFilter

public DimFilter getFilter()

getType

public String getType()

getContextSortByDimsFirst

public boolean getContextSortByDimsFirst()

getResultOrdering

public com.google.common.collect.Ordering getResultOrdering()

Specified by:

getResultOrdering in interface Query<Row>

Overrides:

getResultOrdering in class BaseQuery<Row>

getRowOrdering

public com.google.common.collect.Ordering<Row> getRowOrdering(boolean granular)

applyLimit

public Sequence<Row> applyLimit(Sequence<Row> results)

Apply the havingSpec and limitSpec. Because havingSpecs are not thread safe, and because they are applied during accumulation of the returned sequence, callers must take care to avoid accumulating two different Sequences returned by this method in two different threads.

Parameters:

results - sequence of rows to apply havingSpec and limitSpec to

Returns:

sequence of rows after applying havingSpec and limitSpec

withOverriddenContext

public GroupByQuery withOverriddenContext(Map<String,Object> contextOverride)

withQuerySegmentSpec

public GroupByQuery withQuerySegmentSpec(QuerySegmentSpec spec)

withDimFilter

public GroupByQuery withDimFilter(DimFilter dimFilter)

withDataSource

public Query<Row> withDataSource(DataSource dataSource)

withDimensionSpecs

public GroupByQuery withDimensionSpecs(List<DimensionSpec> dimensionSpecs)

withLimitSpec

public GroupByQuery withLimitSpec(LimitSpec limitSpec)

withAggregatorSpecs

public GroupByQuery withAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs)

withPostAggregatorSpecs

public GroupByQuery withPostAggregatorSpecs(List<PostAggregator> postAggregatorSpecs)

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class BaseQuery<Row>

hashCode

public int hashCode()

Overrides:

hashCode in class BaseQuery<Row>