Uses of Class
com.hazelcast.jet.core.Watermark
Packages that use Watermark
-
Uses of Watermark in com.hazelcast.jet.core
Methods in com.hazelcast.jet.core with parameters of type WatermarkModifier 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.