Package com.hazelcast.jet.aggregate
Interface AggregateOperation3<T0,T1,T2,A,R>
- Type Parameters:
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 result
- All Superinterfaces:
AggregateOperation<A,R>
,Serializable
public interface AggregateOperation3<T0,T1,T2,A,R> extends AggregateOperation<A,R>
Specialization of
AggregateOperation
(refer to its extensive documentation) to the "arity-3" case with
three data streams being aggregated over. AggregateOperations
contains factories for the built-in implementations and you can create
your own using the aggregate
operation builder.
This example constructs an operation that sums up long
values
from three streams:
AggregateOperation3<Long, Long, Long, LongAccumulator, Long> aggrOp = AggregateOperation
.withCreate(LongAccumulator::new)
.<Long>andAccumulate0(LongAccumulator::add)
.<Long>andAccumulate1(LongAccumulator::add)
.<Long>andAccumulate2(LongAccumulator::add)
.andFinish(LongAccumulator::get);
- Since:
- 3.0
-
Method Summary
Modifier and Type Method Description BiConsumerEx<? super A,? super T0>
accumulateFn0()
A primitive that updates the accumulator state to account for a new item coming from stream-0.BiConsumerEx<? super A,? super T1>
accumulateFn1()
A primitive that updates the accumulator state to account for a new item coming from stream-1.BiConsumerEx<? super A,? super T2>
accumulateFn2()
A primitive that updates the accumulator state to account for a new item coming from stream-2.<R_NEW> AggregateOperation3<T0,T1,T2,A,R_NEW>
andThen(FunctionEx<? super R,? extends R_NEW> thenFn)
Returns a copy of this aggregate operation, but with theexport
andfinish
primitives composed with the suppliedthenFn
.<T0_NEW> AggregateOperation3<T0_NEW,T1,T2,A,R>
withAccumulateFn0(BiConsumerEx<? super A,? super T0_NEW> newAccFn0)
Returns a copy of this aggregate operation, but with theaccumulate
primitive at index 0 replaced with the one supplied here.<T1_NEW> AggregateOperation3<T0,T1_NEW,T2,A,R>
withAccumulateFn1(BiConsumerEx<? super A,? super T1_NEW> newAccFn1)
Returns a copy of this aggregate operation, but with theaccumulate
primitive at index 1 replaced with the one supplied here.<T2_NEW> AggregateOperation3<T0,T1,T2_NEW,A,R>
withAccumulateFn2(BiConsumerEx<? super A,? super T2_NEW> newAccFn2)
Returns a copy of this aggregate operation, but with theaccumulate
primitive at index 2 replaced with the one supplied here.AggregateOperation3<T0,T1,T2,A,A>
withIdentityFinish()
Returns a copy of this aggregate operation, but with thefinish
primitive replaced with the identity function.Methods inherited from interface com.hazelcast.jet.aggregate.AggregateOperation
accumulateFn, accumulateFn, arity, combineFn, createFn, deductFn, exportFn, finishFn, withAccumulateFns, withCombiningAccumulateFn
-
Method Details
-
accumulateFn0
A primitive that updates the accumulator state to account for a new item coming from stream-0. -
accumulateFn1
A primitive that updates the accumulator state to account for a new item coming from stream-1. -
accumulateFn2
A primitive that updates the accumulator state to account for a new item coming from stream-2. -
withAccumulateFn0
@Nonnull <T0_NEW> AggregateOperation3<T0_NEW,T1,T2,A,R> withAccumulateFn0(@Nonnull BiConsumerEx<? super A,? super T0_NEW> newAccFn0)Returns a copy of this aggregate operation, but with theaccumulate
primitive at index 0 replaced with the one supplied here. -
withAccumulateFn1
@Nonnull <T1_NEW> AggregateOperation3<T0,T1_NEW,T2,A,R> withAccumulateFn1(@Nonnull BiConsumerEx<? super A,? super T1_NEW> newAccFn1)Returns a copy of this aggregate operation, but with theaccumulate
primitive at index 1 replaced with the one supplied here. -
withAccumulateFn2
@Nonnull <T2_NEW> AggregateOperation3<T0,T1,T2_NEW,A,R> withAccumulateFn2(@Nonnull BiConsumerEx<? super A,? super T2_NEW> newAccFn2)Returns a copy of this aggregate operation, but with theaccumulate
primitive at index 2 replaced with the one supplied here. -
withIdentityFinish
Description copied from interface:AggregateOperation
Returns a copy of this aggregate operation, but with thefinish
primitive replaced with the identity function. It will return the accumulator object as-is. The returned aggregate operation does not support theexport
primitive.- Specified by:
withIdentityFinish
in interfaceAggregateOperation<T0,T1>
-
andThen
@Nonnull <R_NEW> AggregateOperation3<T0,T1,T2,A,R_NEW> andThen(FunctionEx<? super R,? extends R_NEW> thenFn)Description copied from interface:AggregateOperation
Returns a copy of this aggregate operation, but with theexport
andfinish
primitives composed with the suppliedthenFn
. This replacesexportFn
withexportFn.andThen(thenFn)
, same forfinishFn
. The main use case is to transform the result of an existing (library-provided) aggregate operation.- Specified by:
andThen
in interfaceAggregateOperation<T0,T1>
- Type Parameters:
R_NEW
- the type of the returned aggregate operation's result- Parameters:
thenFn
- the function to apply to the results ofexport
andfinish
primitives
-