Package 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	Description
static 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 org.joda.time.Instant	getTimestamp()	Returns latest timestamp of all events in the range.
static ContiguousSequenceRange	largestRange(java.lang.Iterable<ContiguousSequenceRange> rangeIterable)
static ContiguousSequenceRange	of(long start, long end, org.joda.time.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 org.joda.time.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,
                                         org.joda.time.Instant timestamp)