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 supplied
accumulate primitive. |
<T> AggregateOperationBuilder.VarArity<A,Void> |
andAccumulate(Tag<T> tag,
BiConsumerEx<? super A,? super T> accumulateFn)
Registers the supplied
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 supplied
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)
accumulate
primitive. Also selects the
fixed-arity variant of the aggregate operation.
This method is synonymous with andAccumulate0(
BiConsumerEx)
, 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)
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-0T0
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
primitivecreateFn
of the current builderCopyright © 2020 Hazelcast, Inc.. All rights reserved.