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 |
JetInstance.getJob(long jobId)
Returns the job with the given id or
null if no such job could
be found. |
default Job |
JetInstance.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 |
JetInstance.newJob(DAG dag)
Creates and returns a Jet job based on the supplied DAG.
|
Job |
JetInstance.newJob(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job
configuration.
|
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(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job
configuration.
|
Job |
JetInstance.newJobIfAbsent(Pipeline pipeline,
JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job
configuration.
|
Modifier and Type | Method and Description |
---|---|
List<Job> |
JetInstance.getJobs()
Returns all submitted jobs including running and completed ones.
|
List<Job> |
JetInstance.getJobs(String name)
Returns all jobs submitted with the given name, ordered in descending
order by submission time.
|
Copyright © 2021 Hazelcast, Inc.. All rights reserved.