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