Uses of Interface
com.hazelcast.jet.pipeline.Pipeline
Package
Description
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of Pipeline in com.hazelcast.jet
Modifier and TypeMethodDescriptiondefault Job
Creates and returns an executable job based on the supplied pipeline.Creates and returns a Jet job based on the supplied pipeline and job configuration.JetService.newJobIfAbsent
(Pipeline pipeline, JobConfig config) Creates and returns a Jet job based on the supplied pipeline and job configuration.default Job
JetService.newLightJob
(Pipeline p) Submits a new light job with a default config.JetService.newLightJob
(Pipeline p, JobConfig config) Submits a light job for execution. -
Uses of Pipeline in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionstatic Pipeline
Pipeline.create()
Creates a new, empty pipeline.Stage.getPipeline()
Returns thePipeline
this stage belongs to.Pipeline.setPreserveOrder
(boolean value) Tells Jet whether or not it is allowed to reorder the events for better performance.