io.druid.query.scan

Class ScanQueryRunnerFactory

java.lang.Object

io.druid.query.scan.ScanQueryRunnerFactory

All Implemented Interfaces:

QueryRunnerFactory<ScanResultValue,ScanQuery>

public class ScanQueryRunnerFactory
extends Object
implements QueryRunnerFactory<ScanResultValue,ScanQuery>

Field Summary

Fields

Modifier and Type	Field and Description
static String	CTX_COUNT
static String	CTX_TIMEOUT_AT

Constructor Summary

Constructors

Constructor and Description
ScanQueryRunnerFactory(ScanQueryQueryToolChest toolChest, ScanQueryEngine engine)

Method Summary

Modifier and Type	Method and Description
QueryRunner<ScanResultValue>	createRunner(Segment segment) Given a specific segment, this method will create a QueryRunner.
QueryToolChest<ScanResultValue,ScanQuery>	getToolchest() Provides access to the toolchest for this specific query type.
QueryRunner<ScanResultValue>	mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<ScanResultValue>> queryRunners) Runners generated with createRunner() and combined into an Iterable in (time,shardId) order are passed along to this method with an ExecutorService.

Methods inherited from class java.lang.Object

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

Field Detail

CTX_TIMEOUT_AT

public static final String CTX_TIMEOUT_AT

See Also:

Constant Field Values

CTX_COUNT

public static final String CTX_COUNT

See Also:

Constant Field Values

Constructor Detail

ScanQueryRunnerFactory

@Inject
public ScanQueryRunnerFactory(ScanQueryQueryToolChest toolChest,
                                      ScanQueryEngine engine)

Method Detail

createRunner

public QueryRunner<ScanResultValue> 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<ScanResultValue,ScanQuery>

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<ScanResultValue> mergeRunners(ExecutorService queryExecutor,
                                                 Iterable<QueryRunner<ScanResultValue>> 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 ExecutorService. The method should then return a QueryRunner that, when asked, will use the ExecutorService to run the base QueryRunners in some fashion. The vast majority of the time, this should be implemented with return new ChainedExecutionQueryRunner<>( queryExecutor, toolChest.getOrdering(), queryWatcher, queryRunners ); Which will allow for parallel execution up to the maximum number of processing threads allowed.

Specified by:

mergeRunners in interface QueryRunnerFactory<ScanResultValue,ScanQuery>

Parameters:

queryExecutor - ExecutorService 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 QueryRunners

getToolchest

public QueryToolChest<ScanResultValue,ScanQuery> getToolchest()

Description copied from interface: QueryRunnerFactory

Provides access to the toolchest for this specific query type.

Specified by:

getToolchest in interface QueryRunnerFactory<ScanResultValue,ScanQuery>

Returns:

an instance of the toolchest for this specific query type.