Uses of Interface
io.druid.java.util.common.guava.Sequence

Packages that use Sequence

Package	Description
io.druid.benchmark.query
io.druid.client
io.druid.collections
io.druid.common.guava
io.druid.java.util.common.guava
io.druid.query
io.druid.query.groupby
io.druid.query.groupby.epinephelinae
io.druid.query.groupby.orderby
io.druid.query.groupby.strategy
io.druid.query.scan
io.druid.query.search
io.druid.query.select
io.druid.query.spec
io.druid.query.timeseries
io.druid.query.topn
io.druid.segment
io.druid.segment.incremental
io.druid.sql.calcite.planner
io.druid.sql.calcite.rel

Uses of Sequence in io.druid.benchmark.query

Methods in io.druid.benchmark.query that return Sequence

Modifier and Type	Method and Description
Sequence<T>	SerializingQueryRunner.run(Query<T> query, Map<String,Object> responseContext)

Uses of Sequence in io.druid.client

Methods in io.druid.client that return Sequence

Modifier and Type	Method and Description
protected Sequence<T>	CachingClusteredClient.mergeCachedAndUncachedSequences(Query<T> query, List<Sequence<T>> sequencesByInterval)
Sequence<T>	DirectDruidClient.run(Query<T> query, Map<String,Object> context)
Sequence<T>	CachingQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	CachingClusteredClient.run(Query<T> query, Map<String,Object> responseContext)

Method parameters in io.druid.client with type arguments of type Sequence

Modifier and Type	Method and Description
protected Sequence<T>	CachingClusteredClient.mergeCachedAndUncachedSequences(Query<T> query, List<Sequence<T>> sequencesByInterval)

Uses of Sequence in io.druid.collections

Classes in io.druid.collections that implement Sequence

Modifier and Type	Class and Description
class	OrderedMergeSequence<T> An OrderedMergeIterator is an iterator that merges together multiple sorted iterators.

Constructors in io.druid.collections with parameters of type Sequence

Constructor and Description
OrderedMergeSequence(com.google.common.collect.Ordering<T> ordering, Sequence<Sequence<T>> sequences)

Constructor parameters in io.druid.collections with type arguments of type Sequence

Constructor and Description
OrderedMergeSequence(com.google.common.collect.Ordering<T> ordering, Sequence<Sequence<T>> sequences)

Uses of Sequence in io.druid.common.guava

Classes in io.druid.common.guava that implement Sequence

Modifier and Type	Class and Description
class	CombiningSequence<T>

Methods in io.druid.common.guava with parameters of type Sequence

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)

Uses of Sequence in io.druid.java.util.common.guava

Classes in io.druid.java.util.common.guava that implement Sequence

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.

Methods in io.druid.java.util.common.guava that return Sequence

Modifier and Type	Method and Description
static <T> Sequence<T>	Sequences.concat(Iterable<Sequence<T>> sequences)
static <T> Sequence<T>	Sequences.concat(Sequence<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)
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<From,To> fn)
static <T> Sequence<T>	Sequences.simple(Iterable<T> iterable)
static <T> Sequence<T>	Sequences.sort(Sequence<T> sequence, Comparator<T> comparator)
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.

Methods in io.druid.java.util.common.guava with parameters of type Sequence

Modifier and Type	Method and Description
static <T> Sequence<T>	Sequences.concat(Sequence<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<From,To> fn)
static <T> Sequence<T>	Sequences.sort(Sequence<T> sequence, Comparator<T> comparator)
static <T,ListType extends List<T>> ListType	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.

Method parameters in io.druid.java.util.common.guava with type arguments of type Sequence

Modifier and Type	Method and Description
static <T> Sequence<T>	Sequences.concat(Iterable<Sequence<T>> sequences)
static <T> Sequence<T>	Sequences.concat(Sequence<Sequence<T>> sequences)
<OutType> Yielder<OutType>	ConcatSequence.makeYielder(Yielder<Sequence<T>> yielderYielder, OutType initValue, YieldingAccumulator<OutType,T> accumulator)

Constructors in io.druid.java.util.common.guava with parameters of type Sequence

