Uses of Package
com.hazelcast.jet.aggregate
Package
Description
Contains
AggregateOperation
and its several variants, as well
as a builder object for the aggregate operations.Contains static utility classes with factories of Jet processors.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
ClassDescriptionContains primitives needed to compute an aggregated result of data processing.Specialization of
AggregateOperation
(refer to its extensive documentation) to the "arity-1" case with a single data stream being aggregated over.Specialization ofAggregateOperation
(refer to its extensive documentation) to the "arity-2" case with two data streams being aggregated over.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.The arity-1 variant of the aggregate operation builder.The arity-2 variant of the aggregate operation builder.The arity-3 variant of the aggregate operation builder.The variable-arity variant of the aggregate operation builder.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. -
ClassDescriptionContains primitives needed to compute an aggregated result of data processing.
-
ClassDescriptionContains primitives needed to compute an aggregated result of data processing.Specialization of
AggregateOperation
(refer to its extensive documentation) to the "arity-1" case with a single data stream being aggregated over.Specialization ofAggregateOperation
(refer to its extensive documentation) to the "arity-2" case with two data streams being aggregated over.Specialization ofAggregateOperation
(refer to its extensive documentation) to the "arity-3" case with three data streams being aggregated over.