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

Packages that use Accumulator

Package	Description
io.druid.collections
io.druid.common.guava
io.druid.java.util.common.guava
io.druid.query.groupby
io.druid.query.groupby.epinephelinae

Uses of Accumulator in io.druid.collections

Methods in io.druid.collections with parameters of type Accumulator

Modifier and Type	Method and Description
<OutType> OutType	OrderedMergeSequence.accumulate(OutType initValue, Accumulator<OutType,T> accumulator)

Uses of Accumulator in io.druid.common.guava

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

Modifier and Type	Method and Description
<OutType> OutType	CombiningSequence.accumulate(OutType initValue, Accumulator<OutType,T> accumulator)

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

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

Modifier and Type	Class and Description
class	FilteringAccumulator<OutType,T>
class	MappingAccumulator<OutType,InType,MappedType>

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

Modifier and Type	Method and Description
static <ListType extends List<T>,T> Accumulator<ListType,T>	Accumulators.list()

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

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> YieldingAccumulator<AccumulatedType,InType>	YieldingAccumulators.fromAccumulator(Accumulator<AccumulatedType,InType> accumulator)

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

Constructor and Description
FilteringAccumulator(com.google.common.base.Predicate<T> pred, Accumulator<OutType,T> accumulator)
MappingAccumulator(com.google.common.base.Function<InType,MappedType> fn, Accumulator<OutType,MappedType> accumulator)

Uses of Accumulator in io.druid.query.groupby

Methods in io.druid.query.groupby that return types with arguments of type 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, StupidPool<ByteBuffer> bufferPool, boolean combine)

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

Methods in io.druid.query.groupby.epinephelinae that return types with arguments of type Accumulator

Modifier and Type

Method and Description

static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Row>>

RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, boolean isInputRaw, Map<String,ValueType> rawInputRowSignature, GroupByQueryConfig config, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, int concurrencyHint, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, AggregatorFactory[] aggregatorFactories) 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.