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
QueryRunner s. |
<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.