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

Packages that use Tuple3

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 Tuple3 in com.hazelcast.jet.aggregate

Methods in com.hazelcast.jet.aggregate that return types with arguments of type Tuple3

Modifier and Type	Method and Description
static <T0,T1,T2,A0,A1,A2,R0,R1,R2> AggregateOperation3<T0,T1,T2,Tuple3<A0,A1,A2>,Tuple3<R0,R1,R2>>	AggregateOperations.aggregateOperation3(AggregateOperation1<? super T0,A0,? extends R0> op0, AggregateOperation1<? super T1,A1,? extends R1> op1, AggregateOperation1<? super T2,A2,? extends R2> op2) Convenience for aggregateOperation3(aggrOp0, aggrOp1, aggrOp2, finishFn) that outputs a Tuple3(result0, result1, result2).
static <T0,T1,T2,A0,A1,A2,R0,R1,R2> AggregateOperation3<T0,T1,T2,Tuple3<A0,A1,A2>,Tuple3<R0,R1,R2>>	AggregateOperations.aggregateOperation3(AggregateOperation1<? super T0,A0,? extends R0> op0, AggregateOperation1<? super T1,A1,? extends R1> op1, AggregateOperation1<? super T2,A2,? extends R2> op2) Convenience for aggregateOperation3(aggrOp0, aggrOp1, aggrOp2, finishFn) that outputs a Tuple3(result0, result1, result2).
static <T0,T1,T2,A0,A1,A2,R0,R1,R2,R> AggregateOperation3<T0,T1,T2,Tuple3<A0,A1,A2>,R>	AggregateOperations.aggregateOperation3(AggregateOperation1<? super T0,A0,? extends R0> op0, AggregateOperation1<? super T1,A1,? extends R1> op1, AggregateOperation1<? super T2,A2,? extends R2> op2, TriFunction<? super R0,? super R1,? super R2,? extends R> exportFinishFn) Returns an aggregate operation that is a composite of three independent aggregate operations, each one accepting its own input.
static <T,A0,A1,A2,R0,R1,R2> AggregateOperation1<T,Tuple3<A0,A1,A2>,Tuple3<R0,R1,R2>>	AggregateOperations.allOf(AggregateOperation1<? super T,A0,? extends R0> op0, AggregateOperation1<? super T,A1,? extends R1> op1, AggregateOperation1<? super T,A2,? extends R2> op2) Convenience for AggregateOperations.allOf(AggregateOperation1, AggregateOperation1, AggregateOperation1, TriFunction) wrapping the three results in a Tuple3.
static <T,A0,A1,A2,R0,R1,R2> AggregateOperation1<T,Tuple3<A0,A1,A2>,Tuple3<R0,R1,R2>>	AggregateOperations.allOf(AggregateOperation1<? super T,A0,? extends R0> op0, AggregateOperation1<? super T,A1,? extends R1> op1, AggregateOperation1<? super T,A2,? extends R2> op2) Convenience for AggregateOperations.allOf(AggregateOperation1, AggregateOperation1, AggregateOperation1, TriFunction) wrapping the three results in a Tuple3.
static <T,A0,A1,A2,R0,R1,R2,R> AggregateOperation1<T,Tuple3<A0,A1,A2>,R>	AggregateOperations.allOf(AggregateOperation1<? super T,A0,? extends R0> op0, AggregateOperation1<? super T,A1,? extends R1> op1, AggregateOperation1<? super T,A2,? extends R2> op2, TriFunction<? super R0,? super R1,? super R2,? extends R> exportFinishFn) Returns an aggregate operation that is a composite of three aggregate operations.

Uses of Tuple3 in com.hazelcast.jet.datamodel

Methods in com.hazelcast.jet.datamodel that return Tuple3

Modifier and Type	Method and Description
static <E0,E1,E2> Tuple3<E0,E1,E2>	Tuple3.tuple3(E0 f0, E1 f1, E2 f2) Returns a new 3-tuple with the supplied values.

Uses of Tuple3 in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return types with arguments of type Tuple3

Modifier and Type	Method and Description
default <T1,T2,R0,R1,R2> BatchStage<Tuple3<R0,R1,R2>>	BatchStage.aggregate3(AggregateOperation1<? super T,?,? extends R0> aggrOp0, BatchStage<T1> stage1, AggregateOperation1<? super T1,?,? extends R1> aggrOp1, BatchStage<T2> stage2, AggregateOperation1<? super T2,?,? extends R2> aggrOp2) Attaches a stage that co-aggregates the data from this and the two supplied stages by performing a separate aggregate operation on each and emits a single Tuple3 with their results.
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 as stage1 and stage2 you supply.
default <T1,T2,R0,R1,R2> StreamStage<WindowResult<Tuple3<R0,R1,R2>>>	StageWithWindow.aggregate3(AggregateOperation1<? super T,?,? extends R0> aggrOp0, StreamStage<T1> stage1, AggregateOperation1<? super T1,?,? extends R1> aggrOp1, StreamStage<T2> stage2, AggregateOperation1<? super T2,?,? extends R2> aggrOp2) Attaches a stage that performs the given aggregate operation over all the items that belong to the same window.
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 and stage1 you supply.