Uses of Class
org.nuxeo.lib.stream.computation.Watermark
Packages that use Watermark
Package
Description
The Computation pattern with a Log implementation.
Computation pattern implemented with Log
-
Uses of Watermark in org.nuxeo.lib.stream.computation
Fields in org.nuxeo.lib.stream.computation declared as WatermarkMethods in org.nuxeo.lib.stream.computation that return WatermarkModifier 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) Methods in org.nuxeo.lib.stream.computation with parameters of type WatermarkModifier and TypeMethodDescriptionint
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 WatermarkModifier and TypeFieldDescriptionprotected Watermark
WatermarkMonotonicInterval.high
protected Watermark
WatermarkMonotonicInterval.low
protected Watermark
WatermarkMonotonicInterval.lowest
Methods in org.nuxeo.lib.stream.computation.internals that return WatermarkModifier and TypeMethodDescriptionWatermarkMonotonicInterval.getHigh()
WatermarkMonotonicInterval.getLow()
Returns the low mark.Methods in org.nuxeo.lib.stream.computation.internals with parameters of type Watermark -
Uses of Watermark in org.nuxeo.lib.stream.computation.log
Methods in org.nuxeo.lib.stream.computation.log that return Watermark