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.