Uses of Interface
io.druid.query.QueryRunner

Packages that use QueryRunner

Package	Description
io.druid.benchmark.query
io.druid.client
io.druid.indexing.common.task
io.druid.indexing.kafka
io.druid.indexing.overlord
io.druid.query
io.druid.query.datasourcemetadata
io.druid.query.groupby
io.druid.query.groupby.epinephelinae
io.druid.query.groupby.strategy
io.druid.query.metadata
io.druid.query.scan
io.druid.query.search
io.druid.query.select
io.druid.query.spec
io.druid.query.timeboundary
io.druid.query.timeseries
io.druid.query.topn
io.druid.segment.realtime
io.druid.segment.realtime.appenderator
io.druid.segment.realtime.plumber
io.druid.server
io.druid.server.coordination

Uses of QueryRunner in io.druid.benchmark.query

Classes in io.druid.benchmark.query that implement QueryRunner

Modifier and Type	Class and Description
class	SerializingQueryRunner<T>

Methods in io.druid.benchmark.query that return QueryRunner

Modifier and Type	Method and Description
static <T,QueryType extends Query<T>> QueryRunner<T>	QueryBenchmarkUtil.makeQueryRunner(QueryRunnerFactory<T,QueryType> factory, String segmentId, Segment adapter)

Constructors in io.druid.benchmark.query with parameters of type QueryRunner

Constructor and Description
SerializingQueryRunner(com.fasterxml.jackson.databind.ObjectMapper smileMapper, Class<T> clazz, QueryRunner<T> baseRunner)

Uses of QueryRunner in io.druid.client

Classes in io.druid.client that implement QueryRunner

Modifier and Type	Class and Description
class	CachingQueryRunner<T>
class	DirectDruidClient<T>

Methods in io.druid.client that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	TimelineServerView.getQueryRunner(DruidServer server)
<T> QueryRunner<T>	BrokerServerView.getQueryRunner(DruidServer server)
<T> QueryRunner<T>	CachingClusteredClient.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals)
<T> QueryRunner<T>	CachingClusteredClient.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs)

Constructors in io.druid.client with parameters of type QueryRunner

Constructor and Description
CachingQueryRunner(String segmentIdentifier, SegmentDescriptor segmentDescriptor, com.fasterxml.jackson.databind.ObjectMapper mapper, Cache cache, QueryToolChest toolchest, QueryRunner<T> base, ExecutorService backgroundExecutorService, CacheConfig cacheConfig)

Uses of QueryRunner in io.druid.indexing.common.task

Methods in io.druid.indexing.common.task that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	Task.getQueryRunner(Query<T> query) Returns query runners for this task.
<T> QueryRunner<T>	RealtimeIndexTask.getQueryRunner(Query<T> query)
<T> QueryRunner<T>	AbstractTask.getQueryRunner(Query<T> query)

Uses of QueryRunner in io.druid.indexing.kafka

Methods in io.druid.indexing.kafka that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	KafkaIndexTask.getQueryRunner(Query<T> query)

Uses of QueryRunner in io.druid.indexing.overlord

Methods in io.druid.indexing.overlord that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	ThreadPoolTaskRunner.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals)
<T> QueryRunner<T>	ThreadPoolTaskRunner.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs)

Uses of QueryRunner in io.druid.query

Classes in io.druid.query that implement QueryRunner

Modifier and Type	Class and Description
class	AsyncQueryRunner<T>
class	BySegmentQueryRunner<T>
class	BySegmentSkippingQueryRunner<T>
class	ChainedExecutionQueryRunner<T> A QueryRunner that combines a list of other QueryRunners and executes them in parallel on an executor.
class	ConcatQueryRunner<T>
class	CPUTimeMetricQueryRunner<T>
class	FinalizeResultsQueryRunner<T>
class	FluentQueryRunnerBuilder.FluentQueryRunner
class	GroupByMergedQueryRunner<T>
class	IntervalChunkingQueryRunner<T>
class	MetricsEmittingQueryRunner<T>
class	NoopQueryRunner<T>
class	ReferenceCountingSegmentQueryRunner<T>
class	ReportTimelineMissingSegmentQueryRunner<T>
class	ResultMergeQueryRunner<T>
class	RetryQueryRunner<T>
class	SubqueryQueryRunner<T> If there's a subquery, run it instead of the outer query
class	UnionQueryRunner<T>

