Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and its several variants, as well
as a builder object for the aggregate operations. |
Modifier and Type | Method and Description |
---|---|
<T1> AggregateOperationBuilder.Arity2<T0,T1,A,R> |
AggregateOperationBuilder.Arity1.andAccumulate1(BiConsumerEx<? super A,? super T1> accumulateFn1)
Registers the
AggregateOperation2.accumulateFn1() accumulate}
primitive for stream-1, returning the arity-2 variant of the builder. |
AggregateOperationBuilder.Arity2<T0,T1,A,R> |
AggregateOperationBuilder.Arity2.andCombine(BiConsumerEx<? super A,? super A> combineFn)
Registers the
combine primitive. |
AggregateOperationBuilder.Arity2<T0,T1,A,R> |
AggregateOperationBuilder.Arity2.andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers the
deduct primitive. |
<R_NEW> AggregateOperationBuilder.Arity2<T0,T1,A,R_NEW> |
AggregateOperationBuilder.Arity2.andExport(FunctionEx<? super A,? extends R_NEW> exportFn)
Registers the
export primitive. |
Copyright © 2022 Hazelcast, Inc.. All rights reserved.