org.apache.beam.sdk.extensions.ordered

Class ContiguousSequenceRange

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, java.lang.Comparable<ContiguousSequenceRange>

public abstract class ContiguousSequenceRange
extends java.lang.Object
implements java.io.Serializable, java.lang.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 and Description
static ContiguousSequenceRange	EMPTY

Constructor Summary

Constructors

Constructor and Description
ContiguousSequenceRange()

Method Summary

Modifier and Type	Method and Description
int	compareTo(ContiguousSequenceRange other)
abstract long	getEnd()
abstract long	getStart()
abstract Instant	getTimestamp()
static ContiguousSequenceRange	largestRange(java.lang.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 Detail

EMPTY

public static final ContiguousSequenceRange EMPTY

Constructor Detail

ContiguousSequenceRange

public ContiguousSequenceRange()

Method Detail

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 java.lang.Comparable<ContiguousSequenceRange>

largestRange

public static ContiguousSequenceRange largestRange(java.lang.Iterable<ContiguousSequenceRange> rangeIterable)

of

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