Modifier and Type | Class and Description |
---|---|
class |
CachingClusteredClient<T> |
class |
CachingQueryRunner<T> |
class |
DirectDruidClient<T> |
Modifier and Type | Method and Description |
---|---|
<T> QueryRunner<T> |
TimelineServerView.getQueryRunner(DruidServer server) |
<T> QueryRunner<T> |
BrokerServerView.getQueryRunner(DruidServer server) |
Constructor and Description |
---|
CachingQueryRunner(String segmentIdentifier,
io.druid.query.SegmentDescriptor segmentDescriptor,
com.fasterxml.jackson.databind.ObjectMapper mapper,
Cache cache,
QueryToolChest toolchest,
QueryRunner<T> base,
ExecutorService backgroundExecutorService,
CacheConfig cacheConfig) |
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) |
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) |
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 |
FinalizeResultsQueryRunner<T> |
class |
GroupByParallelQueryRunner<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> |
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<io.druid.query.SegmentDescriptor> specs)
Gets the Queryable for a given list of SegmentSpecs.
|
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.
|
Modifier and Type | Method and Description |
---|---|
<T> QueryRunner<T> |
IntervalChunkingQueryRunnerDecorator.decorate(QueryRunner<T> delegate,
QueryToolChest<T,? extends Query<T>> toolChest) |
com.metamx.common.guava.Sequence<T> |
ResultMergeQueryRunner.doRun(QueryRunner<T> baseRunner,
Query<T> query,
Map<String,Object> context) |
protected abstract com.metamx.common.guava.Sequence<T> |
BySegmentSkippingQueryRunner.doRun(QueryRunner<T> baseRunner,
Query<T> query,
Map<String,Object> context) |
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.
|
com.metamx.common.guava.Sequence<T> |
Query.run(QueryRunner<T> runner,
Map<String,Object> context) |
com.metamx.common.guava.Sequence<T> |
BaseQuery.run(QueryRunner<T> runner,
Map<String,Object> context) |
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.
|
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,
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,
QueryToolChest<T,Query<T>> toolChest,
ExecutorService executor,
QueryWatcher queryWatcher,
com.metamx.emitter.service.ServiceEmitter emitter) |
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,
Map<String,String> userDimensions) |
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,
Map<String,String> userDimensions) |
ResultMergeQueryRunner(QueryRunner<T> baseRunner) |
RetryQueryRunner(QueryRunner<T> baseRunner,
QueryToolChest<T,Query<T>> toolChest,
RetryQueryRunnerConfig config,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
SubqueryQueryRunner(QueryRunner<T> baseRunner) |
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,
StupidPool<ByteBuffer> bufferPool,
Iterable<QueryRunner<T>> queryables) |
UnionQueryRunner(Iterable<QueryRunner> baseRunners,
QueryToolChest<T,Query<T>> toolChest) |
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) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<DataSourceMetadataResultValue>> |
DataSourceQueryQueryToolChest.mergeResults(QueryRunner<Result<DataSourceMetadataResultValue>> runner) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<DataSourceMetadataResultValue>> |
DataSourceMetadataQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<DataSourceMetadataResultValue>>> queryRunners) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<io.druid.data.input.Row> |
GroupByQueryRunnerFactory.mergeRunners(ExecutorService exec,
Iterable<QueryRunner<io.druid.data.input.Row>> queryRunners) |
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) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<SegmentAnalysis> |
SegmentMetadataQueryQueryToolChest.mergeResults(QueryRunner<SegmentAnalysis> runner) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<SegmentAnalysis> |
SegmentMetadataQueryRunnerFactory.mergeRunners(ExecutorService exec,
Iterable<QueryRunner<SegmentAnalysis>> queryRunners) |
Modifier and Type | Class and Description |
---|---|
class |
SearchQueryRunner |
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) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<SearchResultValue>> |
SearchQueryQueryToolChest.mergeResults(QueryRunner<Result<SearchResultValue>> runner) |
QueryRunner<Result<SearchResultValue>> |
SearchQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SearchResultValue>> runner) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<SearchResultValue>> |
SearchQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<SearchResultValue>>> queryRunners) |
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) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<SelectResultValue>> |
SelectQueryQueryToolChest.mergeResults(QueryRunner<Result<SelectResultValue>> queryRunner) |
QueryRunner<Result<SelectResultValue>> |
SelectQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SelectResultValue>> runner) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<SelectResultValue>> |
SelectQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<SelectResultValue>>> queryRunners) |
Modifier and Type | Class and Description |
---|---|
class |
SpecificSegmentQueryRunner<T> |
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) |
Constructor and Description |
---|
SpecificSegmentQueryRunner(QueryRunner<T> base,
SpecificSegmentSpec specificSpec) |
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) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeBoundaryResultValue>> runner) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<TimeBoundaryResultValue>> |
TimeBoundaryQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<TimeBoundaryResultValue>>> queryRunners) |
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) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<TimeseriesResultValue>> |
TimeseriesQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeseriesResultValue>> queryRunner) |
QueryRunner<Result<TimeseriesResultValue>> |
TimeseriesQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TimeseriesResultValue>> runner) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<TimeseriesResultValue>> |
TimeseriesQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<TimeseriesResultValue>>> queryRunners) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
QueryRunner<Result<TopNResultValue>> |
TopNQueryRunnerFactory.mergeRunners(ExecutorService queryExecutor,
Iterable<QueryRunner<Result<TopNResultValue>>> queryRunners) |
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) |
Modifier and Type | Method and Description |
---|---|
<T> QueryRunner<T> |
RealtimePlumber.getQueryRunner(Query<T> query) |
<T> QueryRunner<T> |
Plumber.getQueryRunner(Query<T> query) |
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) |
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) |
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) |
Copyright © 2011–2015. All rights reserved.