Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
Modifier and Type | Method and Description |
---|---|
DistributedObjLongBiFunction<? super T,?> |
WatermarkGenerationParams.wrapFn()
Returns the function that transforms the received item and its timestamp
into the emitted item.
|
Modifier and Type | Method and Description |
---|---|
static <T> WatermarkGenerationParams<T> |
WatermarkGenerationParams.wmGenParams(DistributedToLongFunction<? super T> timestampFn,
DistributedObjLongBiFunction<? super T,?> wrapFn,
DistributedSupplier<? extends WatermarkPolicy> newWmPolicyFn,
WatermarkEmissionPolicy wmEmitPolicy,
long idleTimeoutMillis)
Creates and returns new watermark generation parameters.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.