## 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 SupplierEx<WatermarkPolicy>` | WatermarkPolicy.`limitingLag(long lag)` Maintains a watermark that lags behind the top observed timestamp by the given amount.
    `SupplierEx<? extends WatermarkPolicy>` | EventTimePolicy.`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> 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, SupplierEx<? extends WatermarkPolicy> newWmPolicyFn, long watermarkThrottlingFrameSize, long watermarkThrottlingFrameOffset, long idleTimeoutMillis)` Creates and returns a new event time policy.

Copyright © 2019. All rights reserved.