com.hazelcast.jet.aggregate

Class AggregateOperationBuilder.VarArity<A>

java.lang.Object

com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity<A>

Type Parameters:

A - the type of the accumulator

Enclosing class:

AggregateOperationBuilder<A>

public static class AggregateOperationBuilder.VarArity<A>
extends Object

The variable-arity variant of the aggregate operation builder. Accepts any number of accumulate primitives and associates them with Tags. Does not capture the static type of the stream items.

Method Summary

Modifier and Type	Method and Description
<T> AggregateOperationBuilder.VarArity<A>	andAccumulate(Tag<T> tag, DistributedBiConsumer<? super A,T> accumulateFn) Registers the supplied accumulate primitive for the stream tagged with the supplied tag.
AggregateOperationBuilder.VarArity<A>	andCombine(DistributedBiConsumer<? super A,? super A> combineFn) Registers the combine primitive.
AggregateOperationBuilder.VarArity<A>	andDeduct(DistributedBiConsumer<? super A,? super A> deductFn) Registers the deduct primitive.
<R> AggregateOperation<A,R>	andFinish(DistributedFunction<? super A,R> finishFn) Constructs and returns an AggregateOperation from the current state of the builder and the supplied finish primitive.
AggregateOperation<A,A>	andIdentityFinish() Constructs and returns an AggregateOperation 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

andAccumulate

@Nonnull
public <T> AggregateOperationBuilder.VarArity<A> andAccumulate(@Nonnull
                                                                        Tag<T> tag,
                                                                        @Nonnull
                                                                        DistributedBiConsumer<? super A,T> accumulateFn)

Registers the supplied accumulate primitive for the stream tagged with the supplied tag.

Type Parameters:

T - the expected type of input item

Parameters:

tag - the tag of the associated input stream

accumulateFn - the accumulate primitive

Returns:

this

andCombine

@Nonnull
public AggregateOperationBuilder.VarArity<A> andCombine(@Nullable
                                                                 DistributedBiConsumer<? super A,? super A> combineFn)

Registers the combine primitive.

andDeduct

@Nonnull
public AggregateOperationBuilder.VarArity<A> andDeduct(@Nullable
                                                                DistributedBiConsumer<? super A,? super A> deductFn)

Registers the deduct primitive.

andFinish

@Nonnull
public <R> AggregateOperation<A,R> andFinish(@Nonnull
                                                      DistributedFunction<? super A,R> finishFn)

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

andIdentityFinish

@Nonnull
public AggregateOperation<A,A> andIdentityFinish()

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