Uses of Class
org.apache.druid.query.groupby.GroupByQuery

Packages that use GroupByQuery

Package	Description
org.apache.druid.query.groupby
org.apache.druid.query.groupby.epinephelinae
org.apache.druid.query.groupby.epinephelinae.vector
org.apache.druid.query.groupby.having
org.apache.druid.query.groupby.orderby

Uses of GroupByQuery in org.apache.druid.query.groupby

Methods in org.apache.druid.query.groupby that return GroupByQuery

Modifier and Type	Method	Description
GroupByQuery	GroupByQuery.Builder.build()
GroupByQuery	GroupingEngine.prepareGroupByQuery(GroupByQuery query)
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)
GroupByQuery	GroupByQuery.withSubtotalsSpec(List<List<String>> subtotalsSpec)
GroupByQuery	GroupByQuery.withVirtualColumns(VirtualColumns virtualColumns)

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

Modifier and Type	Method	Description
CacheStrategy<ResultRow,Object,GroupByQuery>	GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query)
CacheStrategy<ResultRow,Object,GroupByQuery>	GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query, com.fasterxml.jackson.databind.ObjectMapper mapper)
QueryToolChest<ResultRow,GroupByQuery>	GroupByQueryRunnerFactory.getToolchest()

Methods in org.apache.druid.query.groupby with parameters of type GroupByQuery

