Uses of Class
com.hazelcast.jet.aggregate.AggregateOperationBuilder.VarArity
Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
-
Uses of AggregateOperationBuilder.VarArity in com.hazelcast.jet.aggregate
Methods in com.hazelcast.jet.aggregate that return AggregateOperationBuilder.VarArity Modifier and Type Method Description <T> AggregateOperationBuilder.VarArity<A,Void>
AggregateOperationBuilder. andAccumulate(Tag<T> tag, BiConsumerEx<? super A,? super T> accumulateFn)
Registers theaccumulate
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 theaccumulate
primitive for the stream tagged with the supplied tag.AggregateOperationBuilder.VarArity<A,R>
AggregateOperationBuilder.VarArity. andCombine(BiConsumerEx<? super A,? super A> combineFn)
Registers thecombine
primitive.AggregateOperationBuilder.VarArity<A,R>
AggregateOperationBuilder.VarArity. andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers thededuct
primitive.<R_NEW> AggregateOperationBuilder.VarArity<A,R_NEW>
AggregateOperationBuilder.VarArity. andExport(FunctionEx<? super A,? extends R_NEW> exportFn)
Registers theexport
primitive.AggregateOperationBuilder.VarArity<A,Void>
AggregateOperationBuilder. varArity()
Selects the variable-arity variant for this aggregate operation builder.