Package com.hazelcast.jet.aggregate
Class AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>
java.lang.Object
com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>
- Type Parameters:
T0
- the type of item in stream-0T1
- the type of item in stream-1T2
- the type of item in stream-2A
- the type of the accumulatorR
- type of the aggregation result
- Enclosing class:
- AggregateOperationBuilder<A>
public static class AggregateOperationBuilder.Arity3<T0,T1,T2,A,R> extends Object
The arity-3 variant of the aggregate operation builder.
-
Method Summary
Modifier and Type Method Description AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>
andCombine(BiConsumerEx<? super A,? super A> combineFn)
Registers thecombine
primitive.AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>
andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers thededuct
primitive.<R_NEW> AggregateOperationBuilder.Arity3<T0,T1,T2,A,R_NEW>
andExport(FunctionEx<? super A,? extends R_NEW> exportFn)
Registers theexport
primitive.<R_NEW> AggregateOperation3<T0,T1,T2,A,R_NEW>
andExportFinish(FunctionEx<? super A,? extends R_NEW> exportFinishFn)
Registers the supplied function as both theexport
andfinish
primitive.AggregateOperation3<T0,T1,T2,A,R>
andFinish(FunctionEx<? super A,? extends R> finishFn)
Registers the supplied function as thefinish
primitive.
-
Method Details
-
andCombine
@Nonnull public AggregateOperationBuilder.Arity3<T0,T1,T2,A,R> andCombine(@Nullable BiConsumerEx<? super A,? super A> combineFn)Registers thecombine
primitive. -
andDeduct
@Nonnull public AggregateOperationBuilder.Arity3<T0,T1,T2,A,R> andDeduct(@Nullable BiConsumerEx<? super A,? super A> deductFn)Registers thededuct
primitive. -
andExport
@Nonnull public <R_NEW> AggregateOperationBuilder.Arity3<T0,T1,T2,A,R_NEW> andExport(@Nonnull FunctionEx<? super A,? extends R_NEW> exportFn)Registers theexport
primitive. -
andFinish
@Nonnull public AggregateOperation3<T0,T1,T2,A,R> andFinish(@Nonnull FunctionEx<? super A,? extends R> finishFn)Registers the supplied function as thefinish
primitive. Constructs and returns anAggregateOperation1
from the current state of the builder.- Throws:
IllegalStateException
- if theexport
primitive was not registered
-
andExportFinish
@Nonnull public <R_NEW> AggregateOperation3<T0,T1,T2,A,R_NEW> andExportFinish(@Nonnull FunctionEx<? super A,? extends R_NEW> exportFinishFn)Registers the supplied function as both theexport
andfinish
primitive. Constructs and returns anAggregateOperation3
from the current state of the builder.- Throws:
IllegalStateException
- if theexport
primitive is already registered
-