Uses of Class
org.apache.druid.query.DruidProcessingConfig

Packages that use DruidProcessingConfig

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

Uses of DruidProcessingConfig in org.apache.druid.query

Methods in org.apache.druid.query with parameters of type DruidProcessingConfig

Modifier and Type	Method	Description
static PrioritizedExecutorService	PrioritizedExecutorService.create(Lifecycle lifecycle, DruidProcessingConfig config)

Constructors in org.apache.druid.query with parameters of type DruidProcessingConfig

Modifier	Constructor	Description
	PrioritizedExecutorService(ThreadPoolExecutor threadPoolExecutor, boolean allowRegularTasks, int defaultPriority, DruidProcessingConfig config)
	PrioritizedExecutorService(ThreadPoolExecutor threadPoolExecutor, DruidProcessingConfig config)

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

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

Modifier and Type	Method	Description
long	GroupByQueryConfig.getActualMaxMergingDictionarySize(DruidProcessingConfig processingConfig)
long	GroupByQueryConfig.getActualMaxSelectorDictionarySize(DruidProcessingConfig processingConfig)

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

Modifier	Constructor	Description
	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 DruidProcessingConfig in org.apache.druid.query.groupby.epinephelinae

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

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 DruidProcessingConfig

Modifier	Constructor	Description
	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 DruidProcessingConfig in org.apache.druid.query.groupby.epinephelinae.vector

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

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)