Uses of Class
com.hazelcast.jet.core.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 Description static SlidingWindowPolicy
SlidingWindowPolicy. slidingWinPolicy(long windowSize, long slideBy)
Returns the definition of a sliding window of lengthwindowSize
that slides byslideBy
.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 lengthwindowSize
.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 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 theclass 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 theclass 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 theclass Javadoc
for an explanation of aggregation stages).