Uses of Class
com.hazelcast.jet.datamodel.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 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 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
Methods in com.hazelcast.jet.datamodel that return Tuple3 Modifier and Type Method 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 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 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.