Uses of Interface
com.hazelcast.jet.pipeline.BatchStageWithKey
Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of BatchStageWithKey in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return BatchStageWithKey Modifier and Type Method Description <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.Methods in com.hazelcast.jet.pipeline with parameters of type BatchStageWithKey Modifier and Type Method Description <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.