Package | Description |
---|---|
io.druid.collections | |
io.druid.common.guava | |
io.druid.java.util.common.guava | |
io.druid.query.groupby | |
io.druid.query.groupby.epinephelinae |
Modifier and Type | Method and Description |
---|---|
<OutType> OutType |
OrderedMergeSequence.accumulate(OutType initValue,
Accumulator<OutType,T> accumulator) |
Modifier and Type | Method and Description |
---|---|
<OutType> OutType |
CombiningSequence.accumulate(OutType initValue,
Accumulator<OutType,T> accumulator) |
Modifier and Type | Class and Description |
---|---|
class |
FilteringAccumulator<OutType,T> |
class |
MappingAccumulator<OutType,InType,MappedType> |
Modifier and Type | Method and Description |
---|---|
static <ListType extends List<T>,T> |
Accumulators.list() |
Modifier and Type | Method and Description |
---|---|
<OutType> OutType |
MappedSequence.accumulate(OutType initValue,
Accumulator<OutType,Out> accumulator) |
<OutType> OutType |
YieldingSequenceBase.accumulate(OutType initValue,
Accumulator<OutType,T> accumulator) |
<OutType> OutType |
Sequence.accumulate(OutType initValue,
Accumulator<OutType,T> accumulator)
Accumulate this sequence using the given accumulator.
|
<OutType> OutType |
LazySequence.accumulate(OutType initValue,
Accumulator<OutType,T> accumulator) |
<OutType> OutType |
FilteredSequence.accumulate(OutType initValue,
Accumulator<OutType,T> accumulator) |
<OutType> OutType |
ConcatSequence.accumulate(OutType initValue,
Accumulator<OutType,T> accumulator) |
<OutType> OutType |
BaseSequence.accumulate(OutType initValue,
Accumulator<OutType,T> fn) |
static <AccumulatedType,InType> |
YieldingAccumulators.fromAccumulator(Accumulator<AccumulatedType,InType> accumulator) |
Constructor and Description |
---|
FilteringAccumulator(com.google.common.base.Predicate<T> pred,
Accumulator<OutType,T> accumulator) |
Modifier and Type | Method and Description |
---|---|
static <T> Pair<Queue,Accumulator<Queue,T>> |
GroupByQueryHelper.createBySegmentAccumulatorPair() |
static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> |
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
NonBlockingPool<ByteBuffer> bufferPool,
boolean combine) |
Modifier and Type | Method and Description |
---|---|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
int mergeBufferSize)
Create a single-threaded grouper and accumulator.
|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
int concurrencyHint,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
com.google.common.util.concurrent.ListeningExecutorService grouperSorter,
int priority,
boolean hasQueryTimeout,
long queryTimeoutAt,
int mergeBufferSize)
If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not
been applied to the input rows yet, for example, in a nested query, if an extraction function is being
applied in the outer query to a field of the inner query.
|
Copyright © 2011–2018. All rights reserved.