Methods in io.druid.query that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<T>	QueryRunnerFactory.createRunner(Segment segment) Given a specific segment, this method will create a QueryRunner.
<T> QueryRunner<T>	IntervalChunkingQueryRunnerDecorator.decorate(QueryRunner<T> delegate, QueryToolChest<T,? extends Query<T>> toolChest)
<T> QueryRunner<T>	QuerySegmentWalker.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals) Gets the Queryable for a given interval, the Queryable returned can be any version(s) or partitionNumber(s) such that it represents the interval.
<T> QueryRunner<T>	QuerySegmentWalker.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs) Gets the Queryable for a given list of SegmentSpecs.
QueryRunner<T>	Query.getRunner(QuerySegmentWalker walker)
QueryRunner<T>	BaseQuery.getRunner(QuerySegmentWalker walker)
static <T> QueryRunner<T>	QueryRunnerHelper.makeClosingQueryRunner(QueryRunner<T> runner, Closeable closeable)
abstract QueryRunner<ResultType>	QueryToolChest.mergeResults(QueryRunner<ResultType> runner) This method wraps a QueryRunner.
QueryRunner<T>	QueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, 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 ExecutorService.
QueryRunner<ResultType>	QueryToolChest.postMergeQueryDecoration(QueryRunner<ResultType> runner) Wraps a QueryRunner.
QueryRunner<T>	TimewarpOperator.postProcess(QueryRunner<T> baseQueryRunner)
QueryRunner<T>	PostProcessingOperator.postProcess(QueryRunner<T> baseQueryRunner)
QueryRunner<T>	TimewarpOperator.postProcess(QueryRunner<T> baseRunner, long now)
QueryRunner<ResultType>	QueryToolChest.preMergeQueryDecoration(QueryRunner<ResultType> runner) Wraps a QueryRunner.
static <T> QueryRunner<T>	CPUTimeMetricQueryRunner.safeBuild(QueryRunner<T> delegate, QueryToolChest<T,? extends Query<T>> queryToolChest, ServiceEmitter emitter, AtomicLong accumulator, boolean report)

Methods in io.druid.query with parameters of type QueryRunner

Modifier and Type	Method and Description
FluentQueryRunnerBuilder.FluentQueryRunner	FluentQueryRunnerBuilder.create(QueryRunner<T> baseRunner)
<T> QueryRunner<T>	IntervalChunkingQueryRunnerDecorator.decorate(QueryRunner<T> delegate, QueryToolChest<T,? extends Query<T>> toolChest)
Sequence<T>	ResultMergeQueryRunner.doRun(QueryRunner<T> baseRunner, QueryPlus<T> queryPlus, Map<String,Object> context)
protected abstract Sequence<T>	BySegmentSkippingQueryRunner.doRun(QueryRunner<T> baseRunner, QueryPlus<T> queryPlus, Map<String,Object> context)
FluentQueryRunnerBuilder.FluentQueryRunner	FluentQueryRunnerBuilder.FluentQueryRunner.from(QueryRunner<T> runner)
static <T> QueryRunner<T>	QueryRunnerHelper.makeClosingQueryRunner(QueryRunner<T> runner, Closeable closeable)
abstract QueryRunner<ResultType>	QueryToolChest.mergeResults(QueryRunner<ResultType> runner) This method wraps a QueryRunner.
QueryRunner<ResultType>	QueryToolChest.postMergeQueryDecoration(QueryRunner<ResultType> runner) Wraps a QueryRunner.
QueryRunner<T>	TimewarpOperator.postProcess(QueryRunner<T> baseQueryRunner)
QueryRunner<T>	PostProcessingOperator.postProcess(QueryRunner<T> baseQueryRunner)
QueryRunner<T>	TimewarpOperator.postProcess(QueryRunner<T> baseRunner, long now)
QueryRunner<ResultType>	QueryToolChest.preMergeQueryDecoration(QueryRunner<ResultType> runner) Wraps a QueryRunner.
static <T> QueryRunner<T>	CPUTimeMetricQueryRunner.safeBuild(QueryRunner<T> delegate, QueryToolChest<T,? extends Query<T>> queryToolChest, ServiceEmitter emitter, AtomicLong accumulator, boolean report)

