Uses of Interface
com.hazelcast.jet.pipeline.Pipeline
Packages that use 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
Methods in com.hazelcast.jet with parameters of type PipelineModifier and TypeMethodDescriptiondefault JobCreates 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.newJobBuilder(Pipeline pipeline) Creates aJobBuilderfor a new Jet job withPipelinedefinition.JetService.newJobIfAbsent(Pipeline pipeline, JobConfig config) Creates and returns a Jet job based on the supplied pipeline and job configuration.default JobJetService.newLightJob(Pipeline pipeline) Submits a new light job with a default config.JetService.newLightJob(Pipeline pipeline, JobConfig config) Submits a light job for execution. -
Uses of Pipeline in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return PipelineModifier and TypeMethodDescriptionstatic PipelinePipeline.create()Creates a new, empty pipeline.Stage.getPipeline()Returns thePipelinethis stage belongs to.Pipeline.setPreserveOrder(boolean value) Tells Jet whether or not it is allowed to reorder the events for better performance.