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.
|
Modifier and Type | Method and Description |
---|---|
default Job |
JetService.newJob(Pipeline pipeline)
Creates and returns an executable job based on the supplied pipeline.
|
Job |
JetService.newJob(Pipeline pipeline,
JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job
configuration.
|
Job |
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.
|
Job |
JetService.newLightJob(Pipeline p,
JobConfig config)
Submits a light job for execution.
|
Modifier and Type | Method and Description |
---|---|
static Pipeline |
Pipeline.create()
Creates a new, empty pipeline.
|
Pipeline |
Stage.getPipeline()
Returns the
Pipeline this stage belongs to. |
Pipeline |
Pipeline.setPreserveOrder(boolean value)
Tells Jet whether or not it is allowed to reorder the events for better
performance.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.