Uses of Interface
com.hazelcast.jet.pipeline.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 computationpipeline
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 computationpipeline
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.