Modifier and Type	Method	Description
Sequence<ResultRow>	GroupingEngine.applyPostProcessing(Sequence<ResultRow> results, GroupByQuery query)	Apply the GroupByQuery "postProcessingFn", which is responsible for HavingSpec and LimitSpec.
static int	GroupByQueryResources.countRequiredMergeBufferNumForMergingQueryRunner(GroupByQueryConfig config, GroupByQuery query)	Count the number of merge buffers required for GroupByMergingQueryRunner It can be either 1 or 2, depending on the query's config
static int	GroupByQueryResources.countRequiredMergeBufferNumForToolchestMerge(GroupByQuery query)	Counts the number of merge buffers required for GroupByQueryQueryToolChest.mergeResults(org.apache.druid.query.QueryRunner<org.apache.druid.query.groupby.ResultRow>).
com.fasterxml.jackson.databind.ObjectMapper	GroupByQueryQueryToolChest.decorateObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper, GroupByQuery query)
static com.fasterxml.jackson.databind.ObjectMapper	ResultRowObjectMapperDecoratorUtil.decorateObjectMapper(com.fasterxml.jackson.databind.ObjectMapper baseObjectMapper, GroupByQuery query, GroupByQueryConfig groupByQueryConfig)	Decorates the provided object mapper so that it can read the result rows generated by the given query and the groupByQueryConfig.
static ResultRow	ResultRow.fromLegacyRow(Row row, GroupByQuery query)	Create a row based on a legacy Row that was generated by a given GroupByQuery.
CacheStrategy<ResultRow,Object,GroupByQuery>	GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query)
CacheStrategy<ResultRow,Object,GroupByQuery>	GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query, com.fasterxml.jackson.databind.ObjectMapper mapper)
static int	GroupingEngine.getCardinalityForArrayAggregation(GroupByQueryConfig querySpecificConfig, GroupByQuery query, ColumnInspector columnInspector, List<? extends GroupingSelector> groupingSelectors, ByteBuffer buffer)	Returns the cardinality of array needed to do array-based aggregation, or -1 if array-based aggregation is impossible.
void	DefaultGroupByQueryMetrics.granularity(GroupByQuery query)
void	GroupByQueryMetrics.granularity(GroupByQuery query)	Sets the granularity of BaseQuery.getGranularity() of the given query as dimension.
static boolean	GroupByQueryQueryToolChest.isNestedQueryPushDown(GroupByQuery q)
static CursorBuildSpec	GroupingEngine.makeCursorBuildSpec(GroupByQuery query, QueryMetrics<?> queryMetrics)
GroupByQueryMetrics	GroupByQueryQueryToolChest.makeMetrics(GroupByQuery query)
com.google.common.base.Function<ResultRow,ResultRow>	GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
com.google.common.base.Function<ResultRow,ResultRow>	GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
Sequence<ResultRow>	GroupingEngine.mergeResults(QueryRunner<ResultRow> baseRunner, GroupByQuery query, ResponseContext responseContext)	Runs a provided QueryRunner on a provided GroupByQuery, which is assumed to return rows that are properly sorted (by timestamp and dimensions) but not necessarily fully merged (that is, there may be adjacent rows with the same timestamp and dimensions) and without PostAggregators computed.
void	DefaultGroupByQueryMetrics.numComplexMetrics(GroupByQuery query)
void	GroupByQueryMetrics.numComplexMetrics(GroupByQuery query)	Sets the number of "complex" metrics of the given groupBy query as dimension.
void	DefaultGroupByQueryMetrics.numDimensions(GroupByQuery query)
void	GroupByQueryMetrics.numDimensions(GroupByQuery query)	Sets the size of getDimensions() of the given query as dimension.
void	DefaultGroupByQueryMetrics.numMetrics(GroupByQuery query)
void	GroupByQueryMetrics.numMetrics(GroupByQuery query)	Sets the number of metrics of the given groupBy query as dimension.
GroupByQuery	GroupingEngine.prepareGroupByQuery(GroupByQuery query)
static GroupByQueryResources	GroupingEngine.prepareResource(GroupByQuery query, BlockingPool<ByteBuffer> mergeBufferPool, boolean usesGroupByMergingQueryRunner, GroupByQueryConfig groupByQueryConfig)	Initializes resources required to run GroupByQueryQueryToolChest.mergeResults(QueryRunner) and GroupByMergingQueryRunner for a particular query.
Sequence<ResultRow>	GroupingEngine.process(GroupByQuery query, CursorFactory cursorFactory, TimeBoundaryInspector timeBoundaryInspector, NonBlockingPool<ByteBuffer> bufferPool, GroupByQueryMetrics groupByQueryMetrics)	Process a groupBy query on a single CursorFactory.
Sequence<ResultRow>	GroupingEngine.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResources resource, Sequence<ResultRow> subqueryResult, boolean wasQueryPushedDown, GroupByStatsProvider.PerQueryStats perQueryStats)	Called by GroupByQueryQueryToolChest.mergeResults(QueryRunner) when it needs to process a subquery.
Sequence<ResultRow>	GroupingEngine.processSubtotalsSpec(GroupByQuery query, GroupByQueryResources resource, Sequence<ResultRow> queryResult, GroupByStatsProvider.PerQueryStats perQueryStats)	Called by GroupByQueryQueryToolChest.mergeResults(QueryRunner) when it needs to generate subtotals.
void	DefaultGroupByQueryMetrics.query(GroupByQuery query)
void	GroupByResourcesReservationPool.reserve(QueryResourceId queryResourceId, GroupByQuery groupByQuery, boolean willMergeRunner, GroupByStatsProvider.PerQueryStats perQueryStats)	Reserves appropriate resources, and maps it to the queryResourceId (usually the query's resource id) in the internal map.
RowSignature	GroupByQueryQueryToolChest.resultArraySignature(GroupByQuery query)
Sequence<Object[]>	GroupByQueryQueryToolChest.resultsAsArrays(GroupByQuery query, Sequence<ResultRow> resultSequence)
Optional<Sequence<FrameSignaturePair>>	GroupByQueryQueryToolChest.resultsAsFrames(GroupByQuery query, Sequence<ResultRow> resultSequence, MemoryAllocatorFactory memoryAllocatorFactory, boolean useNestedForUnknownTypes)	This returns a single frame containing the results of the group by query.
static boolean	GroupingEngine.summaryRowPreconditions(GroupByQuery query)	Whether a query should include a summary row.
Map<String,Object>	ResultRow.toMap(GroupByQuery query)	Returns a Map representation of the data in this row.
MapBasedRow	ResultRow.toMapBasedRow(GroupByQuery query)	Returns a Row representation of the data in this row.
GroupByQueryConfig	GroupByQueryConfig.withOverrides(GroupByQuery query)
static Sequence<ResultRow>	GroupingEngine.wrapSummaryRowIfNeeded(GroupByQuery query, Sequence<ResultRow> process)	Wraps the sequence around if for this query a summary row might be needed in case the input becomes empty.

Constructors in org.apache.druid.query.groupby with parameters of type GroupByQuery

Modifier	Constructor	Description
	Builder(GroupByQuery query)

Uses of GroupByQuery in org.apache.druid.query.groupby.epinephelinae

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

Modifier and Type	Method	Description
static Pair<Grouper<RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,ResultRow>>	RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, GroupByQuery subquery, GroupByQueryConfig config, DruidProcessingConfig processingConfig, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, ReferenceCountingResourceHolder<ByteBuffer> combineBufferHolder, int concurrencyHint, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, com.google.common.util.concurrent.ListeningExecutorService grouperSorter, int priority, boolean hasQueryTimeout, long queryTimeoutAt, int mergeBufferSize, GroupByStatsProvider.PerQueryStats perQueryStats)	Create a Grouper that groups according to the dimensions and aggregators in "query", along with an Accumulator that accepts ResultRows and forwards them to the grouper.
static Pair<Grouper<RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,ResultRow>>	RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, GroupByQuery subquery, GroupByQueryConfig config, DruidProcessingConfig processingConfig, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, int mergeBufferSize, GroupByStatsProvider.PerQueryStats perQueryStats)	Create a single-threaded grouper and accumulator.
static ColumnSelectorFactory	RowBasedGrouperHelper.createResultRowBasedColumnSelectorFactory(GroupByQuery query, com.google.common.base.Supplier<ResultRow> supplier, RowSignature.Finalization finalization)	Creates a ColumnSelectorFactory that can read rows which originate as results of the provided "query".
static CloseableGrouperIterator<RowBasedGrouperHelper.RowBasedKey,ResultRow>	RowBasedGrouperHelper.makeGrouperIterator(Grouper<RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, Closeable closeable)
static CloseableGrouperIterator<RowBasedGrouperHelper.RowBasedKey,ResultRow>	RowBasedGrouperHelper.makeGrouperIterator(Grouper<RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, List<DimensionSpec> dimsToInclude, Closeable closeable)
static Sequence<ResultRow>	GroupByQueryEngine.process(GroupByQuery query, TimeBoundaryInspector timeBoundaryInspector, CursorHolder cursorHolder, CursorBuildSpec buildSpec, ByteBuffer processingBuffer, org.joda.time.DateTime fudgeTimestamp, GroupByQueryConfig querySpecificConfig, DruidProcessingConfig processingConfig)
static GroupByRowProcessor.ResultSupplier	GroupByRowProcessor.process(GroupByQuery query, GroupByQuery subquery, Sequence<ResultRow> rows, GroupByQueryConfig config, DruidProcessingConfig processingConfig, GroupByQueryResources resource, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir, int mergeBufferSize, GroupByStatsProvider.PerQueryStats perQueryStats)	Process the input of sequence "rows" (output by "subquery") based on "query" and returns a GroupByRowProcessor.ResultSupplier.

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