Method parameters in io.druid.query with type arguments of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<T>	QueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, 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 ExecutorService.

Constructors in io.druid.query with parameters of type QueryRunner

Constructor and Description
AsyncQueryRunner(QueryRunner<T> baseRunner, ExecutorService executor, QueryWatcher queryWatcher)
BySegmentQueryRunner(String segmentIdentifier, org.joda.time.DateTime timestamp, QueryRunner<T> base)
BySegmentSkippingQueryRunner(QueryRunner<T> baseRunner)
ChainedExecutionQueryRunner(ExecutorService exec, QueryWatcher queryWatcher, QueryRunner<T>... queryables)
FinalizeResultsQueryRunner(QueryRunner<T> baseRunner, QueryToolChest<T,Query<T>> toolChest)
FluentQueryRunner(QueryRunner<T> runner)
IntervalChunkingQueryRunner(QueryRunner<T> baseRunner, QueryToolChest<T,Query<T>> toolChest, ExecutorService executor, QueryWatcher queryWatcher, ServiceEmitter emitter)
MetricsEmittingQueryRunner(ServiceEmitter emitter, QueryToolChest<T,? extends Query<T>> queryToolChest, QueryRunner<T> queryRunner, ObjLongConsumer<? super QueryMetrics<?>> reportMetric, Consumer<QueryMetrics<?>> applyCustomDimensions)
ResultMergeQueryRunner(QueryRunner<T> baseRunner)
RetryQueryRunner(QueryRunner<T> baseRunner, RetryQueryRunnerConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
SubqueryQueryRunner(QueryRunner<T> baseRunner)
UnionQueryRunner(QueryRunner<T> baseRunner)

Constructor parameters in io.druid.query with type arguments of type QueryRunner

Constructor and Description
ChainedExecutionQueryRunner(ExecutorService exec, QueryWatcher queryWatcher, Iterable<QueryRunner<T>> queryables)
ConcatQueryRunner(Sequence<QueryRunner<T>> queryRunners)
GroupByMergedQueryRunner(ExecutorService exec, com.google.common.base.Supplier<GroupByQueryConfig> configSupplier, QueryWatcher queryWatcher, NonBlockingPool<ByteBuffer> bufferPool, Iterable<QueryRunner<T>> queryables)

Uses of QueryRunner in io.druid.query.datasourcemetadata

Methods in io.druid.query.datasourcemetadata that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<DataSourceMetadataResultValue>>	DataSourceMetadataQueryRunnerFactory.createRunner(Segment segment)
QueryRunner<Result<DataSourceMetadataResultValue>>	DataSourceQueryQueryToolChest.mergeResults(QueryRunner<Result<DataSourceMetadataResultValue>> runner)
QueryRunner<Result<DataSourceMetadataResultValue>>	DataSourceMetadataQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<Result<DataSourceMetadataResultValue>>> queryRunners)

Methods in io.druid.query.datasourcemetadata with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<DataSourceMetadataResultValue>>	DataSourceQueryQueryToolChest.mergeResults(QueryRunner<Result<DataSourceMetadataResultValue>> runner)

Method parameters in io.druid.query.datasourcemetadata with type arguments of type QueryRunner

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

Uses of QueryRunner in io.druid.query.groupby

