Uses of Interface
com.hazelcast.jet.pipeline.StreamStageWithKey

Packages that use StreamStageWithKey

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

Uses of StreamStageWithKey in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return StreamStageWithKey

Modifier and Type	Method and Description
<K> StreamStageWithKey<T,K>	StreamStage.groupingKey(FunctionEx<? super T,? extends K> keyFn)

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

Modifier and Type	Method and Description
<T> Tag<T>	WindowGroupAggregateBuilder1.add(StreamStageWithKey<T,K> stage) Adds another stage that will contribute its data to the windowed group-and-aggregate stage being constructed.
<T,R> Tag<R>	WindowGroupAggregateBuilder.add(StreamStageWithKey<T,K> stage, AggregateOperation1<? super T,?,? extends R> aggrOp) Adds another stage that will contribute its data to the windowed group-and-aggregate stage being constructed.
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.
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.
<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.