Uses of Class
org.apache.druid.query.groupby.GroupByStatsProvider.PerQueryStats

Packages that use GroupByStatsProvider.PerQueryStats

Package	Description
org.apache.druid.query.groupby
org.apache.druid.query.groupby.epinephelinae

Uses of GroupByStatsProvider.PerQueryStats in org.apache.druid.query.groupby

Methods in org.apache.druid.query.groupby that return GroupByStatsProvider.PerQueryStats

Modifier and Type	Method	Description
GroupByStatsProvider.PerQueryStats	GroupByStatsProvider.getPerQueryStatsContainer(QueryResourceId resourceId)

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

Modifier and Type	Method	Description
void	GroupByStatsProvider.AggregateStats.addQueryStats(GroupByStatsProvider.PerQueryStats perQueryStats)
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	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.

Uses of GroupByStatsProvider.PerQueryStats in org.apache.druid.query.groupby.epinephelinae

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

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 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 GroupByStatsProvider.PerQueryStats

Modifier	Constructor	Description
	ConcurrentGrouper(GroupByQueryConfig groupByQueryConfig, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, ReferenceCountingResourceHolder<ByteBuffer> combineBufferHolder, Grouper.KeySerdeFactory<KeyType> keySerdeFactory, Grouper.KeySerdeFactory<KeyType> combineKeySerdeFactory, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, int concurrencyHint, DefaultLimitSpec limitSpec, boolean sortHasNonGroupingFields, com.google.common.util.concurrent.ListeningExecutorService executor, int priority, boolean hasQueryTimeout, long queryTimeoutAt, GroupByStatsProvider.PerQueryStats perQueryStats)
	LimitedTemporaryStorage(File storageDirectory, long maxBytesUsed, GroupByStatsProvider.PerQueryStats perQueryStatsContainer)
	SpillingGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier, Grouper.KeySerdeFactory<KeyType> keySerdeFactory, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, int bufferGrouperMaxSize, float bufferGrouperMaxLoadFactor, int bufferGrouperInitialBuckets, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, boolean spillingAllowed, DefaultLimitSpec limitSpec, boolean sortHasNonGroupingFields, int mergeBufferSize, GroupByStatsProvider.PerQueryStats perQueryStats)