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 voidAbstractProcessor.keyedWatermarkCheck(Watermark watermark) ThrowsUnsupportedOperationExceptionif watermark has non-zero key.booleanAbstractProcessor.tryProcessWatermark(Watermark watermark) This basic implementation only forwards the passed watermark.default booleanProcessor.tryProcessWatermark(int ordinal, Watermark watermark) Tries to process the supplied watermark.booleanProcessor.tryProcessWatermark(Watermark watermark) Tries to process the supplied watermark.