Package org.apache.beam.sdk.extensions.ordered.combiner

Class SequenceRangeAccumulator

java.lang.Object

org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator

public class SequenceRangeAccumulator
extends java.lang.Object

Default accumulator used to combine sequence ranges.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SequenceRangeAccumulator.SequenceRangeAccumulatorCoder

Constructor Summary

Constructors

Constructor	Description
SequenceRangeAccumulator()

Method Summary

Modifier and Type	Method	Description
void	add(long sequence, org.joda.time.Instant timestamp, boolean isInitialSequence)
boolean	equals(java.lang.Object o)
int	hashCode()
ContiguousSequenceRange	largestContinuousRange()
void	merge(SequenceRangeAccumulator another)
int	numberOfRanges()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SequenceRangeAccumulator

public SequenceRangeAccumulator()

Method Detail

add

public void add(long sequence,
                org.joda.time.Instant timestamp,
                boolean isInitialSequence)

largestContinuousRange

public ContiguousSequenceRange largestContinuousRange()

numberOfRanges

public int numberOfRanges()

merge

public void merge(SequenceRangeAccumulator another)

equals

public boolean equals(@Nullable
                      java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object