Constructor and Description
ConcatSequence(Sequence<Sequence<T>> baseSequences)
FilteredSequence(Sequence<T> baseSequence, com.google.common.base.Predicate<T> pred)
MappedSequence(Sequence<T> baseSequence, com.google.common.base.Function<T,Out> fn)
MergeSequence(com.google.common.collect.Ordering<T> ordering, Sequence<Sequence<T>> baseSequences)

Constructor parameters in io.druid.java.util.common.guava with type arguments of type Sequence

Constructor and Description
ConcatSequence(Sequence<Sequence<T>> baseSequences)
LazySequence(com.google.common.base.Supplier<Sequence<T>> provider)
MergeSequence(com.google.common.collect.Ordering<T> ordering, Sequence<Sequence<T>> baseSequences)

Uses of Sequence in io.druid.query

Methods in io.druid.query that return Sequence

Modifier and Type	Method and Description
Sequence<T>	ResultMergeQueryRunner.doRun(QueryRunner<T> baseRunner, Query<T> query, Map<String,Object> context)
protected abstract Sequence<T>	BySegmentSkippingQueryRunner.doRun(QueryRunner<T> baseRunner, Query<T> query, 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(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	SubqueryQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	RetryQueryRunner.run(Query<T> query, Map<String,Object> context)
Sequence<T>	ReportTimelineMissingSegmentQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	ReferenceCountingSegmentQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	QueryRunner.run(Query<T> query, Map<String,Object> responseContext) Runs the given query and returns results in a time-ordered sequence
Sequence<T>	NoopQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	MetricsEmittingQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	IntervalChunkingQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	GroupByMergedQueryRunner.run(Query<T> queryParam, Map<String,Object> responseContext)
Sequence<T>	FluentQueryRunnerBuilder.FluentQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	FinalizeResultsQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	ConcatQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	ChainedExecutionQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	CPUTimeMetricQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	BySegmentSkippingQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	BySegmentQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	AsyncQueryRunner.run(Query<T> query, Map<String,Object> responseContext)
Sequence<T>	Query.run(QueryRunner<T> runner, Map<String,Object> context)
Sequence<T>	BaseQuery.run(QueryRunner<T> runner, Map<String,Object> context)
Sequence<T>	Query.run(QuerySegmentWalker walker, Map<String,Object> context)
Sequence<T>	BaseQuery.run(QuerySegmentWalker walker, Map<String,Object> context)

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

Constructor and Description
ConcatQueryRunner(Sequence<QueryRunner<T>> queryRunners)

Uses of Sequence in io.druid.query.groupby

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

Modifier and Type	Method and Description
Sequence<Row>	GroupByQuery.applyLimit(Sequence<Row> results) Apply the havingSpec and limitSpec.
static Sequence<Row>	GroupByQueryHelper.postAggregate(GroupByQuery query, IncrementalIndex index)
Sequence<Row>	GroupByQueryEngine.process(GroupByQuery query, StorageAdapter storageAdapter)

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

Modifier and Type	Method and Description
Sequence<Row>	GroupByQuery.applyLimit(Sequence<Row> results) Apply the havingSpec and limitSpec.
static IncrementalIndex	GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query, GroupByQueryConfig config, StupidPool<ByteBuffer> bufferPool, Sequence<Row> rows, boolean combine)

Uses of Sequence in io.druid.query.groupby.epinephelinae

Methods in io.druid.query.groupby.epinephelinae that return Sequence

Modifier and Type	Method and Description
static Sequence<Row>	GroupByQueryEngineV2.process(GroupByQuery query, StorageAdapter storageAdapter, StupidPool<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)
Sequence<Row>	GroupByMergingQueryRunnerV2.run(Query queryParam, Map responseContext)

Methods in io.druid.query.groupby.epinephelinae with parameters of type Sequence

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)

Uses of Sequence in io.druid.query.groupby.orderby

Classes in io.druid.query.groupby.orderby that implement Sequence

Modifier and Type	Class and Description
class	TopNSequence<T>

Methods in io.druid.query.groupby.orderby that return types with arguments of type Sequence

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)
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	NoopLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	LimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs) 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) 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)
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	DefaultLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)

Constructors in io.druid.query.groupby.orderby with parameters of type Sequence

