Uses of Class
com.hazelcast.jet.core.Watermark
-
Uses of Watermark in com.hazelcast.jet.core
Modifier and TypeMethodDescriptionprotected void
AbstractProcessor.keyedWatermarkCheck
(Watermark watermark) ThrowsUnsupportedOperationException
if watermark has non-zero key.boolean
AbstractProcessor.tryProcessWatermark
(Watermark watermark) This basic implementation only forwards the passed watermark.default boolean
Processor.tryProcessWatermark
(int ordinal, Watermark watermark) Tries to process the supplied watermark.boolean
Processor.tryProcessWatermark
(Watermark watermark) Tries to process the supplied watermark.