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 |
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.
|
LightJob |
JetInstance.newLightJob(Pipeline p)
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 © 2021 Hazelcast, Inc.. All rights reserved.