Package org.nuxeo.lib.stream.computation

Class Watermark

java.lang.Object

org.nuxeo.lib.stream.computation.Watermark

All Implemented Interfaces:

Comparable<Watermark>

public final class Watermark
extends Object
implements Comparable<Watermark>

Watermark represents a point in time. This point in time is composed of a millisecond timestamp and a sequence. There is also a state to denote if the point in time is reached (completed) or not. Watermark are immutable.

Since:

9.3

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	completed
static Watermark	LOWEST
protected short	sequence
protected long	timestamp
protected long	value

Method Summary

Modifier and Type	Method	Description
int	compareTo(Watermark o)
static Watermark	completedOf(Watermark watermark)
boolean	equals(Object o)
short	getSequence()
long	getTimestamp()
long	getValue()
int	hashCode()
boolean	isCompleted()
boolean	isDone(long timestamp)
static Watermark	ofNow()
static Watermark	ofTimestamp(long timestamp)
static Watermark	ofTimestamp(long timestamp, short sequence)
static Watermark	ofValue(long watermarkValue)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

LOWEST

public static final Watermark LOWEST

timestamp

protected final long timestamp

sequence

protected final short sequence

completed

protected final boolean completed

value

protected final long value

Method Detail

ofValue

public static Watermark ofValue(long watermarkValue)

ofNow

public static Watermark ofNow()

ofTimestamp

public static Watermark ofTimestamp(long timestamp)

ofTimestamp

public static Watermark ofTimestamp(long timestamp,
                                    short sequence)

completedOf

public static Watermark completedOf(Watermark watermark)

getValue

public long getValue()

isCompleted

public boolean isCompleted()

getSequence

public short getSequence()

getTimestamp

public long getTimestamp()

isDone

public boolean isDone(long timestamp)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

compareTo

public int compareTo(Watermark o)

Specified by:

compareTo in interface Comparable<Watermark>