Methods in io.druid.query.groupby that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<Row>	GroupByQueryRunnerFactory.createRunner(Segment segment)
QueryRunner<Row>	GroupByQueryQueryToolChest.mergeResults(QueryRunner<Row> runner)
QueryRunner<Row>	GroupByQueryRunnerFactory.mergeRunners(ExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Row> runner)

Methods in io.druid.query.groupby with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Row>	GroupByQueryQueryToolChest.mergeResults(QueryRunner<Row> runner)
QueryRunner<Row>	GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Row> runner)

Method parameters in io.druid.query.groupby with type arguments of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Row>	GroupByQueryRunnerFactory.mergeRunners(ExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)

Uses of QueryRunner in io.druid.query.groupby.epinephelinae

Classes in io.druid.query.groupby.epinephelinae that implement QueryRunner

Modifier and Type	Class and Description
class	GroupByMergingQueryRunnerV2

Constructor parameters in io.druid.query.groupby.epinephelinae with type arguments of type QueryRunner

Constructor and Description
GroupByMergingQueryRunnerV2(GroupByQueryConfig config, ExecutorService exec, QueryWatcher queryWatcher, Iterable<QueryRunner<Row>> queryables, int concurrencyHint, NonBlockingPool<ByteBuffer> processingBufferPool, BlockingPool<ByteBuffer> mergeBufferPool, int mergeBufferSize, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir)

Uses of QueryRunner in io.druid.query.groupby.strategy

Methods in io.druid.query.groupby.strategy that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<Row>	GroupByStrategyV2.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest)
QueryRunner<Row>	GroupByStrategyV1.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest)
QueryRunner<Row>	GroupByStrategy.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest) Decorate a runner with an interval chunking decorator.
QueryRunner<Row>	GroupByStrategyV2.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByStrategyV1.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByStrategy.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)

Methods in io.druid.query.groupby.strategy with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Row>	GroupByStrategyV2.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest)
QueryRunner<Row>	GroupByStrategyV1.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest)
QueryRunner<Row>	GroupByStrategy.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest) Decorate a runner with an interval chunking decorator.
Sequence<Row>	GroupByStrategyV2.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategyV1.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategy.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)

Method parameters in io.druid.query.groupby.strategy with type arguments of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Row>	GroupByStrategyV2.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByStrategyV1.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByStrategy.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)

Uses of QueryRunner in io.druid.query.metadata

Methods in io.druid.query.metadata that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<SegmentAnalysis>	SegmentMetadataQueryRunnerFactory.createRunner(Segment segment)
QueryRunner<SegmentAnalysis>	SegmentMetadataQueryQueryToolChest.mergeResults(QueryRunner<SegmentAnalysis> runner)
QueryRunner<SegmentAnalysis>	SegmentMetadataQueryRunnerFactory.mergeRunners(ExecutorService exec, Iterable<QueryRunner<SegmentAnalysis>> queryRunners)

Methods in io.druid.query.metadata with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<SegmentAnalysis>	SegmentMetadataQueryQueryToolChest.mergeResults(QueryRunner<SegmentAnalysis> runner)

Method parameters in io.druid.query.metadata with type arguments of type QueryRunner

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

Uses of QueryRunner in io.druid.query.scan

Methods in io.druid.query.scan that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<ScanResultValue>	ScanQueryRunnerFactory.createRunner(Segment segment)
QueryRunner<ScanResultValue>	ScanQueryQueryToolChest.mergeResults(QueryRunner<ScanResultValue> runner)
QueryRunner<ScanResultValue>	ScanQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<ScanResultValue>> queryRunners)
QueryRunner<ScanResultValue>	ScanQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<ScanResultValue> runner)

Methods in io.druid.query.scan with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<ScanResultValue>	ScanQueryQueryToolChest.mergeResults(QueryRunner<ScanResultValue> runner)
QueryRunner<ScanResultValue>	ScanQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<ScanResultValue> runner)

Method parameters in io.druid.query.scan with type arguments of type QueryRunner

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

Constructors in io.druid.query.scan with parameters of type QueryRunner

