Uses of Interface
com.hazelcast.jet.core.WatermarkPolicy

Packages that use 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 and 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 and Description
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.
static <T> EventTimePolicy<T>	EventTimePolicy.eventTimePolicy(ToLongFunctionEx<? super T> timestampFn, ObjLongBiFunction<? super T,?> wrapFn, SupplierEx<? extends WatermarkPolicy> newWmPolicyFn, long watermarkThrottlingFrameSize, long watermarkThrottlingFrameOffset, long idleTimeoutMillis, byte wmKey) Creates and returns a new event time policy.
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.