Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BatchStage<T>
A stage in a distributed computation
pipeline that will
observe a finite amount of data (a batch). |
interface |
GeneralStage<T>
|
interface |
SinkStage
A pipeline stage that doesn't allow any downstream stages to be attached
to it.
|
interface |
StreamStage<T>
A stage in a distributed computation
pipeline that will
observe an unbounded amount of data (i.e., an event stream). |
Modifier and Type | Method and Description |
---|---|
Stage |
Stage.setLocalParallelism(int localParallelism)
Sets the preferred local parallelism (number of processors per Jet
cluster member) this stage will configure its DAG vertices with.
|
Stage |
Stage.setName(String name)
Overrides the default name of the stage with the name you choose and
returns the stage.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.