Constructor and Description
ScanQueryLimitRowIterator(QueryRunner<ScanResultValue> baseRunner, QueryPlus<ScanResultValue> queryPlus, Map<String,Object> responseContext)

Uses of QueryRunner in io.druid.query.search

Classes in io.druid.query.search that implement QueryRunner

Modifier and Type	Class and Description
class	SearchQueryRunner

Methods in io.druid.query.search that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<SearchResultValue>>	SearchQueryRunnerFactory.createRunner(Segment segment)
QueryRunner<Result<SearchResultValue>>	SearchQueryQueryToolChest.mergeResults(QueryRunner<Result<SearchResultValue>> runner)
QueryRunner<Result<SearchResultValue>>	SearchQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<Result<SearchResultValue>>> queryRunners)
QueryRunner<Result<SearchResultValue>>	SearchQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SearchResultValue>> runner)

Methods in io.druid.query.search with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<SearchResultValue>>	SearchQueryQueryToolChest.mergeResults(QueryRunner<Result<SearchResultValue>> runner)
QueryRunner<Result<SearchResultValue>>	SearchQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SearchResultValue>> runner)

Method parameters in io.druid.query.search with type arguments of type QueryRunner

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

Uses of QueryRunner in io.druid.query.select

Methods in io.druid.query.select that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<SelectResultValue>>	SelectQueryRunnerFactory.createRunner(Segment segment)
QueryRunner<Result<SelectResultValue>>	SelectQueryQueryToolChest.mergeResults(QueryRunner<Result<SelectResultValue>> queryRunner)
QueryRunner<Result<SelectResultValue>>	SelectQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<Result<SelectResultValue>>> queryRunners)
QueryRunner<Result<SelectResultValue>>	SelectQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SelectResultValue>> runner)

Methods in io.druid.query.select with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<SelectResultValue>>	SelectQueryQueryToolChest.mergeResults(QueryRunner<Result<SelectResultValue>> queryRunner)
QueryRunner<Result<SelectResultValue>>	SelectQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SelectResultValue>> runner)

Method parameters in io.druid.query.select with type arguments of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<SelectResultValue>>	SelectQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<Result<SelectResultValue>>> queryRunners)

Uses of QueryRunner in io.druid.query.spec

Classes in io.druid.query.spec that implement QueryRunner

Modifier and Type	Class and Description
class	SpecificSegmentQueryRunner<T>

Methods in io.druid.query.spec that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	SpecificSegmentSpec.lookup(Query<T> query, QuerySegmentWalker walker)
<T> QueryRunner<T>	QuerySegmentSpec.lookup(Query<T> query, QuerySegmentWalker walker)
<T> QueryRunner<T>	MultipleSpecificSegmentSpec.lookup(Query<T> query, QuerySegmentWalker walker)
<T> QueryRunner<T>	MultipleIntervalSegmentSpec.lookup(Query<T> query, QuerySegmentWalker walker)

Constructors in io.druid.query.spec with parameters of type QueryRunner

Constructor and Description
SpecificSegmentQueryRunner(QueryRunner<T> base, SpecificSegmentSpec specificSpec)

Uses of QueryRunner in io.druid.query.timeboundary

Methods in io.druid.query.timeboundary that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<TimeBoundaryResultValue>>	TimeBoundaryQueryRunnerFactory.createRunner(Segment segment)
QueryRunner<Result<TimeBoundaryResultValue>>	TimeBoundaryQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeBoundaryResultValue>> runner)
QueryRunner<Result<TimeBoundaryResultValue>>	TimeBoundaryQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<Result<TimeBoundaryResultValue>>> queryRunners)

Methods in io.druid.query.timeboundary with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<TimeBoundaryResultValue>>	TimeBoundaryQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeBoundaryResultValue>> runner)

Method parameters in io.druid.query.timeboundary with type arguments of type QueryRunner

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

Uses of QueryRunner in io.druid.query.timeseries