Modifier	Constructor	Description
	GroupByResultMergeFn(GroupByQuery query)

Uses of GroupByQuery in org.apache.druid.query.groupby.epinephelinae.vector

Methods in org.apache.druid.query.groupby.epinephelinae.vector with parameters of type GroupByQuery

Modifier and Type	Method	Description
static Sequence<ResultRow>	VectorGroupByEngine.process(GroupByQuery query, TimeBoundaryInspector timeBoundaryInspector, CursorHolder cursorHolder, ByteBuffer processingBuffer, org.joda.time.DateTime fudgeTimestamp, org.joda.time.Interval interval, GroupByQueryConfig config, DruidProcessingConfig processingConfig)

Uses of GroupByQuery in org.apache.druid.query.groupby.having

Methods in org.apache.druid.query.groupby.having with parameters of type GroupByQuery

Modifier and Type	Method	Description
void	AlwaysHavingSpec.setQuery(GroupByQuery query)
void	AndHavingSpec.setQuery(GroupByQuery query)
void	DimensionSelectorHavingSpec.setQuery(GroupByQuery query)
void	DimFilterHavingSpec.setQuery(GroupByQuery query)
void	EqualToHavingSpec.setQuery(GroupByQuery query)
void	GreaterThanHavingSpec.setQuery(GroupByQuery query)
void	HavingSpec.setQuery(GroupByQuery query)	Informs this HavingSpec that rows passed to "eval" will originate from a particular groupBy query.
void	LessThanHavingSpec.setQuery(GroupByQuery query)
void	NeverHavingSpec.setQuery(GroupByQuery query)
void	NotHavingSpec.setQuery(GroupByQuery query)
void	OrHavingSpec.setQuery(GroupByQuery query)

Uses of GroupByQuery in org.apache.druid.query.groupby.orderby

Methods in org.apache.druid.query.groupby.orderby with parameters of type GroupByQuery

Modifier and Type	Method	Description
com.google.common.base.Function<Sequence<ResultRow>,Sequence<ResultRow>>	DefaultLimitSpec.build(GroupByQuery query)
com.google.common.base.Function<Sequence<ResultRow>,Sequence<ResultRow>>	LimitSpec.build(GroupByQuery query)	Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
com.google.common.base.Function<Sequence<ResultRow>,Sequence<ResultRow>>	NoopLimitSpec.build(GroupByQuery query)