Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
Modifier and Type | Method and Description |
---|---|
<T> AggregateOperationBuilder.Arity1<T,A> |
AggregateOperationBuilder.andAccumulate(DistributedBiConsumer<? super A,T> accumulateFn)
Registers the supplied
accumulate primitive. |
<T0> AggregateOperationBuilder.Arity1<T0,A> |
AggregateOperationBuilder.andAccumulate0(DistributedBiConsumer<? super A,T0> accumulateFn0)
Registers the supplied
accumulate primitive for stream-0. |
AggregateOperationBuilder.Arity1<T0,A> |
AggregateOperationBuilder.Arity1.andCombine(DistributedBiConsumer<? super A,? super A> combineFn)
Registers the
combine primitive. |
AggregateOperationBuilder.Arity1<T0,A> |
AggregateOperationBuilder.Arity1.andDeduct(DistributedBiConsumer<? super A,? super A> deductFn)
Registers the
deduct primitive. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.