Uses of Class
org.nuxeo.lib.stream.computation.Watermark
Package
Description
The Computation pattern with a Log implementation.
Computation pattern implemented with Log
-
Uses of Watermark in org.nuxeo.lib.stream.computation
Modifier and TypeMethodDescriptionstatic 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) Modifier and TypeMethodDescriptionint
static Watermark
Watermark.completedOf
(Watermark watermark) -
Uses of Watermark in org.nuxeo.lib.stream.computation.internals
Modifier and TypeFieldDescriptionprotected Watermark
WatermarkMonotonicInterval.high
protected Watermark
WatermarkMonotonicInterval.low
protected Watermark
WatermarkMonotonicInterval.lowest
-
Uses of Watermark in org.nuxeo.lib.stream.computation.log