Uses of Interface
com.hazelcast.jet.core.function.ObjLongBiFunction
-
Uses of ObjLongBiFunction in com.hazelcast.jet.core
Modifier and TypeMethodDescriptionObjLongBiFunction<? super T,
?> EventTimePolicy.wrapFn()
Returns the function that transforms the received item and its timestamp into the emitted item.Modifier and TypeMethodDescriptionstatic <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.