Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
Modifier and Type | Field and Description |
---|---|
static WatermarkEmissionPolicy |
WatermarkEmissionPolicy.NULL_EMIT_POLICY
The null-object.
|
Modifier and Type | Method and Description |
---|---|
static WatermarkEmissionPolicy |
WatermarkEmissionPolicy.emitByFrame(SlidingWindowPolicy wDef)
Returns a watermark emission policy that ensures that the value of
the emitted watermark belongs to a frame higher than the previous
watermark's frame, as per the supplied
WindowDefinition . |
static WatermarkEmissionPolicy |
WatermarkEmissionPolicy.emitByMinStep(long minStep)
Returns a watermark emission policy that ensures that each emitted
watermark's value is at least
minStep more than the previous
one. |
static WatermarkEmissionPolicy |
WatermarkEmissionPolicy.noThrottling()
Returns a policy that does no throttling: emits each watermark.
|
WatermarkEmissionPolicy |
WatermarkGenerationParams.wmEmitPolicy()
Returns the watermark emission policy, which decides how to suppress
redundant watermarks.
|
Modifier and Type | Method and Description |
---|---|
WatermarkGenerationParams<T> |
WatermarkGenerationParams.withEmitPolicy(WatermarkEmissionPolicy emitPolicy)
Returns new instance with emit policy replaced with the given argument.
|
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.
|
static <T> WatermarkGenerationParams<T> |
WatermarkGenerationParams.wmGenParams(DistributedToLongFunction<? super T> timestampFn,
DistributedSupplier<? extends WatermarkPolicy> wmPolicy,
WatermarkEmissionPolicy wmEmitPolicy,
long idleTimeoutMillis)
Creates and returns a watermark generation parameters object.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.