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.