A
- the type of the accumulatorpublic final class AggregateOperationBuilder<A> extends Object
AggregateOperation.withCreate()
for more details.Modifier and Type | Class and Description |
---|---|
static class |
AggregateOperationBuilder.Arity1<T0,A,R>
The arity-1 variant of the aggregate operation builder.
|
static class |
AggregateOperationBuilder.Arity2<T0,T1,A,R>
The arity-2 variant of the aggregate operation builder.
|
static class |
AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>
The arity-3 variant of the aggregate operation builder.
|
static class |
AggregateOperationBuilder.VarArity<A,R>
The variable-arity variant of the aggregate operation builder.
|
Modifier and Type | Method and Description |
---|---|
<T> AggregateOperationBuilder.Arity1<T,A,Void> |
andAccumulate(BiConsumerEx<? super A,? super T> accumulateFn)
Registers the
AggregateOperation1.accumulateFn() accumulate}
primitive. |
<T> AggregateOperationBuilder.VarArity<A,Void> |
andAccumulate(Tag<T> tag,
BiConsumerEx<? super A,? super T> accumulateFn)
Registers the
accumulate
primitive for the stream tagged with the supplied tag. |
<T0> AggregateOperationBuilder.Arity1<T0,A,Void> |
andAccumulate0(BiConsumerEx<? super A,? super T0> accumulateFn0)
Registers the
accumulate
primitive for stream-0. |
AggregateOperationBuilder.VarArity<A,Void> |
varArity()
Selects the variable-arity variant for this aggregate operation builder.
|
@Nonnull public <T> AggregateOperationBuilder.Arity1<T,A,Void> andAccumulate(@Nonnull BiConsumerEx<? super A,? super T> accumulateFn)
AggregateOperation1.accumulateFn()
accumulate}
primitive. Also selects the fixed-arity variant of the aggregate
operation.
This method is synonymous with andAccumulate0()
, but makes more sense when defining a simple, arity-1
aggregate operation.
T
- the expected type of input itemaccumulateFn
- the accumulate
primitive, parameters are
(accumulator, item)
. It must be stateless and cooperative.T0
type parameter@Nonnull public <T0> AggregateOperationBuilder.Arity1<T0,A,Void> andAccumulate0(@Nonnull BiConsumerEx<? super A,? super T0> accumulateFn0)
accumulate
primitive for stream-0. Also selects the fixed-arity variant of the
aggregate operation.T0
- the expected type of item in stream-0accumulateFn0
- the accumulate
primitive for stream-0. It
must be stateless and cooperative.T0
type parameterpublic AggregateOperationBuilder.VarArity<A,Void> varArity()
createFn
of the current builder@Nonnull public <T> AggregateOperationBuilder.VarArity<A,Void> andAccumulate(@Nonnull Tag<T> tag, @Nonnull BiConsumerEx<? super A,? super T> accumulateFn)
accumulate
primitive for the stream tagged with the supplied tag. Also selects the
variable-arity variant of the aggregate operation.T
- the expected type of input itemtag
- the tag of the associated input streamaccumulateFn
- the accumulate
primitive. It must be
stateless and cooperative.createFn
of the current builderCopyright © 2023 Hazelcast, Inc.. All rights reserved.