Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
Modifier and Type | Method and Description |
---|---|
static DistributedSupplier<WatermarkPolicy> |
WatermarkPolicies.limitingLag(long lag)
Maintains a watermark that lags behind the top observed timestamp by the
given amount.
|
static DistributedSupplier<WatermarkPolicy> |
WatermarkPolicies.limitingLagAndDelay(long lag,
long maxDelayMs)
Maintains a watermark that lags behind the top observed timestamp by at
most the given amount and is additionally guaranteed to reach the
timestamp of any given event within
maxDelayMs of system time
after observing it. |
static DistributedSupplier<WatermarkPolicy> |
WatermarkPolicies.limitingLagAndLull(long lag,
long maxLullMs)
Maintains watermark that lags behind the top timestamp by the amount
specified with
lag . |
static DistributedSupplier<WatermarkPolicy> |
WatermarkPolicies.limitingTimestampAndWallClockLag(long timestampLag,
long wallClockLag)
Maintains watermark that lags behind the top timestamp by at most
timestampLag and behind wall-clock time by at most wallClockLag . |
DistributedSupplier<? extends WatermarkPolicy> |
WatermarkGenerationParams.newWmPolicyFn()
Returns the factory of the watermark policy objects.
|
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.
|
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.