Uses of Class
io.druid.query.groupby.GroupByQuery

Packages that use GroupByQuery

Package	Description
io.druid.query.groupby
io.druid.query.groupby.epinephelinae
io.druid.query.groupby.strategy
io.druid.sql.calcite.rel

Uses of GroupByQuery in io.druid.query.groupby

Methods in io.druid.query.groupby that return GroupByQuery

Modifier and Type	Method and Description
GroupByQuery	GroupByQuery.Builder.build()
GroupByQuery	GroupByQuery.withAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs)
GroupByQuery	GroupByQuery.withDimensionSpecs(List<DimensionSpec> dimensionSpecs)
GroupByQuery	GroupByQuery.withDimFilter(DimFilter dimFilter)
GroupByQuery	GroupByQuery.withLimitSpec(LimitSpec limitSpec)
GroupByQuery	GroupByQuery.withOverriddenContext(Map<String,Object> contextOverride)
GroupByQuery	GroupByQuery.withPostAggregatorSpecs(List<PostAggregator> postAggregatorSpecs)
GroupByQuery	GroupByQuery.withQuerySegmentSpec(QuerySegmentSpec spec)

Methods in io.druid.query.groupby that return types with arguments of type GroupByQuery

Modifier and Type	Method and Description
CacheStrategy<Row,Object,GroupByQuery>	GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query)
QueryToolChest<Row,GroupByQuery>	GroupByQueryRunnerFactory.getToolchest()

Methods in io.druid.query.groupby with parameters of type GroupByQuery

Modifier and Type	Method and Description
static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>>	GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query, GroupByQueryConfig config, StupidPool<ByteBuffer> bufferPool, boolean combine)
static Collection<DimensionSpec>	GroupByQueryQueryToolChest.extractionsToRewrite(GroupByQuery query) This function checks the query for dimensions which can be optimized by applying the dimension extraction as the final step of the query instead of on every event.
CacheStrategy<Row,Object,GroupByQuery>	GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query)
static IncrementalIndex	GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query, GroupByQueryConfig config, StupidPool<ByteBuffer> bufferPool, Sequence<Row> rows, boolean combine)
com.metamx.emitter.service.ServiceMetricEvent.Builder	GroupByQueryQueryToolChest.makeMetricBuilder(GroupByQuery query)
com.google.common.base.Function<Row,Row>	GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
com.google.common.base.Function<Row,Row>	GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
static Sequence<Row>	GroupByQueryHelper.postAggregate(GroupByQuery query, IncrementalIndex index)
Sequence<Row>	GroupByQueryEngine.process(GroupByQuery query, StorageAdapter storageAdapter)
static Map<String,ValueType>	GroupByQueryHelper.rowSignatureFor(GroupByQuery query) Returns types for fields that will appear in the Rows output from "query".
GroupByQueryConfig	GroupByQueryConfig.withOverrides(GroupByQuery query)

Constructors in io.druid.query.groupby with parameters of type GroupByQuery

Constructor and Description
Builder(GroupByQuery query)

Uses of GroupByQuery in io.druid.query.groupby.epinephelinae

Methods in io.druid.query.groupby.epinephelinae with parameters of type GroupByQuery

Modifier and Type	Method and Description
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Row>>	RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, boolean isInputRaw, Map<String,ValueType> rawInputRowSignature, GroupByQueryConfig config, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, int concurrencyHint, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, AggregatorFactory[] aggregatorFactories) If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not been applied to the input rows yet, for example, in a nested query, if an extraction function is being applied in the outer query to a field of the inner query.
static CloseableGrouperIterator<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row>	RowBasedGrouperHelper.makeGrouperIterator(Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, Closeable closeable)
static Sequence<Row>	GroupByQueryEngineV2.process(GroupByQuery query, StorageAdapter storageAdapter, StupidPool<ByteBuffer> intermediateResultsBufferPool, GroupByQueryConfig config)

Constructors in io.druid.query.groupby.epinephelinae with parameters of type GroupByQuery

Constructor and Description
GroupByBinaryFnV2(GroupByQuery query)

Uses of GroupByQuery in io.druid.query.groupby.strategy

Methods in io.druid.query.groupby.strategy with parameters of type GroupByQuery

Modifier and Type	Method and Description
boolean	GroupByStrategyV2.doMergeResults(GroupByQuery query)
boolean	GroupByStrategyV1.doMergeResults(GroupByQuery query)
boolean	GroupByStrategy.doMergeResults(GroupByQuery query) Indicates if this query should undergo "mergeResults" or not.
static org.joda.time.DateTime	GroupByStrategyV2.getUniversalTimestamp(GroupByQuery query) If "query" has a single universal timestamp, return it.
Sequence<Row>	GroupByStrategyV2.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategyV1.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategy.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
GroupByQueryResource	GroupByStrategyV2.prepareResource(GroupByQuery query, boolean willMergeRunners)
GroupByQueryResource	GroupByStrategyV1.prepareResource(GroupByQuery query, boolean willMergeRunners)
GroupByQueryResource	GroupByStrategy.prepareResource(GroupByQuery query, boolean willMergeRunners) Initializes resources required for a broker to process the given query.
Sequence<Row>	GroupByStrategyV2.process(GroupByQuery query, StorageAdapter storageAdapter)
Sequence<Row>	GroupByStrategyV1.process(GroupByQuery query, StorageAdapter storageAdapter)
Sequence<Row>	GroupByStrategy.process(GroupByQuery query, StorageAdapter storageAdapter)
Sequence<Row>	GroupByStrategyV2.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResource resource, Sequence<Row> subqueryResult)
Sequence<Row>	GroupByStrategyV1.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResource resource, Sequence<Row> subqueryResult)
Sequence<Row>	GroupByStrategy.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResource resource, Sequence<Row> subqueryResult)
GroupByStrategy	GroupByStrategySelector.strategize(GroupByQuery query)

Uses of GroupByQuery in io.druid.sql.calcite.rel

Methods in io.druid.sql.calcite.rel that return GroupByQuery

Modifier and Type	Method and Description
GroupByQuery	DruidQueryBuilder.toGroupByQuery(DataSource dataSource, RowSignature sourceRowSignature, Map<String,Object> context) Return this query as a GroupBy query, or null if this query is not compatible with GroupBy.