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

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

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

    Fields in com.hazelcast.jet.core declared as WatermarkEmissionPolicy
    Modifier and Type | Field and Description
    --- | ---
    `static WatermarkEmissionPolicy` | WatermarkEmissionPolicy.`NULL_EMIT_POLICY` The null-object.

    Methods in com.hazelcast.jet.core that return WatermarkEmissionPolicy
    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.
    `static WatermarkEmissionPolicy` | WatermarkEmissionPolicy.`noWatermarks()` Returns a policy that doesn't emit watermarks.
    `WatermarkEmissionPolicy` | WatermarkGenerationParams.`wmEmitPolicy()` Returns the watermark emission policy, which decides how to suppress redundant watermarks.

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