Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
Modifier and Type | Method and Description |
---|---|
ObjLongBiFunction<? super T,?> |
EventTimePolicy.wrapFn()
Returns the function that transforms the received item and its timestamp
into the emitted item.
|
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.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.