io.druid.java.util.common.guava

Class MergeSequence<T>

java.lang.Object

io.druid.java.util.common.guava.YieldingSequenceBase<T>

io.druid.java.util.common.guava.MergeSequence<T>

All Implemented Interfaces:

Sequence<T>

public class MergeSequence<T>
extends YieldingSequenceBase<T>

Constructor Summary

Constructors

Constructor and Description
MergeSequence(com.google.common.collect.Ordering<? super T> ordering, Sequence<? extends Sequence<? extends T>> baseSequences)

Method Summary

Modifier and Type	Method and Description
<OutType> Yielder<OutType>	toYielder(OutType initValue, YieldingAccumulator<OutType,T> accumulator) Return an Yielder for accumulated sequence.

Methods inherited from class io.druid.java.util.common.guava.YieldingSequenceBase

accumulate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.druid.java.util.common.guava.Sequence

flatMap, flatMerge, map, withBaggage, withEffect

Constructor Detail

MergeSequence

public MergeSequence(com.google.common.collect.Ordering<? super T> ordering,
                     Sequence<? extends Sequence<? extends T>> baseSequences)

Method Detail

toYielder

public <OutType> Yielder<OutType> toYielder(OutType initValue,
                                            YieldingAccumulator<OutType,T> accumulator)

Description copied from interface: Sequence

Return an Yielder for accumulated sequence.

Type Parameters:

OutType - the type of accumulated value.

Parameters:

initValue - the initial value to pass along to start the accumulation.

accumulator - the accumulator which is responsible for accumulating input values.

Returns:

an Yielder for accumulated sequence.

See Also:

Yielder