Uses of Class
com.hazelcast.jet.datamodel.KeyedWindowResult

Packages that use KeyedWindowResult

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of KeyedWindowResult in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return types with arguments of type KeyedWindowResult

Modifier and Type	Method and Description
<R> StreamStage<KeyedWindowResult<K,R>>	StageWithKeyAndWindow.aggregate(AggregateOperation1<? super T,?,? extends R> aggrOp) Attaches a stage that performs the given group-and-aggregate operation.
default <T1,R0,R1> StreamStage<KeyedWindowResult<K,Tuple2<R0,R1>>>	StageWithKeyAndWindow.aggregate2(AggregateOperation1<? super T,?,? extends R0> aggrOp0, StreamStageWithKey<T1,? extends K> stage1, AggregateOperation1<? super T1,?,? extends R1> aggrOp1) Attaches a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and stage1 you supply.
<T1,R> StreamStage<KeyedWindowResult<K,R>>	StageWithKeyAndWindow.aggregate2(StreamStageWithKey<T1,? extends K> stage1, AggregateOperation2<? super T,? super T1,?,? extends R> aggrOp) Attaches a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and stage1 you supply.
default <T1,T2,R0,R1,R2> StreamStage<KeyedWindowResult<K,Tuple3<R0,R1,R2>>>	StageWithKeyAndWindow.aggregate3(AggregateOperation1<? super T,?,? extends R0> aggrOp0, StreamStageWithKey<T1,? extends K> stage1, AggregateOperation1<? super T1,?,? extends R1> aggrOp1, StreamStageWithKey<T2,? extends K> stage2, AggregateOperation1<? super T2,?,? extends R2> aggrOp2) Attaches a stage that performs the given cogroup-and-aggregate operation over the items from both this stage and stage1 you supply.
<T1,T2,R> StreamStage<KeyedWindowResult<K,R>>	StageWithKeyAndWindow.aggregate3(StreamStageWithKey<T1,? extends K> stage1, StreamStageWithKey<T2,? extends K> stage2, AggregateOperation3<? super T,? super T1,? super T2,?,? extends R> aggrOp) Attaches a stage that performs the given cogroup-and-aggregate operation over the items from this stage as well as stage1 and stage2 you supply.
StreamStage<KeyedWindowResult<K,ItemsByTag>>	WindowGroupAggregateBuilder.build() Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate operation on the stages registered with this builder object.
<R> StreamStage<KeyedWindowResult<K,R>>	WindowGroupAggregateBuilder1.build(AggregateOperation<?,? extends R> aggrOp) Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate of the pipeline stages registered with this builder object.
default StreamStage<KeyedWindowResult<K,T>>	StageWithKeyAndWindow.distinct() Attaches a stage that passes through just the items that are distinct within their window according to the grouping key (no two items emitted for a window map to the same key).