Uses of Class
org.nuxeo.lib.stream.computation.Watermark

Packages that use Watermark

Package	Description
org.nuxeo.lib.stream.computation	The Computation pattern with a Log implementation.
org.nuxeo.lib.stream.computation.internals
org.nuxeo.lib.stream.computation.log	Computation pattern implemented with Log

Uses of Watermark in org.nuxeo.lib.stream.computation

Fields in org.nuxeo.lib.stream.computation declared as Watermark

Modifier and Type	Field and Description
static Watermark	Watermark.LOWEST

Methods in org.nuxeo.lib.stream.computation that return Watermark

Modifier and Type	Method and Description
static Watermark	Watermark.completedOf(Watermark watermark)
static Watermark	Watermark.ofNow()
static Watermark	Watermark.ofTimestamp(long timestamp)
static Watermark	Watermark.ofTimestamp(long timestamp, short sequence)
static Watermark	Watermark.ofValue(long watermarkValue)

Methods in org.nuxeo.lib.stream.computation with parameters of type Watermark

Modifier and Type	Method and Description
int	Watermark.compareTo(Watermark o)
static Watermark	Watermark.completedOf(Watermark watermark)

Uses of Watermark in org.nuxeo.lib.stream.computation.internals

Fields in org.nuxeo.lib.stream.computation.internals declared as Watermark

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

Methods in org.nuxeo.lib.stream.computation.internals that return Watermark

Modifier and Type	Method and Description
Watermark	WatermarkMonotonicInterval.getHigh()
Watermark	WatermarkMonotonicInterval.getLow() Returns the low mark.

Methods in org.nuxeo.lib.stream.computation.internals with parameters of type Watermark

Modifier and Type	Method and Description
long	WatermarkMonotonicInterval.mark(Watermark watermark) Take in account the watermark. Not thread safe.

Uses of Watermark in org.nuxeo.lib.stream.computation.log

Methods in org.nuxeo.lib.stream.computation.log that return Watermark

Modifier and Type	Method and Description
Watermark	ComputationRunner.getLowWatermark()