Package org.apache.druid.java.util.common.guava

Class ExplodingSequence<T>

java.lang.Object

org.apache.druid.java.util.common.guava.YieldingSequenceBase<T>

org.apache.druid.java.util.common.guava.ExplodingSequence<T>

All Implemented Interfaces:

Sequence<T>

public class ExplodingSequence<T>
extends YieldingSequenceBase<T>

Wraps an underlying sequence and allows us to force it to explode at various points.

Constructor Summary

Constructors

Constructor	Description
ExplodingSequence(Sequence<T> baseSequence, boolean getThrowsException, boolean closeThrowsException)

Method Summary

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

Methods inherited from class org.apache.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 org.apache.druid.java.util.common.guava.Sequence

filter, flatMap, flatMerge, forEach, limit, map, skip, toList, withBaggage, withEffect

Constructor Details

ExplodingSequence

public ExplodingSequence(Sequence<T> baseSequence,
 boolean getThrowsException,
 boolean closeThrowsException)

Method Details

toYielder

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

Description copied from interface: Sequence

Return a 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:

a Yielder for accumulated sequence.

See Also:

• Yielder

getCloseCount

public long getCloseCount()