Package com.hazelcast.jet
Interface JetService.JobBuilder
- Enclosing interface:
- JetService
@NotThreadSafe
public static interface JetService.JobBuilder
- Since:
- 5.5
-
Method Summary
Modifier and TypeMethodDescriptionSeeJetService.newLightJob(Pipeline, JobConfig)
for details.start()
SeeJetService.newJob(Pipeline, JobConfig)
for details.SeeJetService.newJobIfAbsent(Pipeline, JobConfig)
for details.withConfig
(JobConfig jobConfig) SeeJobConfig
for details.withMemberSelector
(JetMemberSelector memberSelector) Selects the members on which the job will run.
-
Method Details
-
withConfig
SeeJobConfig
for details. -
withMemberSelector
Selects the members on which the job will run.If there is no member matching the selector during submission, the submission will be successful, but the job will fail with a
RejectedExecutionException
. If the cluster topology changes during the job execution and there is no longer a matching member, the job execution will be delayed until at least one member satisfies the selector. The duration between checks is the same as in cluster safety and quorum checks, which is 2 seconds and not configurable.- See Also:
-
asLightJob
JetService.JobBuilder asLightJob()SeeJetService.newLightJob(Pipeline, JobConfig)
for details. -
start
Job start()SeeJetService.newJob(Pipeline, JobConfig)
for details.- See Also:
-
startIfAbsent
Job startIfAbsent()SeeJetService.newJobIfAbsent(Pipeline, JobConfig)
for details.- Throws:
UnsupportedOperationException
- for light jobs- See Also:
-