## Uses of Class
com.hazelcast.jet.core.SlidingWindowPolicy

- Packages that use SlidingWindowPolicy
  Package | Description
  --- | ---
  com.hazelcast.jet.core | Jet's Core API.
  com.hazelcast.jet.core.processor | Contains static utility classes with factories of Jet processors.
  com.hazelcast.jet.pipeline | The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

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

    Methods in com.hazelcast.jet.core that return SlidingWindowPolicy
    Modifier and Type | Method and Description
    --- | ---
    `static SlidingWindowPolicy` | SlidingWindowPolicy.`slidingWinPolicy(long windowSize, long slideBy)` Returns the definition of a sliding window of length `windowSize` that slides by `slideBy`.
    `SlidingWindowPolicy` | SlidingWindowPolicy.`toTumblingByFrame()` Converts this definition to one defining a tumbling window of the same length as this definition's frame.
    `static SlidingWindowPolicy` | SlidingWindowPolicy.`tumblingWinPolicy(long windowSize)` Returns the definition of a tumbling window of length `windowSize`.
    `SlidingWindowPolicy` | SlidingWindowPolicy.`withOffset(long offset)` Returns a new window definition where all the frames are shifted by the given offset.

    Methods in com.hazelcast.jet.core with parameters of type SlidingWindowPolicy
    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`.

  - ### Uses of SlidingWindowPolicy in com.hazelcast.jet.core.processor

    Methods in com.hazelcast.jet.core.processor with parameters of type SlidingWindowPolicy
    Modifier and Type | Method and Description
    --- | ---
    `static <K,A> DistributedSupplier<Processor>` | Processors.`accumulateByFrameP(List<DistributedFunction<?,? extends K>> keyFns, List<DistributedToLongFunction<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, AggregateOperation<A,?> aggrOp)` Returns a supplier of processors for the first-stage vertex in a two-stage sliding window aggregation setup (see the `class Javadoc` for an explanation of aggregation stages).
    `static <K,A,R,OUT> DistributedSupplier<Processor>` | Processors.`aggregateToSlidingWindowP(List<DistributedFunction<?,? extends K>> keyFns, List<DistributedToLongFunction<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, AggregateOperation<A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)` Returns a supplier of processors for a vertex that aggregates events into a sliding window in a single stage (see the `class Javadoc` for an explanation of aggregation stages).
    `static <K,A,R,OUT> DistributedSupplier<Processor>` | Processors.`combineToSlidingWindowP(SlidingWindowPolicy winPolicy, AggregateOperation<A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn)` Returns a supplier of processors for the second-stage vertex in a two-stage sliding window aggregation setup (see the `class Javadoc` for an explanation of aggregation stages).

  - ### Uses of SlidingWindowPolicy in com.hazelcast.jet.pipeline

    Methods in com.hazelcast.jet.pipeline that return SlidingWindowPolicy
    Modifier and Type | Method and Description
    --- | ---
    `SlidingWindowPolicy` | SlidingWindowDef.`toSlidingWindowPolicy()` Returns the policy object used by the Core API processors to drive the sliding window logic.

Copyright © 2018. All rights reserved.