Uses of Interface
org.apache.druid.query.QueryProcessingPool

Packages that use QueryProcessingPool

Package	Description
org.apache.druid.query
org.apache.druid.query.datasourcemetadata
org.apache.druid.query.groupby
org.apache.druid.query.groupby.epinephelinae
org.apache.druid.query.metadata
org.apache.druid.query.operator
org.apache.druid.query.scan
org.apache.druid.query.search
org.apache.druid.query.timeboundary
org.apache.druid.query.timeseries
org.apache.druid.query.topn

Uses of QueryProcessingPool in org.apache.druid.query

Classes in org.apache.druid.query that implement QueryProcessingPool

Modifier and Type	Class	Description
class	DirectQueryProcessingPool	QueryProcessingPool wrapper over Execs.directExecutor()
class	ForwardingQueryProcessingPool	Default implementation of QueryProcessingPool that just forwards operations, including query execution tasks, to an underlying ExecutorService Exposes a method ForwardingQueryProcessingPool.submitRunnerTask(PrioritizedQueryRunnerCallable, long, TimeUnit) which allows execution tasks to be serviced a custom timeout.
class	MetricsEmittingQueryProcessingPool
class	NoopQueryProcessingPool	Implementation of QueryProcessingPool that throws when any query execution task unit is submitted to it.

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

Modifier and Type	Method	Description
QueryRunner<T>	QueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<T>> queryRunners)	Runners generated with createRunner() and combined into an Iterable in (time,shardId) order are passed along to this method with an QueryProcessingPool.

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

Modifier	Constructor	Description
	ChainedExecutionQueryRunner(QueryProcessingPool queryProcessingPool, QueryWatcher queryWatcher, Iterable<QueryRunner<T>> queryables)

Uses of QueryProcessingPool in org.apache.druid.query.datasourcemetadata

Methods in org.apache.druid.query.datasourcemetadata with parameters of type QueryProcessingPool

Modifier and Type	Method	Description
QueryRunner<Result<DataSourceMetadataResultValue>>	DataSourceMetadataQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<DataSourceMetadataResultValue>>> queryRunners)

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

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

Modifier and Type	Method	Description
QueryRunner<ResultRow>	GroupByQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners)
QueryRunner<ResultRow>	GroupingEngine.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners)	Merges a variety of single-segment query runners into a combined runner.

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

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

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 QueryProcessingPool in org.apache.druid.query.metadata

Methods in org.apache.druid.query.metadata with parameters of type QueryProcessingPool

Modifier and Type	Method	Description
QueryRunner<SegmentAnalysis>	SegmentMetadataQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<SegmentAnalysis>> queryRunners)

Uses of QueryProcessingPool in org.apache.druid.query.operator

Methods in org.apache.druid.query.operator with parameters of type QueryProcessingPool

Modifier and Type	Method	Description
QueryRunner<RowsAndColumns>	WindowOperatorQueryQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<RowsAndColumns>> queryRunners)

Uses of QueryProcessingPool in org.apache.druid.query.scan

Methods in org.apache.druid.query.scan with parameters of type QueryProcessingPool

Modifier and Type	Method	Description
QueryRunner<ScanResultValue>	ScanQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ScanResultValue>> queryRunners)

Uses of QueryProcessingPool in org.apache.druid.query.search

Methods in org.apache.druid.query.search with parameters of type QueryProcessingPool

Modifier and Type	Method	Description
QueryRunner<Result<SearchResultValue>>	SearchQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<SearchResultValue>>> queryRunners)

Uses of QueryProcessingPool in org.apache.druid.query.timeboundary

Methods in org.apache.druid.query.timeboundary with parameters of type QueryProcessingPool

Modifier and Type	Method	Description
QueryRunner<Result<TimeBoundaryResultValue>>	TimeBoundaryQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<TimeBoundaryResultValue>>> queryRunners)

Uses of QueryProcessingPool in org.apache.druid.query.timeseries

Methods in org.apache.druid.query.timeseries with parameters of type QueryProcessingPool

Modifier and Type	Method	Description
QueryRunner<Result<TimeseriesResultValue>>	TimeseriesQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<TimeseriesResultValue>>> queryRunners)

Uses of QueryProcessingPool in org.apache.druid.query.topn

Methods in org.apache.druid.query.topn with parameters of type QueryProcessingPool

Modifier and Type	Method	Description
QueryRunner<Result<TopNResultValue>>	TopNQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<TopNResultValue>>> queryRunners)