Constructor and Description
TopNSequence(Sequence<T> input, com.google.common.collect.Ordering<T> ordering, int limit)

Uses of Sequence in io.druid.query.groupby.strategy

Methods in io.druid.query.groupby.strategy that return Sequence

Modifier and Type	Method and Description
Sequence<Row>	GroupByStrategyV2.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategyV1.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategy.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategyV2.process(GroupByQuery query, StorageAdapter storageAdapter)
Sequence<Row>	GroupByStrategyV1.process(GroupByQuery query, StorageAdapter storageAdapter)
Sequence<Row>	GroupByStrategy.process(GroupByQuery query, StorageAdapter storageAdapter)
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)

Methods in io.druid.query.groupby.strategy with parameters of type Sequence

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)

Uses of Sequence in io.druid.query.scan

Methods in io.druid.query.scan that return Sequence

Modifier and Type	Method and Description
Sequence<ScanResultValue>	ScanQueryEngine.process(ScanQuery query, Segment segment, Map<String,Object> responseContext)

Uses of Sequence in io.druid.query.search

Methods in io.druid.query.search that return Sequence

Modifier and Type	Method and Description
Sequence<Result<SearchResultValue>>	SearchQueryRunner.run(Query<Result<SearchResultValue>> input, Map<String,Object> responseContext)

Uses of Sequence in io.druid.query.select

Methods in io.druid.query.select that return Sequence

Modifier and Type	Method and Description
Sequence<Result<SelectResultValue>>	SelectQueryEngine.process(SelectQuery query, Segment segment)

Uses of Sequence in io.druid.query.spec

Methods in io.druid.query.spec that return Sequence

Modifier and Type	Method and Description
Sequence<T>	SpecificSegmentQueryRunner.run(Query<T> input, Map<String,Object> responseContext)

Uses of Sequence in io.druid.query.timeseries

Methods in io.druid.query.timeseries that return Sequence

Modifier and Type	Method and Description
Sequence<Result<TimeseriesResultValue>>	TimeseriesQueryEngine.process(TimeseriesQuery query, StorageAdapter adapter)

Uses of Sequence in io.druid.query.topn

Methods in io.druid.query.topn that return Sequence

Modifier and Type	Method and Description
Sequence<Result<TopNResultValue>>	TopNQueryEngine.query(TopNQuery query, StorageAdapter adapter)

Uses of Sequence in io.druid.segment

Methods in io.druid.segment that return Sequence

Modifier and Type	Method and Description
Sequence<Cursor>	QueryableIndexStorageAdapter.makeCursors(Filter filter, org.joda.time.Interval interval, VirtualColumns virtualColumns, Granularity gran, boolean descending)
Sequence<Cursor>	CursorFactory.makeCursors(Filter filter, org.joda.time.Interval interval, VirtualColumns virtualColumns, Granularity gran, boolean descending)

Uses of Sequence in io.druid.segment.incremental

Methods in io.druid.segment.incremental that return Sequence

Modifier and Type	Method and Description
Sequence<Cursor>	IncrementalIndexStorageAdapter.makeCursors(Filter filter, org.joda.time.Interval interval, VirtualColumns virtualColumns, Granularity gran, boolean descending)

Uses of Sequence in io.druid.sql.calcite.planner

Methods in io.druid.sql.calcite.planner that return Sequence

Modifier and Type	Method and Description
Sequence<Object[]>	PlannerResult.run()

Constructor parameters in io.druid.sql.calcite.planner with type arguments of type Sequence

Constructor and Description
PlannerResult(com.google.common.base.Supplier<Sequence<Object[]>> resultsSupplier, org.apache.calcite.rel.type.RelDataType rowType)

Uses of Sequence in io.druid.sql.calcite.rel

Methods in io.druid.sql.calcite.rel that return Sequence

Modifier and Type	Method and Description
Sequence<Object[]>	DruidSemiJoin.runQuery()
abstract Sequence<Object[]>	DruidRel.runQuery()
Sequence<Object[]>	DruidQueryRel.runQuery()
Sequence<Object[]>	DruidNestedGroupBy.runQuery()
Sequence<Object[]>	QueryMaker.runQuery(DataSource dataSource, RowSignature sourceRowSignature, DruidQueryBuilder queryBuilder)