com.hazelcast.jet.aggregate

Class AggregateOperationBuilder.Arity2<T0,T1,A>

java.lang.Object

com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity2<T0,T1,A>

Type Parameters:

T0 - the type of item in stream-0

T1 - the type of item in stream-1

A - the type of the accumulator

Enclosing class:

AggregateOperationBuilder<A>

public static class AggregateOperationBuilder.Arity2<T0,T1,A>
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>	andAccumulate2(DistributedBiConsumer<? super A,T2> accumulateFn2) Registers the supplied accumulate primitive for stream-2, returning the arity-3 variant of the builder.
AggregateOperationBuilder.Arity2<T0,T1,A>	andCombine(DistributedBiConsumer<? super A,? super A> combineFn) Registers the combine primitive.
AggregateOperationBuilder.Arity2<T0,T1,A>	andDeduct(DistributedBiConsumer<? super A,? super A> deductFn) Registers the deduct primitive.
<R> AggregateOperation2<T0,T1,A,R>	andFinish(DistributedFunction<? super A,R> finishFn) Constructs and returns an AggregateOperation2 from the current state of the builder and the supplied finish primitive.
AggregateOperation2<T0,T1,A,A>	andIdentityFinish() Constructs and returns an AggregateOperation2 from the current state of the builder, with the identity function as 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> andAccumulate2(@Nonnull
                                                                                 DistributedBiConsumer<? super A,T2> accumulateFn2)

Registers the supplied 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

Returns:

a new builder object that captures the T2 type parameter

andCombine

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

Registers the combine primitive.

andDeduct

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

Registers the deduct primitive.

andFinish

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

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

andIdentityFinish

@Nonnull
public AggregateOperation2<T0,T1,A,A> andIdentityFinish()

Constructs and returns an AggregateOperation2 from the current state of the builder, with the identity function as the finish primitive.