org.apache.beam.sdk.extensions.ordered

Class ContiguousSequenceRange

java.lang.Object

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

public abstract class ContiguousSequenceRange
extends java.lang.Object

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

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

of

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