| 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 | 
|---|---|
<T> AggregateOperationBuilder.VarArity<A,Void> | 
AggregateOperationBuilder.andAccumulate(Tag<T> tag,
             BiConsumerEx<? super A,? super T> accumulateFn)
Registers the  
accumulate
 primitive 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  
accumulate
 primitive for the stream tagged with the supplied tag. | 
AggregateOperationBuilder.VarArity<A,R> | 
AggregateOperationBuilder.VarArity.andCombine(BiConsumerEx<? super A,? super A> combineFn)
Registers the  
combine primitive. | 
AggregateOperationBuilder.VarArity<A,R> | 
AggregateOperationBuilder.VarArity.andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers the  
deduct primitive. | 
<R_NEW> AggregateOperationBuilder.VarArity<A,R_NEW> | 
AggregateOperationBuilder.VarArity.andExport(FunctionEx<? super A,? extends R_NEW> exportFn)
Registers the  
export primitive. | 
AggregateOperationBuilder.VarArity<A,Void> | 
AggregateOperationBuilder.varArity()
Selects the variable-arity variant for this aggregate operation builder. 
 | 
Copyright © 2023 Hazelcast, Inc.. All rights reserved.