com.hazelcast.jet.aggregate

Class AggregateOperationBuilder.Arity2<T0,T1,A,R>

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 Object

The arity-2 variant of the aggregate operation builder. Can be raised to arity-3 by calling andAccumulate2().

Method Summary

Modifier and Type	Method and 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

andCombine

@Nonnull
public AggregateOperationBuilder.Arity2<T0,T1,A,R> andCombine(@Nullable
                                                                       BiConsumerEx<? super A,? super A> combineFn)

Registers the combine primitive.

The given function must be stateless and cooperative.

andDeduct

@Nonnull
public AggregateOperationBuilder.Arity2<T0,T1,A,R> andDeduct(@Nullable
                                                                      BiConsumerEx<? super A,? super A> deductFn)

Registers the deduct primitive.

The given function must be stateless and cooperative.

andExport

@Nonnull
public <R_NEW> AggregateOperationBuilder.Arity2<T0,T1,A,R_NEW> andExport(@Nonnull
                                                                                  FunctionEx<? super A,? extends R_NEW> exportFn)

Registers the export primitive.

The given function must be stateless and cooperative.

andFinish

@Nonnull
public AggregateOperation2<T0,T1,A,R> andFinish(@Nonnull
                                                         FunctionEx<? super A,? extends R> finishFn)

Registers the finish primitive. Constructs and returns an AggregateOperation2 from the current state of the builder.

The given function must be stateless and cooperative.

Throws:

IllegalStateException - if the export primitive was not registered

andExportFinish

@Nonnull
public <R_NEW> AggregateOperation2<T0,T1,A,R_NEW> andExportFinish(@Nonnull
                                                                           FunctionEx<? super A,? extends R_NEW> exportFinishFn)

Registers the supplied function as both the export and finish primitive. Constructs and returns an AggregateOperation2 from the current state of the builder.

The given function must be stateless and cooperative.

Throws:

IllegalStateException - if the export primitive is already registered