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.Job
JetInstance. newJob(Pipeline pipeline, JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job configuration.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.Pipeline
Pipeline. setPreserveOrder(boolean value)
Tells Jet whether or not it is allowed to reorder the events for better performance.