Package com.hazelcast.jet.aggregate

Contains AggregateOperation and its several variants, as well as a builder object for the aggregate operations.

Since:

Jet 3.0

Interface Summary

Interface	Description
AggregateOperation<A,R>	Contains primitives needed to compute an aggregated result of data processing.
AggregateOperation1<T,A,R>	Specialization of AggregateOperation (refer to its extensive documentation) to the "arity-1" case with a single data stream being aggregated over.
AggregateOperation2<T0,T1,A,R>	Specialization of AggregateOperation (refer to its extensive documentation) to the "arity-2" case with two data streams being aggregated over.
AggregateOperation3<T0,T1,T2,A,R>	Specialization of AggregateOperation (refer to its extensive documentation) to the "arity-3" case with three data streams being aggregated over.

Class Summary

Class	Description
AggregateOperationBuilder<A>	A builder object that can be used to construct the definition of an aggregate operation in a step-by-step manner.
AggregateOperationBuilder.Arity1<T0,A,R>	The arity-1 variant of the aggregate operation builder.
AggregateOperationBuilder.Arity2<T0,T1,A,R>	The arity-2 variant of the aggregate operation builder.
AggregateOperationBuilder.Arity3<T0,T1,T2,A,R>	The arity-3 variant of the aggregate operation builder.
AggregateOperationBuilder.VarArity<A,R>	The variable-arity variant of the aggregate operation builder.
AggregateOperations	Utility class with factory methods for several useful aggregate operations.
AllOfAggregationBuilder<T>	Offers a step-by-step API to create a composite of multiple aggregate operations.
CoAggregateOperationBuilder	Offers a step-by-step API to create an aggregate operation that accepts multiple inputs.