Uses of Class
com.hazelcast.jet.datamodel.Tuple2
Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and its several variants, as well
as a builder object for the aggregate operations. |
com.hazelcast.jet.datamodel |
Generic data containers used by the Pipeline API.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of Tuple2 in com.hazelcast.jet.aggregate
Methods in com.hazelcast.jet.aggregate that return types with arguments of type Tuple2 Modifier and Type Method Description static <T0, T1, A0, A1, R0, R1>
AggregateOperation2<T0,T1,Tuple2<A0,A1>,Tuple2<R0,R1>>AggregateOperations. aggregateOperation2(AggregateOperation1<? super T0,A0,? extends R0> op0, AggregateOperation1<? super T1,A1,? extends R1> op1)
Convenience foraggregateOperation2(aggrOp0, aggrOp1, finishFn)
that outputs aTuple2(result0, result1)
.static <T0, T1, A0, A1, R0, R1>
AggregateOperation2<T0,T1,Tuple2<A0,A1>,Tuple2<R0,R1>>AggregateOperations. aggregateOperation2(AggregateOperation1<? super T0,A0,? extends R0> op0, AggregateOperation1<? super T1,A1,? extends R1> op1)
Convenience foraggregateOperation2(aggrOp0, aggrOp1, finishFn)
that outputs aTuple2(result0, result1)
.static <T0, A0, R0, T1, A1, R1, R>
AggregateOperation2<T0,T1,Tuple2<A0,A1>,R>AggregateOperations. aggregateOperation2(AggregateOperation1<? super T0,A0,? extends R0> op0, AggregateOperation1<? super T1,A1,? extends R1> op1, BiFunctionEx<? super R0,? super R1,? extends R> exportFinishFn)
Returns an aggregate operation that is a composite of two independent aggregate operations, each one accepting its own input.static <T, A0, A1, R0, R1, R>
AggregateOperation1<T,Tuple2<A0,A1>,R>AggregateOperations. allOf(AggregateOperation1<? super T,A0,? extends R0> op0, AggregateOperation1<? super T,A1,? extends R1> op1, BiFunctionEx<? super R0,? super R1,? extends R> exportFinishFn)
Returns an aggregate operation that is a composite of two aggregate operations.static <T, A0, A1, R0, R1>
AggregateOperation1<T,Tuple2<A0,A1>,Tuple2<R0,R1>>AggregateOperations. allOf(AggregateOperation1<? super T,A0,R0> op1, AggregateOperation1<? super T,A1,R1> op2)
Convenience forAggregateOperations.allOf(AggregateOperation1, AggregateOperation1, BiFunctionEx)
wrapping the two results in aTuple2
.static <T, A0, A1, R0, R1>
AggregateOperation1<T,Tuple2<A0,A1>,Tuple2<R0,R1>>AggregateOperations. allOf(AggregateOperation1<? super T,A0,R0> op1, AggregateOperation1<? super T,A1,R1> op2)
Convenience forAggregateOperations.allOf(AggregateOperation1, AggregateOperation1, BiFunctionEx)
wrapping the two results in aTuple2
. -
Uses of Tuple2 in com.hazelcast.jet.datamodel
Methods in com.hazelcast.jet.datamodel that return Tuple2 Modifier and Type Method Description static <E0, E1> Tuple2<E0,E1>
Tuple2. tuple2(E0 f0, E1 f1)
Returns a new 2-tuple with the supplied values. -
Uses of Tuple2 in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return types with arguments of type Tuple2 Modifier and Type Method Description default <T1, R0, R1> BatchStage<Tuple2<R0,R1>>
BatchStage. aggregate2(AggregateOperation1<? super T,?,? extends R0> aggrOp0, BatchStage<T1> stage1, AggregateOperation1<? super T1,?,? extends R1> aggrOp1)
Attaches a stage that co-aggregates the data from this and the supplied stage by performing a separate aggregate operation on each and emits a singleTuple2
with their results.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.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.default <T1, R0, R1> StreamStage<WindowResult<Tuple2<R0,R1>>>
StageWithWindow. aggregate2(AggregateOperation1<? super T,?,? extends R0> aggrOp0, StreamStage<T1> stage1, AggregateOperation1<? super T1,?,? extends R1> aggrOp1)
Attaches a stage that performs the given co-aggregate operations over the items from this stage andstage1
you supply.