Package org.apache.druid.query.groupby

Class GroupByQueryRunnerFactory

java.lang.Object

org.apache.druid.query.groupby.GroupByQueryRunnerFactory

All Implemented Interfaces:

QueryRunnerFactory<ResultRow,GroupByQuery>

public class GroupByQueryRunnerFactory
extends Object
implements QueryRunnerFactory<ResultRow,GroupByQuery>

Constructor Summary

Constructors

Constructor	Description
GroupByQueryRunnerFactory(GroupingEngine groupingEngine, GroupByQueryQueryToolChest toolChest, NonBlockingPool<ByteBuffer> processingBufferPool)

Method Summary

Modifier and Type	Method	Description
QueryRunner<ResultRow>	createRunner(Segment segment)	Given a specific segment, this method will create a QueryRunner.
GroupingEngine	getGroupingEngine()
QueryToolChest<ResultRow,GroupByQuery>	getToolchest()	Provides access to the QueryToolChest for this specific Query type.
QueryRunner<ResultRow>	mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners)	Runners generated with createRunner() and combined into an Iterable in (time,shardId) order are passed along to this method with an QueryProcessingPool.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.druid.query.QueryRunnerFactory

mergeRunners

Constructor Details

GroupByQueryRunnerFactory

@Inject
public GroupByQueryRunnerFactory(GroupingEngine groupingEngine,
 GroupByQueryQueryToolChest toolChest,
 NonBlockingPool<ByteBuffer> processingBufferPool)

Method Details

createRunner

public QueryRunner<ResultRow> createRunner(Segment segment)

Description copied from interface: QueryRunnerFactory

Given a specific segment, this method will create a QueryRunner. The QueryRunner, when asked, will generate a Sequence of results based on the given segment. This is the meat of the Query processing and is where the results are actually generated. Everything else is just merging and reduction logic.

Specified by:

createRunner in interface QueryRunnerFactory<ResultRow,GroupByQuery>

Parameters:

segment - The segment to process

Returns:

A QueryRunner that, when asked, will generate a Sequence of results based on the given segment

mergeRunners

public QueryRunner<ResultRow> mergeRunners(QueryProcessingPool queryProcessingPool,
 Iterable<QueryRunner<ResultRow>> queryRunners)

Description copied from interface: QueryRunnerFactory

Runners generated with createRunner() and combined into an Iterable in (time,shardId) order are passed along to this method with an QueryProcessingPool. The method should then return a QueryRunner that, when asked, will use the QueryProcessingPool to run the base QueryRunners in some fashion. The vast majority of the time, this should be implemented with ChainedExecutionQueryRunner: return new ChainedExecutionQueryRunner<>(queryProcessingPool, toolChest.getOrdering(), queryWatcher, queryRunners); Which will allow for parallel execution up to the maximum number of processing threads allowed. Unlike QueryRunnerFactory.mergeRunners(ExecutorService, Iterable), this method takes a QueryProcessingPool instead which allows custom implementations for prioritize query execution on segments.

Specified by:

mergeRunners in interface QueryRunnerFactory<ResultRow,GroupByQuery>

Parameters:

queryProcessingPool - QueryProcessingPool to be used for parallel processing

queryRunners - Individual QueryRunner objects that produce some results

Returns:

a QueryRunner that, when asked, will use the ExecutorService to run the base QueryRunner collection.

See Also:

• GroupingEngine.mergeRunners(QueryProcessingPool, Iterable)

getToolchest

public QueryToolChest<ResultRow,GroupByQuery> getToolchest()

Description copied from interface: QueryRunnerFactory

Provides access to the QueryToolChest for this specific Query type.

Specified by:

getToolchest in interface QueryRunnerFactory<ResultRow,GroupByQuery>

Returns:

an instance of the toolchest for this specific query type.

getGroupingEngine

public GroupingEngine getGroupingEngine()