Uses of Interface
com.hazelcast.jet.Job

Packages that use Job

Package	Description
com.hazelcast.jet	Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.
com.hazelcast.jet.cdc	Contains source/sink connectors that deal with Change Data Capture (CDC) events from various databases as well as a generic connector for Debezium CDC sources.

Uses of Job in com.hazelcast.jet

Methods in com.hazelcast.jet that return Job

Modifier and Type	Method	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 pipeline)	Submits a new light job with a default config.
Job	JetService.newLightJob(Pipeline pipeline, JobConfig config)	Submits a light job for execution.
Job	JetService.JobBuilder.start()	See JetService.newJob(Pipeline, JobConfig) for details.
Job	JetService.JobBuilder.startIfAbsent()	See JetService.newJobIfAbsent(Pipeline, JobConfig) for details.

Methods in com.hazelcast.jet that return types with arguments of type Job

Modifier and Type	Method	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.

Uses of Job in com.hazelcast.jet.cdc

Methods in com.hazelcast.jet.cdc with parameters of type Job

Modifier and Type	Method	Description
static boolean	SnapshotCompletionListener.isSnapshotCompleted(HazelcastInstance instance, Job job)	Checks whether every registered tracked source of a running job has completed its initial snapshot.