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.

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.

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> SupplierEx<Processor>	Processors.accumulateByFrameP(List<FunctionEx<?,? extends K>> keyFns, List<ToLongFunctionEx<?>> 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> SupplierEx<Processor>	Processors.accumulateByFrameP(List<FunctionEx<?,? extends K>> keyFns, List<ToLongFunctionEx<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, AggregateOperation<A,?> aggrOp, byte watermarkKey) 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> SupplierEx<Processor>	Processors.aggregateToSlidingWindowP(List<FunctionEx<?,? extends K>> keyFns, List<ToLongFunctionEx<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, long earlyResultsPeriod, AggregateOperation<A,? extends R> aggrOp, KeyedWindowResultFunction<? super K,? super R,? extends 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> SupplierEx<Processor>	Processors.aggregateToSlidingWindowP(List<FunctionEx<?,? extends K>> keyFns, List<ToLongFunctionEx<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, long earlyResultsPeriod, AggregateOperation<A,? extends R> aggrOp, KeyedWindowResultFunction<? super K,? super R,? extends OUT> mapToOutputFn, byte windowWatermarkKey) 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> SupplierEx<Processor>	Processors.combineToSlidingWindowP(SlidingWindowPolicy winPolicy, AggregateOperation<A,? extends R> aggrOp, KeyedWindowResultFunction<? super K,? super R,? extends 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).
static <K,A,R,OUT> SupplierEx<Processor>	Processors.combineToSlidingWindowP(SlidingWindowPolicy winPolicy, AggregateOperation<A,? extends R> aggrOp, KeyedWindowResultFunction<? super K,? super R,? extends OUT> mapToOutputFn, byte windowWatermarkKey) 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) with specified windowWatermarkKey.