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()
abstract long	getStart()
abstract Instant	getTimestamp()
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)