Uses of Interface
com.hazelcast.jet.function.KeyedWindowResultFunction

Packages that use KeyedWindowResultFunction

Package	Description
com.hazelcast.jet.core.processor	Contains static utility classes with factories of Jet processors.
com.hazelcast.jet.function	Serializable variants of functional interfaces from java.util.function.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

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 and Description
static <K,A,R,OUT> DistributedSupplier<Processor>	Processors.aggregateToSessionWindowP(long sessionTimeout, List<DistributedToLongFunction<?>> timestampFns, List<DistributedFunction<?,? extends K>> keyFns, AggregateOperation<A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn) Returns a supplier of processors for a vertex that aggregates events into session windows.
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 KeyedWindowResultFunction in com.hazelcast.jet.function

Methods in com.hazelcast.jet.function that return KeyedWindowResultFunction

Modifier and Type	Method and Description
default KeyedWindowResultFunction<Object,R,OUT>	WindowResultFunction.toKeyedWindowResultFn()

Uses of KeyedWindowResultFunction in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline with parameters of type KeyedWindowResultFunction

Modifier and Type	Method and Description
<A,R,OUT> StreamStage<OUT>	StageWithGroupingAndWindow.aggregate(AggregateOperation1<? super T,A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn) Attaches to this stage a stage that performs the given group-and-aggregate operation over the window described by the window definition captured by this object.
<T1,A,R,OUT> StreamStage<OUT>	StageWithGroupingAndWindow.aggregate2(StreamStageWithGrouping<T1,? extends K> stage1, AggregateOperation2<? super T,? super T1,A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn) Attaches to this stage a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and stage1 you supply.
<T1,T2,A,R,OUT> StreamStage<OUT>	StageWithGroupingAndWindow.aggregate3(StreamStageWithGrouping<T1,? extends K> stage1, StreamStageWithGrouping<T2,? extends K> stage2, AggregateOperation3<? super T,? super T1,? super T2,A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn) Attaches to this stage a stage that performs the given cogroup-and-aggregate operation over the items from this stage as well as stage1 and stage2 you supply.
<A,R,OUT> StreamStage<OUT>	WindowGroupAggregateBuilder.build(AggregateOperation<A,R> aggrOp, KeyedWindowResultFunction<? super K,? super R,OUT> mapToOutputFn) Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate of the pipeline stages registered with this builder object.