Package | Description |
---|---|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and its several variants, as well
as a builder object for the aggregate operations. |
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Class and Description |
---|
AggregateOperation
Contains primitives needed to compute an aggregated result of data
processing.
|
AggregateOperation1
Specialization of
AggregateOperation (refer to its extensive documentation) to the "arity-1" case with
a single data stream being aggregated over. |
AggregateOperation2
Specialization of
AggregateOperation (refer to its extensive documentation) to the "arity-2" case with
two data streams being aggregated over. |
AggregateOperation3
Specialization of
AggregateOperation (refer to its extensive documentation) to the "arity-3" case with
three data streams being aggregated over. |
AggregateOperationBuilder
A builder object that can be used to construct the definition of an
aggregate operation in a step-by-step manner.
|
AggregateOperationBuilder.Arity1
The arity-1 variant of the aggregate operation builder.
|
AggregateOperationBuilder.Arity2
The arity-2 variant of the aggregate operation builder.
|
AggregateOperationBuilder.Arity3
The arity-3 variant of the aggregate operation builder.
|
AggregateOperationBuilder.VarArity
The variable-arity variant of the aggregate operation builder.
|
AllOfAggregationBuilder
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.
|
Class and Description |
---|
AggregateOperation
Contains primitives needed to compute an aggregated result of data
processing.
|
Class and Description |
---|
AggregateOperation
Contains primitives needed to compute an aggregated result of data
processing.
|
AggregateOperation1
Specialization of
AggregateOperation (refer to its extensive documentation) to the "arity-1" case with
a single data stream being aggregated over. |
AggregateOperation2
Specialization of
AggregateOperation (refer to its extensive documentation) to the "arity-2" case with
two data streams being aggregated over. |
AggregateOperation3
Specialization of
AggregateOperation (refer to its extensive documentation) to the "arity-3" case with
three data streams being aggregated over. |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.