| 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 © 2022 Hazelcast, Inc.. All rights reserved.