com.hazelcast.jet.aggregate

Interface AggregateOperation1<T,A,R>

Type Parameters:

T - the type of the stream item

A - the type of the accumulator

R - the type of the aggregation result

All Superinterfaces:

AggregateOperation<A,R>, Serializable

public interface AggregateOperation1<T,A,R>
extends AggregateOperation<A,R>

Specialization of AggregateOperation to the "arity-1" case with a single data stream being aggregated over.

Method Summary

Modifier and Type	Method and Description
DistributedBiConsumer<? super A,? super T>	accumulateFn() A primitive that updates the accumulator state to account for a new item.
<R_NEW> AggregateOperation1<T,A,R_NEW>	withFinishFn(DistributedFunction<? super A,R_NEW> finishFn) Returns a copy of this aggregate operation, but with the finish primitive replaced with the supplied one.

Methods inherited from interface com.hazelcast.jet.aggregate.AggregateOperation

accumulateFn, accumulateFn, combineFn, createFn, deductFn, finishFn, withCombiningAccumulateFn, withCreate

Method Detail

accumulateFn

@Nonnull
DistributedBiConsumer<? super A,? super T> accumulateFn()

A primitive that updates the accumulator state to account for a new item.

withFinishFn

@Nonnull
<R_NEW> AggregateOperation1<T,A,R_NEW> withFinishFn(@Nonnull
                                                             DistributedFunction<? super A,R_NEW> finishFn)

Description copied from interface: AggregateOperation

Returns a copy of this aggregate operation, but with the finish primitive replaced with the supplied one.

Specified by:

withFinishFn in interface AggregateOperation<A,R>

Type Parameters:

R_NEW - the new aggregation result type

Parameters:

finishFn - the new finish primitive