com.hazelcast.jet.aggregate

Class AggregateOperationBuilder.Arity1<T0,A,R>

java.lang.Object

com.hazelcast.jet.aggregate.AggregateOperationBuilder.Arity1<T0,A,R>

Type Parameters:

T0 - type of item in stream-0

A - type of the accumulator

R - type of the aggregation result

Enclosing class:

AggregateOperationBuilder<A>

public static class AggregateOperationBuilder.Arity1<T0,A,R>
extends Object

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

Method Summary

Modifier and Type	Method and Description
<T1> AggregateOperationBuilder.Arity2<T0,T1,A,R>	andAccumulate1(DistributedBiConsumer<? super A,? super T1> accumulateFn1) Registers the supplied accumulate primitive for stream-1, returning the arity-2 variant of the builder.
AggregateOperationBuilder.Arity1<T0,A,R>	andCombine(DistributedBiConsumer<? super A,? super A> combineFn) Registers the combine primitive.
AggregateOperationBuilder.Arity1<T0,A,R>	andDeduct(DistributedBiConsumer<? super A,? super A> deductFn) Registers the deduct primitive.
<R_NEW> AggregateOperationBuilder.Arity1<T0,A,R_NEW>	andExport(DistributedFunction<? super A,? extends R_NEW> exportFn) Registers the export primitive.
<R_NEW> AggregateOperation1<T0,A,R_NEW>	andExportFinish(DistributedFunction<? super A,? extends R_NEW> exportFinishFn) Registers the supplied function as both the export and finish primitive.
AggregateOperation1<T0,A,R>	andFinish(DistributedFunction<? super A,? extends R> finishFn) Registers the supplied 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

andAccumulate1

@Nonnull
public <T1> AggregateOperationBuilder.Arity2<T0,T1,A,R> andAccumulate1(@Nonnull
                                                                                DistributedBiConsumer<? super A,? super T1> accumulateFn1)

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

Type Parameters:

T1 - the expected type of item in stream-1

Parameters:

accumulateFn1 - the accumulate primitive for stream-1

Returns:

a new builder object that captures the T1 type parameter

andCombine

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

Registers the combine primitive.

andDeduct

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

Registers the deduct primitive.

andExport

@Nonnull
public <R_NEW> AggregateOperationBuilder.Arity1<T0,A,R_NEW> andExport(@Nonnull
                                                                               DistributedFunction<? super A,? extends R_NEW> exportFn)

Registers the export primitive.

andFinish

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

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

Throws:

IllegalStateException - if the export primitive was not registered

andExportFinish

@Nonnull
public <R_NEW> AggregateOperation1<T0,A,R_NEW> andExportFinish(@Nonnull
                                                                        DistributedFunction<? super A,? extends R_NEW> exportFinishFn)

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

Throws:

IllegalStateException - if the export primitive is already registered