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 ofAggregateOperation
(refer to its extensive documentation) to the "arity-1" case with a single data stream being aggregated over.AggregateOperation2<T0,T1,A,R> Specialization ofAggregateOperation
(refer to its extensive documentation) to the "arity-2" case with two data streams being aggregated over.AggregateOperation3<T0,T1,T2,A,R> Specialization ofAggregateOperation
(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.