io.druid.common.guava

Class CombiningSequence<T>

java.lang.Object

io.druid.common.guava.CombiningSequence<T>

All Implemented Interfaces:

com.metamx.common.guava.Sequence<T>

public class CombiningSequence<T>
extends Object
implements com.metamx.common.guava.Sequence<T>

Constructor Summary

Constructors

Constructor and Description
CombiningSequence(com.metamx.common.guava.Sequence<T> baseSequence, com.google.common.collect.Ordering<T> ordering, com.metamx.common.guava.nary.BinaryFn<T,T,T> mergeFn)

Method Summary

Methods

Modifier and Type	Method and Description
<OutType> OutType	accumulate(OutType initValue, com.metamx.common.guava.Accumulator<OutType,T> accumulator)
static <T> CombiningSequence<T>	create(com.metamx.common.guava.Sequence<T> baseSequence, com.google.common.collect.Ordering<T> ordering, com.metamx.common.guava.nary.BinaryFn<T,T,T> mergeFn)
<OutType,T> com.metamx.common.guava.Yielder<OutType>	makeYielder(com.metamx.common.guava.Yielder<T> yielder, io.druid.common.guava.CombiningSequence.CombiningYieldingAccumulator<OutType,T> combiningAccumulator, boolean finalValue)
<OutType> com.metamx.common.guava.Yielder<OutType>	toYielder(OutType initValue, com.metamx.common.guava.YieldingAccumulator<OutType,T> accumulator)

Methods inherited from class java.lang.Object

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

Constructor Detail

CombiningSequence

public CombiningSequence(com.metamx.common.guava.Sequence<T> baseSequence,
                 com.google.common.collect.Ordering<T> ordering,
                 com.metamx.common.guava.nary.BinaryFn<T,T,T> mergeFn)

Method Detail

create

public static <T> CombiningSequence<T> create(com.metamx.common.guava.Sequence<T> baseSequence,
                              com.google.common.collect.Ordering<T> ordering,
                              com.metamx.common.guava.nary.BinaryFn<T,T,T> mergeFn)

accumulate

public <OutType> OutType accumulate(OutType initValue,
                           com.metamx.common.guava.Accumulator<OutType,T> accumulator)

Specified by:

accumulate in interface com.metamx.common.guava.Sequence<T>

toYielder

public <OutType> com.metamx.common.guava.Yielder<OutType> toYielder(OutType initValue,
                                                           com.metamx.common.guava.YieldingAccumulator<OutType,T> accumulator)

Specified by:

toYielder in interface com.metamx.common.guava.Sequence<T>

makeYielder

public <OutType,T> com.metamx.common.guava.Yielder<OutType> makeYielder(com.metamx.common.guava.Yielder<T> yielder,
                                                               io.druid.common.guava.CombiningSequence.CombiningYieldingAccumulator<OutType,T> combiningAccumulator,
                                                               boolean finalValue)