Package com.hazelcast.jet.aggregate
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
-
ClassDescriptionAggregateOperation<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.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.The variable-arity variant of the aggregate operation builder.Utility class with factory methods for several useful aggregate operations.Offers a step-by-step API to create a composite of multiple aggregate operations.Offers a step-by-step API to create an aggregate operation that accepts multiple inputs.