T- the type of the stream item
A- the type of the accumulator
R- the type of the aggregation result
public interface AggregateOperation1<T,A,R> extends AggregateOperation<A,R>
AggregateOperationto the "arity-1" case with a single data stream being aggregated over.
|Modifier and Type||Method and Description|
A primitive that updates the accumulator state to account for a new item.
Returns a copy of this aggregate operation, but with the
@Nonnull DistributedBiConsumer<? super A,? super T> accumulateFn()
@Nonnull <R_NEW> AggregateOperation1<T,A,R_NEW> withFinishFn(@Nonnull DistributedFunction<? super A,R_NEW> finishFn)
finishprimitive replaced with the supplied one.
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.