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 | Class and Description |
---|---|
class |
OrderedMergeSequence<T>
An OrderedMergeIterator is an iterator that merges together multiple sorted iterators.
|
Constructor and Description |
---|
OrderedMergeSequence(com.google.common.collect.Ordering<T> ordering,
Sequence<Sequence<T>> sequences) |
Constructor and Description |
---|
OrderedMergeSequence(com.google.common.collect.Ordering<T> ordering,
Sequence<Sequence<T>> sequences) |
Modifier and Type | Class and Description |
---|---|
class |
CombiningSequence<T> |
Modifier and Type | Method and Description |
---|---|
static <T> CombiningSequence<T> |
CombiningSequence.create(Sequence<T> baseSequence,
com.google.common.collect.Ordering<T> ordering,
BinaryFn<T,T,T> mergeFn) |
Modifier and Type | Class and Description |
---|---|
class |
BaseSequence<T,IterType extends Iterator<T>> |
class |
ConcatSequence<T> |
class |
FilteredSequence<T> |
class |
LazySequence<T> |
class |
MappedSequence<T,Out> |
class |
MergeSequence<T> |
class |
YieldingSequenceBase<T>
A Sequence that is based entirely on the Yielder implementation.
|
Modifier and Type | Method and Description |
---|---|
static <T> Sequence<T> |
Sequences.concat(Iterable<Sequence<T>> sequences) |
static <T> Sequence<T> |
Sequences.concat(Sequence<? extends Sequence<T>> sequences) |
static <T> Sequence<T> |
Sequences.concat(Sequence<T>... sequences) |
static <T> Sequence<T> |
Sequences.empty() |
static <T> Sequence<T> |
Sequences.filter(Sequence<T> sequence,
com.google.common.base.Predicate<T> pred) |
default <R> Sequence<R> |
Sequence.flatMap(Function<? super T,? extends Sequence<? extends R>> mapper) |
default <R> Sequence<R> |
Sequence.flatMerge(Function<? super T,? extends Sequence<? extends R>> mapper,
com.google.common.collect.Ordering<? super R> ordering) |
static <T> Sequence<T> |
Sequences.limit(Sequence<T> sequence,
int limit) |
default <U> Sequence<U> |
Sequence.map(Function<? super T,? extends U> mapper) |
static <From,To> Sequence<To> |
Sequences.map(Sequence<From> sequence,
com.google.common.base.Function<? super From,? extends To> fn) |
static <T> Sequence<T> |
Sequences.simple(Iterable<T> iterable) |
static <T> Sequence<T> |
Sequences.sort(Sequence<T> sequence,
Comparator<T> comparator) |
default Sequence<T> |
Sequence.withBaggage(Closeable baggage) |
static <T> Sequence<T> |
Sequences.withBaggage(Sequence<T> seq,
Closeable baggage) |
default Sequence<T> |
Sequence.withEffect(Runnable effect,
Executor effectExecutor) |
static <T> Sequence<T> |
Sequences.withEffect(Sequence<T> seq,
Runnable effect,
Executor exec) |
static <T> Sequence<T> |
Sequences.wrap(Sequence<T> seq,
SequenceWrapper wrapper)
Allows to execute something before, after or around the processing of the given sequence.
|
Modifier and Type | Method and Description |
---|---|
static <T> Sequence<T> |
Sequences.concat(Sequence<? extends Sequence<T>> sequences) |
static <T> Sequence<T> |
Sequences.concat(Sequence<T>... sequences) |
static <T> Yielder<T> |
Yielders.each(Sequence<T> sequence) |
static <T> Sequence<T> |
Sequences.filter(Sequence<T> sequence,
com.google.common.base.Predicate<T> pred) |
static <T> Sequence<T> |
Sequences.limit(Sequence<T> sequence,
int limit) |
static <From,To> Sequence<To> |
Sequences.map(Sequence<From> sequence,
com.google.common.base.Function<? super From,? extends To> fn) |
static <T> Sequence<T> |
Sequences.sort(Sequence<T> sequence,
Comparator<T> comparator) |
static <T,ListType extends List<T>> |
Sequences.toList(Sequence<T> seq,
ListType list) |
static <T> Sequence<T> |
Sequences.withBaggage(Sequence<T> seq,
Closeable baggage) |
static <T> Sequence<T> |
Sequences.withEffect(Sequence<T> seq,
Runnable effect,
Executor exec) |
static <T> Sequence<T> |
Sequences.wrap(Sequence<T> seq,
SequenceWrapper wrapper)
Allows to execute something before, after or around the processing of the given sequence.
|
Modifier and Type | Method and Description |
---|---|
static <T> Sequence<T> |
Sequences.concat(Iterable<Sequence<T>> sequences) |
static <T> Sequence<T> |
Sequences.concat(Sequence<? extends Sequence<T>> sequences) |
default <R> Sequence<R> |
Sequence.flatMap(Function<? super T,? extends Sequence<? extends R>> mapper) |
default <R> Sequence<R> |
Sequence.flatMerge(Function<? super T,? extends Sequence<? extends R>> mapper,
com.google.common.collect.Ordering<? super R> ordering) |
<OutType> Yielder<OutType> |
ConcatSequence.makeYielder(Yielder<Sequence<T>> yielderYielder,
OutType initValue,
YieldingAccumulator<OutType,T> accumulator) |
Constructor and Description |
---|
ConcatSequence(Sequence<? extends Sequence<? extends T>> baseSequences) |
FilteredSequence(Sequence<T> baseSequence,
com.google.common.base.Predicate<T> pred) |
MappedSequence(Sequence<T> baseSequence,
Function<? super T,? extends Out> fn) |
MergeSequence(com.google.common.collect.Ordering<? super T> ordering,
Sequence<? extends Sequence<? extends T>> baseSequences) |
Constructor and Description |
---|
ConcatSequence(Sequence<? extends Sequence<? extends T>> baseSequences) |
LazySequence(com.google.common.base.Supplier<Sequence<T>> provider) |
MergeSequence(com.google.common.collect.Ordering<? super T> ordering,
Sequence<? extends Sequence<? extends T>> baseSequences) |
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) |
static <T> Sequence<Result<T>> |
QueryRunnerHelper.makeCursorBasedQuery(StorageAdapter adapter,
List<org.joda.time.Interval> queryIntervals,
Filter filter,
VirtualColumns virtualColumns,
boolean descending,
Granularity granularity,
com.google.common.base.Function<Cursor,Result<T>> mapFn) |
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) |
Sequence<T> |
QueryPlus.run(QuerySegmentWalker walker,
Map<String,Object> context) |
Constructor and Description |
---|
ConcatQueryRunner(Sequence<QueryRunner<T>> queryRunners) |
Modifier and Type | Method and Description |
---|---|
static Sequence<Row> |
GroupByQueryHelper.postAggregate(GroupByQuery query,
IncrementalIndex index) |
Sequence<Row> |
GroupByQuery.postProcess(Sequence<Row> results)
Apply the havingSpec and limitSpec.
|
Sequence<Row> |
GroupByQueryEngine.process(GroupByQuery query,
StorageAdapter storageAdapter) |
Modifier and Type | Method and Description |
---|---|
static IncrementalIndex |
GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query,
GroupByQueryConfig config,
NonBlockingPool<ByteBuffer> bufferPool,
Sequence<Row> rows,
boolean combine) |
Sequence<Row> |
GroupByQuery.postProcess(Sequence<Row> results)
Apply the havingSpec and limitSpec.
|
Modifier and Type | Method and Description |
---|---|
static Sequence<Row> |
GroupByQueryEngineV2.process(GroupByQuery query,
StorageAdapter storageAdapter,
NonBlockingPool<ByteBuffer> intermediateResultsBufferPool,
GroupByQueryConfig config) |
static Sequence<Row> |
GroupByRowProcessor.process(Query queryParam,
Sequence<Row> rows,
Map<String,ValueType> rowSignature,
GroupByQueryConfig config,
GroupByQueryResource resource,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir,
int mergeBufferSize) |
Sequence<Row> |
GroupByMergingQueryRunnerV2.run(QueryPlus<Row> queryPlus,
Map<String,Object> responseContext) |
Modifier and Type | Method and Description |
---|---|
static Sequence<Row> |
GroupByRowProcessor.process(Query queryParam,
Sequence<Row> rows,
Map<String,ValueType> rowSignature,
GroupByQueryConfig config,
GroupByQueryResource resource,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir,
int mergeBufferSize) |
Modifier and Type | Class and Description |
---|---|
class |
TopNSequence<T> |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
NoopLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
NoopLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
LimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst)
Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
LimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst)
Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
DefaultLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
DefaultLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
Constructor and Description |
---|
TopNSequence(Sequence<T> input,
com.google.common.collect.Ordering<T> ordering,
int limit) |
Modifier and Type | Method and Description |
---|---|
Sequence<Row> |
GroupByStrategyV2.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Sequence<Row> |
GroupByStrategyV1.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Sequence<Row> |
GroupByStrategy.processSubqueryResult(GroupByQuery subquery,
GroupByQuery query,
GroupByQueryResource resource,
Sequence<Row> subqueryResult) |
Modifier and Type | Method and Description |
---|---|
Sequence<ScanResultValue> |
ScanQueryEngine.process(ScanQuery query,
Segment segment,
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<Result<SelectResultValue>> |
SelectQueryEngine.process(SelectQuery query,
Segment segment) |
Modifier and Type | Method and Description |
---|---|
Sequence<T> |
SpecificSegmentQueryRunner.run(QueryPlus<T> input,
Map<String,Object> responseContext) |
Modifier and Type | Method and Description |
---|---|
Sequence<Result<TimeseriesResultValue>> |
TimeseriesQueryEngine.process(TimeseriesQuery query,
StorageAdapter adapter) |
Modifier and Type | Method and Description |
---|---|
Sequence<Result<TopNResultValue>> |
TopNQueryEngine.query(TopNQuery query,
StorageAdapter adapter,
TopNQueryMetrics queryMetrics) |
Modifier and Type | Method and Description |
---|---|
Sequence<Cursor> |
QueryableIndexStorageAdapter.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending,
QueryMetrics<?> queryMetrics) |
Sequence<Cursor> |
CursorFactory.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending,
QueryMetrics<?> queryMetrics) |
Modifier and Type | Method and Description |
---|---|
Sequence<Cursor> |
IncrementalIndexStorageAdapter.makeCursors(Filter filter,
org.joda.time.Interval interval,
VirtualColumns virtualColumns,
Granularity gran,
boolean descending,
QueryMetrics<?> queryMetrics) |
Modifier and Type | Method and Description |
---|---|
Sequence |
QueryLifecycle.QueryResponse.getResults() |
Sequence |
SetAndVerifyContextQueryRunner.run(QueryPlus queryPlus,
Map responseContext) |
<T> Sequence<T> |
QueryLifecycle.runSimple(Query<T> query,
AuthenticationResult authenticationResult,
String remoteAddress)
For callers where simplicity is desiredĀ over flexibility.
|
Modifier and Type | Method and Description |
---|---|
Sequence<Object[]> |
PlannerResult.run() |
Constructor and Description |
---|
PlannerResult(com.google.common.base.Supplier<Sequence<Object[]>> resultsSupplier,
org.apache.calcite.rel.type.RelDataType rowType) |
Modifier and Type | Method and Description |
---|---|
Sequence<Object[]> |
DruidSemiJoin.runQuery() |
abstract Sequence<Object[]> |
DruidRel.runQuery() |
Sequence<Object[]> |
DruidQueryRel.runQuery() |
Sequence<Object[]> |
DruidOuterQueryRel.runQuery() |
Sequence<Object[]> |
QueryMaker.runQuery(DruidQuery druidQuery) |
Copyright © 2011–2018. All rights reserved.