Uses of Class
com.hazelcast.jet.datamodel.KeyedWindowResult
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of KeyedWindowResult in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescription<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 andstage1
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 andstage1
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 andstage1
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 asstage1
andstage2
you supply.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).