Uses of Interface
com.hazelcast.jet.pipeline.Pipeline
Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of Pipeline in com.hazelcast.jet
Methods in com.hazelcast.jet with parameters of type Pipeline Modifier and Type Method Description default Job
JetInstance. newJob(Pipeline pipeline)
Creates and returns an executable job based on the supplied pipeline.default Job
JetInstance. newJob(Pipeline pipeline, JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job configuration.default Job
JetInstance. newJobIfAbsent(Pipeline pipeline, JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job configuration. -
Uses of Pipeline in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return Pipeline Modifier and Type Method Description static Pipeline
Pipeline. create()
Creates a new, empty pipeline.Pipeline
Stage. getPipeline()
Returns thePipeline
this stage belongs to.