T0
- type of item in stream-0A
- type of the accumulatorR
- type of the aggregation resultpublic static class AggregateOperationBuilder.Arity1<T0,A,R> extends Object
andAccumulate1()
.Modifier and Type | Method and Description |
---|---|
<T1> AggregateOperationBuilder.Arity2<T0,T1,A,R> |
andAccumulate1(BiConsumerEx<? super A,? super T1> accumulateFn1)
Registers the
AggregateOperation2.accumulateFn1() accumulate}
primitive for stream-1, returning the arity-2 variant of the builder. |
AggregateOperationBuilder.Arity1<T0,A,R> |
andCombine(BiConsumerEx<? super A,? super A> combineFn)
Registers the
combine primitive. |
AggregateOperationBuilder.Arity1<T0,A,R> |
andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers the
deduct primitive. |
<R_NEW> AggregateOperationBuilder.Arity1<T0,A,R_NEW> |
andExport(FunctionEx<? super A,? extends R_NEW> exportFn)
Registers the
export primitive. |
<R_NEW> AggregateOperation1<T0,A,R_NEW> |
andExportFinish(FunctionEx<? super A,? extends R_NEW> exportFinishFn)
|
AggregateOperation1<T0,A,R> |
andFinish(FunctionEx<? super A,? extends R> finishFn)
Registers the
finish primitive. |
@Nonnull public <T1> AggregateOperationBuilder.Arity2<T0,T1,A,R> andAccumulate1(@Nonnull BiConsumerEx<? super A,? super T1> accumulateFn1)
AggregateOperation2.accumulateFn1()
accumulate}
primitive for stream-1, returning the arity-2 variant of the builder.T1
- the expected type of item in stream-1accumulateFn1
- the accumulate
primitive for stream-1. It
must be stateless and cooperative.T1
type parameter@Nonnull public AggregateOperationBuilder.Arity1<T0,A,R> andCombine(@Nullable BiConsumerEx<? super A,? super A> combineFn)
combine
primitive.
The given function must be stateless and cooperative.
@Nonnull public AggregateOperationBuilder.Arity1<T0,A,R> andDeduct(@Nullable BiConsumerEx<? super A,? super A> deductFn)
deduct
primitive.
The given function must be stateless and cooperative.
@Nonnull public <R_NEW> AggregateOperationBuilder.Arity1<T0,A,R_NEW> andExport(@Nonnull FunctionEx<? super A,? extends R_NEW> exportFn)
export
primitive.
The given function must be stateless and cooperative.
@Nonnull public AggregateOperation1<T0,A,R> andFinish(@Nonnull FunctionEx<? super A,? extends R> finishFn)
finish
primitive.
Constructs and returns an AggregateOperation1
from the current
state of the builder.
The given function must be stateless and cooperative.
IllegalStateException
- if the export
primitive was
not registered@Nonnull public <R_NEW> AggregateOperation1<T0,A,R_NEW> andExportFinish(@Nonnull FunctionEx<? super A,? extends R_NEW> exportFinishFn)
export
and finish
primitive.
Constructs and returns an AggregateOperation1
from the current
state of the builder.
The given function must be stateless and cooperative.
IllegalStateException
- if the export
primitive is
already registeredCopyright © 2022 Hazelcast, Inc.. All rights reserved.