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	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).