T0
- the type of item in stream-0T1
- the type of item in stream-1A
- the type of the accumulatorR
- type of the aggregation resultpublic static class AggregateOperationBuilder.Arity2<T0,T1,A,R> extends Object
andAccumulate2()
.Modifier and Type | Method and Description |
---|---|
<T2> AggregateOperationBuilder.Arity3<T0,T1,T2,A,R> |
andAccumulate2(BiConsumerEx<? super A,? super T2> accumulateFn2)
Registers the
accumulate
primitive for stream-2, returning the arity-3 variant of the builder. |
AggregateOperationBuilder.Arity2<T0,T1,A,R> |
andCombine(BiConsumerEx<? super A,? super A> combineFn)
Registers the
combine primitive. |
AggregateOperationBuilder.Arity2<T0,T1,A,R> |
andDeduct(BiConsumerEx<? super A,? super A> deductFn)
Registers the
deduct primitive. |
<R_NEW> AggregateOperationBuilder.Arity2<T0,T1,A,R_NEW> |
andExport(FunctionEx<? super A,? extends R_NEW> exportFn)
Registers the
export primitive. |
<R_NEW> AggregateOperation2<T0,T1,A,R_NEW> |
andExportFinish(FunctionEx<? super A,? extends R_NEW> exportFinishFn)
|
AggregateOperation2<T0,T1,A,R> |
andFinish(FunctionEx<? super A,? extends R> finishFn)
Registers the
finish primitive. |
@Nonnull public <T2> AggregateOperationBuilder.Arity3<T0,T1,T2,A,R> andAccumulate2(@Nonnull BiConsumerEx<? super A,? super T2> accumulateFn2)
accumulate
primitive for stream-2, returning the arity-3 variant of the builder.T2
- the expected type of item in stream-2accumulateFn2
- the accumulate
primitive for stream-2. It
must be stateless and cooperative.T2
type parameter@Nonnull public AggregateOperationBuilder.Arity2<T0,T1,A,R> andCombine(@Nullable BiConsumerEx<? super A,? super A> combineFn)
combine
primitive.
The given function must be stateless and cooperative.
@Nonnull public AggregateOperationBuilder.Arity2<T0,T1,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.Arity2<T0,T1,A,R_NEW> andExport(@Nonnull FunctionEx<? super A,? extends R_NEW> exportFn)
export
primitive.
The given function must be stateless and cooperative.
@Nonnull public AggregateOperation2<T0,T1,A,R> andFinish(@Nonnull FunctionEx<? super A,? extends R> finishFn)
finish
primitive.
Constructs and returns an AggregateOperation2
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> AggregateOperation2<T0,T1,A,R_NEW> andExportFinish(@Nonnull FunctionEx<? super A,? extends R_NEW> exportFinishFn)
export
and finish
primitive.
Constructs and returns an AggregateOperation2
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.