Uses of Interface
com.hazelcast.jet.pipeline.BatchStageWithKey
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of BatchStageWithKey in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescription<K> BatchStageWithKey<T,
K> BatchStage.groupingKey
(FunctionEx<? super T, ? extends K> keyFn) Specifies the function that will extract a key from the items in the associated pipeline stage.Modifier and TypeMethodDescription<T,
R> Tag<R> GroupAggregateBuilder.add
(BatchStageWithKey<T, K> stage, AggregateOperation1<? super T, ?, ? extends R> aggrOp) Adds another stage that will contribute its data to the aggregate operation to be performed.<T> Tag<T>
GroupAggregateBuilder1.add
(BatchStageWithKey<T, K> stage) Adds another stage that will contribute its data to the aggregate operation to be performed.default <T1,
R0, R1> BatchStage<Map.Entry<K, Tuple2<R0, R1>>> BatchStageWithKey.aggregate2
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, BatchStageWithKey<? extends T1, ? extends K> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1) Attaches a stage that performs the given cogroup-and-aggregate transformation of the items from both this stage andstage1
you supply.<T1,
R> BatchStage<Map.Entry<K, R>> BatchStageWithKey.aggregate2
(BatchStageWithKey<T1, ? extends K> stage1, AggregateOperation2<? super T, ? super T1, ?, 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>
BatchStage<Map.Entry<K,Tuple3<R0, R1, R2>>> BatchStageWithKey.aggregate3
(AggregateOperation1<? super T, ?, ? extends R0> aggrOp0, BatchStageWithKey<T1, ? extends K> stage1, AggregateOperation1<? super T1, ?, ? extends R1> aggrOp1, BatchStageWithKey<T2, ? extends K> stage2, AggregateOperation1<? super T2, ?, ? extends R2> aggrOp2) Attaches a stage that performs the given cogroup-and-aggregate transformation of the items from this stage as well asstage1
andstage2
you supply.<T1,
T2, R> BatchStage<Map.Entry<K, R>> BatchStageWithKey.aggregate3
(BatchStageWithKey<T1, ? extends K> stage1, BatchStageWithKey<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.