Uses of Interface
com.hazelcast.jet.pipeline.Stage

Packages that use Stage

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of Stage in com.hazelcast.jet.pipeline

Subinterfaces of Stage in com.hazelcast.jet.pipeline

Modifier and Type	Interface	Description
interface	BatchStage<T>	A stage in a distributed computation pipeline that will observe a finite amount of data (a batch).
interface	GeneralStage<T>	The common aspect of batch and stream pipeline stages, defining those operations that apply to both.
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).

Methods in com.hazelcast.jet.pipeline that return Stage

Modifier and Type	Method	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.