org.nuxeo.lib.stream.computation.internals

Class WatermarkMonotonicInterval

java.lang.Object

org.nuxeo.lib.stream.computation.internals.WatermarkMonotonicInterval

public class WatermarkMonotonicInterval
extends Object

Keep track of minimum and maximum watermark level. On checkpoint move the low watermark to the previous maximum mark.

Since:

9.3

Field Summary

Fields

Modifier and Type	Field and Description
protected Watermark	high
protected Watermark	low
protected Watermark	lowest

Constructor Summary

Constructors

Constructor and Description
WatermarkMonotonicInterval()

Method Summary

Modifier and Type	Method and Description
long	checkpoint() Move the low watermark to the highest mark.
Watermark	getHigh()
Watermark	getLow() Returns the low mark.
boolean	isDone(long timestamp)
long	mark(long watermarkValue) Take in account the watermark. Not thread safe.
long	mark(Watermark watermark) Take in account the watermark. Not thread safe.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

low

protected volatile Watermark low

lowest

protected Watermark lowest

high

protected Watermark high

Constructor Detail

WatermarkMonotonicInterval

public WatermarkMonotonicInterval()

Method Detail

mark

public long mark(long watermarkValue)

Take in account the watermark.
Not thread safe.

mark

public long mark(Watermark watermark)

Take in account the watermark.
Not thread safe.

checkpoint

public long checkpoint()

Move the low watermark to the highest mark. Returns the low watermark that should be monotonic (the value returned here never decrease).
Not thread safe.

isDone

public boolean isDone(long timestamp)

getLow

public Watermark getLow()

Returns the low mark. The value can decrease but not under the last checkpoint value.
Thread safe usage.

getHigh

public Watermark getHigh()

toString

public String toString()

Overrides:

toString in class Object