Uses of Class
com.hazelcast.jet.datamodel.Tuple2

Packages that use 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 for aggregateOperation2(aggrOp0, aggrOp1, finishFn) that outputs a Tuple2(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 for aggregateOperation2(aggrOp0, aggrOp1, finishFn) that outputs a Tuple2(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 for AggregateOperations.allOf(AggregateOperation1, AggregateOperation1, BiFunctionEx) wrapping the two results in a Tuple2.
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 for AggregateOperations.allOf(AggregateOperation1, AggregateOperation1, BiFunctionEx) wrapping the two results in a Tuple2.

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 single Tuple2 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 and stage1 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 and stage1 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 and stage1 you supply.