java.lang.Object
- com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2<T0,T1,A,R>

Type Parameters:

T0 - the type of item in stream-0

T1 - the type of item in stream-1

A - the type of the accumulator

R - type of the aggregation result

Enclosing class:

AggregateOperationBuilder<A>
```
public static class AggregateOperationBuilder.Arity2<T0,T1,A,R>
extends java.lang.Object
```
The arity-2 variant of the aggregate operation builder. Can be raised to arity-3 by calling andAccumulate2().

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`<T2> AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>`	`andAccumulate2(BiConsumerEx<? super A,? super T2> accumulateFn2)`	Registers the `accumulate` primitive for stream-2, returning the arity-3 variant of the builder.
`AggregateOperationBuilder.Arity2<T0,T1,A,R>`	`andCombine(BiConsumerEx<? super A,? super A> combineFn)`	Registers the `combine` primitive.
`AggregateOperationBuilder.Arity2<T0,T1,A,R>`	`andDeduct(BiConsumerEx<? super A,? super A> deductFn)`	Registers the `deduct` primitive.
`<R_NEW> AggregateOperationBuilder.Arity2<T0,T1,A,R_NEW>`	`andExport(FunctionEx<? super A,? extends R_NEW> exportFn)`	Registers the `export` primitive.
`<R_NEW> AggregateOperation2<T0,T1,A,R_NEW>`	`andExportFinish(FunctionEx<? super A,? extends R_NEW> exportFinishFn)`	Registers the supplied function as both the `export` and `finish` primitive.
`AggregateOperation2<T0,T1,A,R>`	`andFinish(FunctionEx<? super A,? extends R> finishFn)`	Registers the `finish` primitive.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

andAccumulate2

@Nonnull
public <T2> AggregateOperationBuilder.Arity3<T0,T1,T2,A,R> andAccumulate2(@Nonnull
                                                                                                  BiConsumerEx<? super A,? super T2> accumulateFn2)

Registers the accumulate primitive for stream-2, returning the arity-3 variant of the builder.

Type Parameters:: T2 - the expected type of item in stream-2
Parameters:: accumulateFn2 - the accumulate primitive for stream-2. It must be stateless and cooperative.
Returns:: a new builder object that captures the T2 type parameter