T0
- the type of item in stream-0T1
- the type of item in stream-1T2
- the type of item in stream-2A
- the type of the accumulatorR
- the type of the aggregation resultpublic interface AggregateOperation3<T0,T1,T2,A,R> extends AggregateOperation<A,R>
AggregateOperation
to the "arity-3" case with
two data stream being aggregated over.Modifier and Type | Method and Description |
---|---|
DistributedBiConsumer<? super A,? super T0> |
accumulateFn0()
A primitive that updates the accumulator state to account for a new
item coming from stream-0.
|
DistributedBiConsumer<? super A,? super T1> |
accumulateFn1()
A primitive that updates the accumulator state to account for a new
item coming from stream-1.
|
DistributedBiConsumer<? super A,? super T2> |
accumulateFn2()
A primitive that updates the accumulator state to account for a new
item coming from stream-2.
|
<R1> AggregateOperation3<T0,T1,T2,A,R1> |
withFinishFn(DistributedFunction<? super A,R1> finishFn)
Returns a copy of this aggregate operation, but with the
finish
primitive replaced with the supplied one. |
accumulateFn, accumulateFn, combineFn, createFn, deductFn, finishFn, withCombiningAccumulateFn, withCreate
@Nonnull DistributedBiConsumer<? super A,? super T0> accumulateFn0()
@Nonnull DistributedBiConsumer<? super A,? super T1> accumulateFn1()
@Nonnull DistributedBiConsumer<? super A,? super T2> accumulateFn2()
@Nonnull <R1> AggregateOperation3<T0,T1,T2,A,R1> withFinishFn(@Nonnull DistributedFunction<? super A,R1> finishFn)
AggregateOperation
finish
primitive replaced with the supplied one.withFinishFn
in interface AggregateOperation<A,R>
R1
- the new aggregation result typefinishFn
- the new finish
primitiveCopyright © 2017 Hazelcast, Inc.. All Rights Reserved.