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

Packages that use GroupByQueryConfig

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

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

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

Modifier and Type	Method	Description
GroupByQueryConfig	GroupByQueryConfig.withOverrides(GroupByQuery query)

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

Modifier and Type	Method	Description
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 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 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.
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.

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

Modifier	Constructor	Description
	GroupByResourcesReservationPool(BlockingPool<ByteBuffer> mergeBufferPool, GroupByQueryConfig groupByQueryConfig)

Constructor parameters in org.apache.druid.query.groupby with type arguments of type GroupByQueryConfig

Modifier	Constructor	Description
	GroupByQueryQueryToolChest(GroupingEngine groupingEngine, com.google.common.base.Supplier<GroupByQueryConfig> queryConfigSupplier, GroupByQueryMetricsFactory queryMetricsFactory, GroupByResourcesReservationPool groupByResourcesReservationPool, GroupByStatsProvider groupByStatsProvider)
	GroupingEngine(DruidProcessingConfig processingConfig, com.google.common.base.Supplier<GroupByQueryConfig> configSupplier, GroupByResourcesReservationPool groupByResourcesReservationPool, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.fasterxml.jackson.databind.ObjectMapper spillMapper, QueryWatcher queryWatcher, GroupByStatsProvider groupByStatsProvider)

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

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

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 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 GroupByQueryConfig

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)
	GroupByMergingQueryRunner(GroupByQueryConfig config, DruidProcessingConfig processingConfig, QueryProcessingPool queryProcessingPool, QueryWatcher queryWatcher, Iterable<QueryRunner<ResultRow>> queryables, GroupByResourcesReservationPool groupByResourcesReservationPool, int concurrencyHint, int mergeBufferSize, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir, GroupByStatsProvider groupByStatsProvider)

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

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

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)