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

Class ContiguousSequenceRange

java.lang.Object

org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange

All Implemented Interfaces:

Serializable, Comparable<ContiguousSequenceRange>

public abstract class ContiguousSequenceRange
extends Object
implements Serializable, Comparable<ContiguousSequenceRange>

A range of contiguous event sequences and the latest timestamp of the events in the range.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final ContiguousSequenceRange	EMPTY

Constructor Summary

Constructors

Constructor	Description
ContiguousSequenceRange()

Method Summary

Modifier and Type	Method	Description
int	compareTo(ContiguousSequenceRange other)
abstract long	getEnd()	Returns exclusive end sequence.
abstract long	getStart()	Returns inclusive starting sequence.
abstract Instant	getTimestamp()	Returns latest timestamp of all events in the range.
static ContiguousSequenceRange	largestRange(Iterable<ContiguousSequenceRange> rangeIterable)
static ContiguousSequenceRange	of(long start, long end, Instant timestamp)

Methods inherited from class java.lang.Object

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

Field Details

EMPTY

public static final ContiguousSequenceRange EMPTY

Constructor Details

ContiguousSequenceRange

public ContiguousSequenceRange()

Method Details

getStart

public abstract long getStart()

Returns inclusive starting sequence.

getEnd

public abstract long getEnd()

Returns exclusive end sequence.

getTimestamp

public abstract Instant getTimestamp()

Returns latest timestamp of all events in the range.

compareTo

public int compareTo(ContiguousSequenceRange other)

Specified by:

compareTo in interface Comparable<ContiguousSequenceRange>

largestRange

public static ContiguousSequenceRange largestRange(Iterable<ContiguousSequenceRange> rangeIterable)

of

public static ContiguousSequenceRange of(long start,
 long end,
 Instant timestamp)