Uses of Interface
io.druid.query.QueryRunner

Packages that use QueryRunner

Package	Description
io.druid.client
io.druid.indexing.common.task
io.druid.indexing.overlord
io.druid.query
io.druid.query.groupby
io.druid.query.metadata
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.plumber
io.druid.server
io.druid.server.bridge
io.druid.server.coordination

Uses of QueryRunner in io.druid.client

Classes in io.druid.client that implement QueryRunner

Modifier and Type	Class and Description
class	CachingClusteredClient<T>
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)

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

Constructor and Description
CachingQueryRunner(String segmentIdentifier, io.druid.query.SegmentDescriptor segmentDescriptor, com.fasterxml.jackson.databind.ObjectMapper mapper, Cache cache, QueryToolChest toolchest, QueryRunner<T> base, 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.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<io.druid.query.SegmentDescriptor> specs)

Uses of QueryRunner in io.druid.query

Classes in io.druid.query that implement QueryRunner

Modifier and Type	Class and Description
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	FinalizeResultsQueryRunner<T>
class	GroupByParallelQueryRunner<T>
class	IntervalChunkingQueryRunner<T>
class	MetricsEmittingQueryRunner<T>
class	NoopQueryRunner<T>
class	ReferenceCountingSegmentQueryRunner<T>
class	ResultMergeQueryRunner<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)
<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<io.druid.query.SegmentDescriptor> specs) Gets the Queryable for a given list of SegmentSpecs.
abstract QueryRunner<ResultType>	QueryToolChest.mergeResults(QueryRunner<ResultType> runner)
QueryRunner<T>	QueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<T>> queryRunners)
QueryRunner<ResultType>	QueryToolChest.postMergeQueryDecoration(QueryRunner<ResultType> runner)
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)

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

Modifier and Type	Method and Description
com.metamx.common.guava.Sequence<T>	ResultMergeQueryRunner.doRun(QueryRunner<T> baseRunner, Query<T> query)
protected abstract com.metamx.common.guava.Sequence<T>	BySegmentSkippingQueryRunner.doRun(QueryRunner<T> baseRunner, Query<T> query)
abstract QueryRunner<ResultType>	QueryToolChest.mergeResults(QueryRunner<ResultType> runner)
QueryRunner<ResultType>	QueryToolChest.postMergeQueryDecoration(QueryRunner<ResultType> runner)
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)
com.metamx.common.guava.Sequence<T>	Query.run(QueryRunner<T> runner)
com.metamx.common.guava.Sequence<T>	BaseQuery.run(QueryRunner<T> runner)

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)

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

Constructor and Description
BySegmentQueryRunner(String segmentIdentifier, org.joda.time.DateTime timestamp, QueryRunner<T> base)
BySegmentSkippingQueryRunner(QueryRunner<T> baseRunner)
ChainedExecutionQueryRunner(ExecutorService exec, com.google.common.collect.Ordering<T> ordering, QueryWatcher queryWatcher, QueryRunner<T>... queryables)
FinalizeResultsQueryRunner(QueryRunner<T> baseRunner, QueryToolChest<T,Query<T>> toolChest)
IntervalChunkingQueryRunner(QueryRunner<T> baseRunner, org.joda.time.Period period)
MetricsEmittingQueryRunner(com.metamx.emitter.service.ServiceEmitter emitter, com.google.common.base.Function<Query<T>,com.metamx.emitter.service.ServiceMetricEvent.Builder> builderFn, QueryRunner<T> queryRunner)
MetricsEmittingQueryRunner(com.metamx.emitter.service.ServiceEmitter emitter, com.google.common.base.Function<Query<T>,com.metamx.emitter.service.ServiceMetricEvent.Builder> builderFn, QueryRunner<T> queryRunner, long creationTime, String metricName)
MetricsEmittingQueryRunner(com.metamx.emitter.service.ServiceEmitter emitter, com.google.common.base.Function<Query<T>,com.metamx.emitter.service.ServiceMetricEvent.Builder> builderFn, QueryRunner<T> queryRunner, String metricName)
ResultMergeQueryRunner(QueryRunner<T> baseRunner)
SubqueryQueryRunner(QueryRunner<T> baseRunner)
UnionQueryRunner(QueryRunner<T> baseRunner, QueryToolChest<T,Query<T>> toolChest)

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

Constructor and Description
ChainedExecutionQueryRunner(ExecutorService exec, com.google.common.collect.Ordering<T> ordering, QueryWatcher queryWatcher, Iterable<QueryRunner<T>> queryables)
ConcatQueryRunner(com.metamx.common.guava.Sequence<QueryRunner<T>> queryRunners)
GroupByParallelQueryRunner(ExecutorService exec, com.google.common.base.Supplier<GroupByQueryConfig> configSupplier, QueryWatcher queryWatcher, Iterable<QueryRunner<T>> queryables)

Uses of QueryRunner in io.druid.query.groupby

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

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

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

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

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

Modifier and Type	Method and Description
QueryRunner<io.druid.data.input.Row>	GroupByQueryRunnerFactory.mergeRunners(ExecutorService exec, Iterable<QueryRunner<io.druid.data.input.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.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, QuerySegmentSpec 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<io.druid.query.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

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<io.druid.query.SegmentDescriptor> specs)
<T> QueryRunner<T>	ClientQuerySegmentWalker.getQueryRunnerForSegments(Query<T> query, Iterable<io.druid.query.SegmentDescriptor> specs)

Uses of QueryRunner in io.druid.server.bridge

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

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

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<io.druid.query.SegmentDescriptor> specs)