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.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Method and Description |
---|---|
static <T0,T1,T2,A0,A1,A2,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> |
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.
|
<R_NEW> AggregateOperation3<T0,T1,T2,A,R_NEW> |
AggregateOperationBuilder.Arity3.andExportFinish(FunctionEx<? super A,? extends R_NEW> exportFinishFn)
|
AggregateOperation3<T0,T1,T2,A,R> |
AggregateOperationBuilder.Arity3.andFinish(FunctionEx<? super A,? extends R> finishFn)
Registers the
finish primitive. |
<R_NEW> AggregateOperation3<T0,T1,T2,A,R_NEW> |
AggregateOperation3.andThen(FunctionEx<? super R,? extends R_NEW> thenFn) |
<T0_NEW> AggregateOperation3<T0_NEW,T1,T2,A,R> |
AggregateOperation3.withAccumulateFn0(BiConsumerEx<? super A,? super T0_NEW> newAccFn0)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 0 replaced with the one supplied here. |
<T1_NEW> AggregateOperation3<T0,T1_NEW,T2,A,R> |
AggregateOperation3.withAccumulateFn1(BiConsumerEx<? super A,? super T1_NEW> newAccFn1)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 1 replaced with the one supplied here. |
<T2_NEW> AggregateOperation3<T0,T1,T2_NEW,A,R> |
AggregateOperation3.withAccumulateFn2(BiConsumerEx<? super A,? super T2_NEW> newAccFn2)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 2 replaced with the one supplied here. |
AggregateOperation3<T0,T1,T2,A,A> |
AggregateOperation3.withIdentityFinish() |
Modifier and Type | Method and Description |
---|---|
<T1,T2,R> BatchStage<R> |
BatchStage.aggregate3(BatchStage<T1> stage1,
BatchStage<T2> stage2,
AggregateOperation3<? super T,? super T1,? super T2,?,? extends R> aggrOp)
Attaches a stage that performs the given aggregate operation over all
the items it receives from this stage as well as
stage1 and
stage2 you supply. |
<T1,T2,R> BatchStage<Map.Entry<K,R>> |
BatchStageWithKey.aggregate3(BatchStageWithKey<T1,? extends K> stage1,
BatchStageWithKey<T2,? extends K> stage2,
AggregateOperation3<? super T,? super T1,? super T2,?,? extends R> aggrOp)
Attaches a stage that performs the given cogroup-and-aggregate operation
over the items from this stage as well as
stage1 and stage2 you supply. |
<T1,T2,R> StreamStage<WindowResult<R>> |
StageWithWindow.aggregate3(StreamStage<T1> stage1,
StreamStage<T2> stage2,
AggregateOperation3<? super T,? super T1,? super T2,?,? extends R> aggrOp)
Attaches a stage that performs the given aggregate operation over the
items it receives from this stage as well as
stage1 and stage2 you supply. |
<T1,T2,R> StreamStage<KeyedWindowResult<K,R>> |
StageWithKeyAndWindow.aggregate3(StreamStageWithKey<T1,? extends K> stage1,
StreamStageWithKey<T2,? extends K> stage2,
AggregateOperation3<? super T,? super T1,? super T2,?,? extends R> aggrOp)
Attaches a stage that performs the given cogroup-and-aggregate operation
over the items from this stage as well as
stage1 and stage2 you supply. |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.