Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Method and Description |
---|---|
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.
|
default Job |
JetInstance.newJob(Pipeline pipeline,
JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job
configuration.
|
Modifier and Type | Method and Description |
---|---|
Collection<Job> |
JetInstance.getJobs()
Returns all submitted jobs including running and completed ones
|
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.