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 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, Instant timestamp, boolean isInitialSequence)
boolean	equals(Object o)
int	hashCode()
ContiguousSequenceRange	largestContinuousRange()
void	merge(SequenceRangeAccumulator another)
int	numberOfRanges()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

SequenceRangeAccumulator

public SequenceRangeAccumulator()

Method Details

add

public void add(long sequence,
 Instant timestamp,
 boolean isInitialSequence)

largestContinuousRange

public ContiguousSequenceRange largestContinuousRange()

numberOfRanges

public int numberOfRanges()

merge

public void merge(SequenceRangeAccumulator another)

equals

public boolean equals(@Nullable
 Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object