| Package | Description | 
|---|---|
| io.druid.benchmark.query | |
| io.druid.client | |
| io.druid.query | |
| io.druid.query.groupby.epinephelinae | |
| io.druid.query.scan | |
| io.druid.query.search | |
| io.druid.query.spec | |
| io.druid.server | 
| Modifier and Type | Method and Description | 
|---|---|
Sequence<T> | 
SerializingQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
Sequence<T> | 
DirectDruidClient.run(QueryPlus<T> queryPlus,
   Map<String,Object> context)  | 
Sequence<T> | 
CachingQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
QueryPlus<T> | 
QueryPlus.withoutThreadUnsafeState()
Returns a QueryPlus object without the components which are unsafe for concurrent use from multiple threads,
 therefore couldn't be passed down in concurrent or async  
QueryRunners. | 
<U> QueryPlus<U> | 
QueryPlus.withQuery(Query<U> replacementQuery)
Returns a QueryPlus object with  
QueryMetrics from this QueryPlus object, and the provided Query. | 
QueryPlus<T> | 
QueryPlus.withQueryMetrics(QueryToolChest<T,? extends Query<T>> queryToolChest)
Returns the same QueryPlus object, if it already has  
QueryMetrics (getQueryMetrics() returns not
 null), or returns a new QueryPlus object with Query from this QueryPlus and QueryMetrics created using the
 given QueryToolChest, via QueryToolChest.makeMetrics(Query) method. | 
QueryPlus<T> | 
QueryPlus.withQuerySegmentSpec(QuerySegmentSpec spec)
Equivalent of withQuery(getQuery().withQuerySegmentSpec(spec)). 
 | 
static <T> QueryPlus<T> | 
QueryPlus.wrap(Query<T> query)
Returns the minimum bare QueryPlus object with the given query. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
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)  | 
Sequence<T> | 
UnionQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
SubqueryQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
RetryQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> context)  | 
Sequence<T> | 
ReportTimelineMissingSegmentQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
ReferenceCountingSegmentQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
QueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)
Runs the given query and returns results in a time-ordered sequence. 
 | 
Sequence<T> | 
NoopQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
MetricsEmittingQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
IntervalChunkingQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
GroupByMergedQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
FluentQueryRunnerBuilder.FluentQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
FinalizeResultsQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
ConcatQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
ChainedExecutionQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
CPUTimeMetricQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
BySegmentSkippingQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
BySegmentQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
Sequence<T> | 
AsyncQueryRunner.run(QueryPlus<T> queryPlus,
   Map<String,Object> responseContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
Sequence<Row> | 
GroupByMergingQueryRunnerV2.run(QueryPlus<Row> queryPlus,
   Map<String,Object> responseContext)  | 
| Constructor and Description | 
|---|
ScanQueryLimitRowIterator(QueryRunner<ScanResultValue> baseRunner,
                         QueryPlus<ScanResultValue> queryPlus,
                         Map<String,Object> responseContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
Sequence<Result<SearchResultValue>> | 
SearchQueryRunner.run(QueryPlus<Result<SearchResultValue>> queryPlus,
   Map<String,Object> responseContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
Sequence<T> | 
SpecificSegmentQueryRunner.run(QueryPlus<T> input,
   Map<String,Object> responseContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
Sequence | 
SetAndVerifyContextQueryRunner.run(QueryPlus queryPlus,
   Map responseContext)  | 
Copyright © 2011–2018. All rights reserved.