| Package | Description | 
|---|---|
| com.hazelcast.jet.aggregate | Contains  AggregateOperationand its several variants, as well
 as a builder object for the aggregate operations. | 
| Modifier and Type | Method and Description | 
|---|---|
| <T> AggregateOperationBuilder.VarArity<A,Void> | AggregateOperationBuilder. andAccumulate(Tag<T> tag,
             BiConsumerEx<? super A,? super T> accumulateFn)Registers the  accumulateprimitive for the stream tagged with the supplied tag. | 
| <T> AggregateOperationBuilder.VarArity<A,R> | AggregateOperationBuilder.VarArity. andAccumulate(Tag<T> tag,
             BiConsumerEx<? super A,T> accumulateFn)Registers the  accumulateprimitive for the stream tagged with the supplied tag. | 
| AggregateOperationBuilder.VarArity<A,R> | AggregateOperationBuilder.VarArity. andCombine(BiConsumerEx<? super A,? super A> combineFn)Registers the  combineprimitive. | 
| AggregateOperationBuilder.VarArity<A,R> | AggregateOperationBuilder.VarArity. andDeduct(BiConsumerEx<? super A,? super A> deductFn)Registers the  deductprimitive. | 
| <R_NEW> AggregateOperationBuilder.VarArity<A,R_NEW> | AggregateOperationBuilder.VarArity. andExport(FunctionEx<? super A,? extends R_NEW> exportFn)Registers the  exportprimitive. | 
| AggregateOperationBuilder.VarArity<A,Void> | AggregateOperationBuilder. varArity()Selects the variable-arity variant for this aggregate operation builder. | 
Copyright © 2022 Hazelcast, Inc.. All rights reserved.