Modifier and Type | Class and Description |
---|---|
static class |
GroupByQuery.Builder |
Modifier and Type | Field and Description |
---|---|
static String |
CTX_KEY_SORT_BY_DIMS_FIRST |
DATASOURCE_METADATA, GROUP_BY, SCAN, SEARCH, SEGMENT_METADATA, SELECT, TIME_BOUNDARY, TIMESERIES, TOPN
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) |
checkInterrupted, computeOverriddenContext, computeOverridenContext, getContext, getContextBoolean, getContextValue, getContextValue, getDataSource, getDuration, getGranularity, getId, getIntervals, getQuerySegmentSpec, getRunner, getTimezone, isDescending, withId
public static final String CTX_KEY_SORT_BY_DIMS_FIRST
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)
public static GroupByQuery.Builder builder()
public VirtualColumns getVirtualColumns()
public DimFilter getDimFilter()
public List<DimensionSpec> getDimensions()
public List<AggregatorFactory> getAggregatorSpecs()
public List<PostAggregator> getPostAggregatorSpecs()
public HavingSpec getHavingSpec()
public LimitSpec getLimitSpec()
public boolean hasFilters()
public DimFilter getFilter()
public String getType()
public boolean getContextSortByDimsFirst()
public boolean isApplyLimitPushDown()
public boolean getApplyLimitPushDownFromContext()
public com.google.common.collect.Ordering getResultOrdering()
getResultOrdering
in interface Query<Row>
getResultOrdering
in class BaseQuery<Row>
public boolean determineApplyLimitPushDown()
public com.google.common.collect.Ordering<Row> getRowOrdering(boolean granular)
public Sequence<Row> postProcess(Sequence<Row> results)
results
- sequence of rows to apply havingSpec and limitSpec topublic GroupByQuery withOverriddenContext(Map<String,Object> contextOverride)
public GroupByQuery withQuerySegmentSpec(QuerySegmentSpec spec)
public GroupByQuery withDimFilter(DimFilter dimFilter)
public Query<Row> withDataSource(DataSource dataSource)
public GroupByQuery withDimensionSpecs(List<DimensionSpec> dimensionSpecs)
public GroupByQuery withLimitSpec(LimitSpec limitSpec)
public GroupByQuery withPostAggregatorSpecs(List<PostAggregator> postAggregatorSpecs)
Copyright © 2011–2018. All rights reserved.