## Uses of Interface
com.hazelcast.jet.core.WatermarkPolicy

- Packages that use WatermarkPolicy
  Package | Description
  --- | ---
  com.hazelcast.jet.core | Jet's Core API.

- - ### Uses of WatermarkPolicy in com.hazelcast.jet.core

    Methods in com.hazelcast.jet.core that return types with arguments of type WatermarkPolicy
    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.

    Method parameters in com.hazelcast.jet.core with type arguments of type WatermarkPolicy
    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. All rights reserved.