Uses of Interface
com.hazelcast.jet.core.WatermarkPolicy
Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
-
Uses of WatermarkPolicy in com.hazelcast.jet.core
Methods in com.hazelcast.jet.core that return types with arguments of type WatermarkPolicy Modifier and Type Method Description static SupplierEx<WatermarkPolicy>
WatermarkPolicy. limitingLag(long lag)
Maintains a watermark that lags behind the top observed timestamp by the given amount.static SupplierEx<WatermarkPolicy>
WatermarkPolicy. limitingRealTimeLag(long lag)
Maintains a watermark that lags behind the real time by the given amount.SupplierEx<? extends WatermarkPolicy>
EventTimePolicy. newWmPolicyFn()
Returns the factory of the watermark policy objects.Method parameters in com.hazelcast.jet.core with type arguments of type WatermarkPolicy Modifier and Type Method Description static <T> EventTimePolicy<T>
EventTimePolicy. eventTimePolicy(ToLongFunctionEx<? super T> timestampFn, SupplierEx<? extends WatermarkPolicy> newWmPolicyFn, long watermarkThrottlingFrameSize, long watermarkThrottlingFrameOffset, long idleTimeoutMillis)
Creates and returns a new event time policy.static <T> EventTimePolicy<T>
EventTimePolicy. eventTimePolicy(ToLongFunctionEx<? super T> timestampFn, ObjLongBiFunction<? super T,?> wrapFn, SupplierEx<? extends WatermarkPolicy> newWmPolicyFn, long watermarkThrottlingFrameSize, long watermarkThrottlingFrameOffset, long idleTimeoutMillis)
Creates and returns a new event time policy.