Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
Modifier and Type | Method and Description |
---|---|
Job |
JetService.getJob(long jobId)
Returns the job with the given id or
null if no such job could
be found. |
default Job |
JetService.getJob(String name)
Returns the active or last submitted job with the given name or
null if no such job could be found. |
default Job |
JetService.newJob(DAG dag)
Creates and returns a Jet job based on the supplied DAG.
|
Job |
JetService.newJob(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job
configuration.
|
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(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG 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(DAG dag)
Submits a job defined in the Core API with a default config.
|
Job |
JetService.newLightJob(DAG dag,
JobConfig config)
Submits a job defined in the Core API.
|
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 |
---|---|
List<Job> |
JetService.getJobs()
Returns all submitted jobs.
|
List<Job> |
JetService.getJobs(String name)
Returns all jobs submitted with the given name, ordered in descending
order by submission time.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.