Uses of Interface
com.hazelcast.jet.core.function.KeyedWindowResultFunction
Package | Description |
---|---|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
-
Uses of KeyedWindowResultFunction in com.hazelcast.jet.core.processor
Methods in com.hazelcast.jet.core.processor with parameters of type KeyedWindowResultFunction Modifier and Type Method Description static <K, A, R, OUT>
SupplierEx<Processor>Processors. aggregateToSessionWindowP(long sessionTimeout, long earlyResultsPeriod, List<ToLongFunctionEx<?>> timestampFns, List<FunctionEx<?,? extends K>> keyFns, 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 session windows.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).