Uses of Class
com.hazelcast.jet.datamodel.Tuple3
Package
Description
Contains
AggregateOperation
and its several variants, as well
as a builder object for the aggregate operations.Generic data containers used by the Pipeline API.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of Tuple3 in com.hazelcast.jet.aggregate
Modifier and TypeMethodDescriptionstatic <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 foraggregateOperation3(aggrOp0, aggrOp1, aggrOp2, finishFn)
that outputs aTuple3(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 foraggregateOperation3(aggrOp0, aggrOp1, aggrOp2, finishFn)
that outputs aTuple3(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 forAggregateOperations.allOf(AggregateOperation1, AggregateOperation1, AggregateOperation1, TriFunction)
wrapping the three results in aTuple3
.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 forAggregateOperations.allOf(AggregateOperation1, AggregateOperation1, AggregateOperation1, TriFunction)
wrapping the three results in aTuple3
.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
-
Uses of Tuple3 in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptiondefault <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 singleTuple3
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 asstage1
andstage2
you supply.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 andstage1
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.