Methods in io.druid.query.timeseries that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<TimeseriesResultValue>>	TimeseriesQueryRunnerFactory.createRunner(Segment segment)
QueryRunner<Result<TimeseriesResultValue>>	TimeseriesQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeseriesResultValue>> queryRunner)
QueryRunner<Result<TimeseriesResultValue>>	TimeseriesQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<Result<TimeseriesResultValue>>> queryRunners)
QueryRunner<Result<TimeseriesResultValue>>	TimeseriesQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TimeseriesResultValue>> runner)

Methods in io.druid.query.timeseries with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<TimeseriesResultValue>>	TimeseriesQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeseriesResultValue>> queryRunner)
QueryRunner<Result<TimeseriesResultValue>>	TimeseriesQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TimeseriesResultValue>> runner)

Method parameters in io.druid.query.timeseries with type arguments of type QueryRunner

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

Uses of QueryRunner in io.druid.query.topn

Methods in io.druid.query.topn that return QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<TopNResultValue>>	TopNQueryRunnerFactory.createRunner(Segment segment)
QueryRunner<Result<TopNResultValue>>	TopNQueryQueryToolChest.mergeResults(QueryRunner<Result<TopNResultValue>> runner)
QueryRunner<Result<TopNResultValue>>	TopNQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<Result<TopNResultValue>>> queryRunners)
QueryRunner<Result<TopNResultValue>>	TopNQueryQueryToolChest.postMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner)
QueryRunner<Result<TopNResultValue>>	TopNQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner)

Methods in io.druid.query.topn with parameters of type QueryRunner

Modifier and Type	Method and Description
QueryRunner<Result<TopNResultValue>>	TopNQueryQueryToolChest.mergeResults(QueryRunner<Result<TopNResultValue>> runner)
QueryRunner<Result<TopNResultValue>>	TopNQueryQueryToolChest.postMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner)
QueryRunner<Result<TopNResultValue>>	TopNQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner)

Method parameters in io.druid.query.topn with type arguments of type QueryRunner

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

Uses of QueryRunner in io.druid.segment.realtime

Methods in io.druid.segment.realtime that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	RealtimeManager.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals)
<T> QueryRunner<T>	RealtimeManager.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs)

Uses of QueryRunner in io.druid.segment.realtime.appenderator

Methods in io.druid.segment.realtime.appenderator that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	AppenderatorPlumber.getQueryRunner(Query<T> query)
<T> QueryRunner<T>	SinkQuerySegmentWalker.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals)
<T> QueryRunner<T>	AppenderatorImpl.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals)
<T> QueryRunner<T>	SinkQuerySegmentWalker.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs)
<T> QueryRunner<T>	AppenderatorImpl.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs)

Uses of QueryRunner in io.druid.segment.realtime.plumber

Methods in io.druid.segment.realtime.plumber that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	RealtimePlumber.getQueryRunner(Query<T> query)
<T> QueryRunner<T>	Plumber.getQueryRunner(Query<T> query)

Uses of QueryRunner in io.druid.server

Classes in io.druid.server that implement QueryRunner

Modifier and Type	Class and Description
class	SetAndVerifyContextQueryRunner Use this QueryRunner to set and verify Query contexts.

Methods in io.druid.server that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	DirectClientQuerySegmentWalker.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals)
<T> QueryRunner<T>	ClientQuerySegmentWalker.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals)
<T> QueryRunner<T>	DirectClientQuerySegmentWalker.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs)
<T> QueryRunner<T>	ClientQuerySegmentWalker.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs)

Constructors in io.druid.server with parameters of type QueryRunner

Constructor and Description
SetAndVerifyContextQueryRunner(ServerConfig serverConfig, QueryRunner baseRunner)

Uses of QueryRunner in io.druid.server.coordination

Methods in io.druid.server.coordination that return QueryRunner

Modifier and Type	Method and Description
<T> QueryRunner<T>	ServerManager.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals)
<T> QueryRunner<T>	ServerManager.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs)