Package com.hazelcast.jet

Interface JetService.JobBuilder

Enclosing interface:

JetService

@NotThreadSafe
public static interface JetService.JobBuilder

Since:

5.5

Method Summary

Modifier and Type	Method	Description
JetService.JobBuilder	asLightJob()	See JetService.newLightJob(Pipeline, JobConfig) for details.
Job	start()	See JetService.newJob(Pipeline, JobConfig) for details.
Job	startIfAbsent()	See JetService.newJobIfAbsent(Pipeline, JobConfig) for details.
JetService.JobBuilder	withConfig(JobConfig jobConfig)	See JobConfig for details.
JetService.JobBuilder	withMemberSelector(JetMemberSelector memberSelector)	Selects the members on which the job will run.

Method Details

withConfig

JetService.JobBuilder withConfig(@Nonnull
 JobConfig jobConfig)

See JobConfig for details.

withMemberSelector

JetService.JobBuilder withMemberSelector(@Nonnull
 JetMemberSelector memberSelector)

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:

• JetMemberSelector.ALL_LITE_MEMBERS

asLightJob

JetService.JobBuilder asLightJob()

See JetService.newLightJob(Pipeline, JobConfig) for details.

start

Job start()

See JetService.newJob(Pipeline, JobConfig) for details.

See Also:

• startIfAbsent()

startIfAbsent

Job startIfAbsent()

See JetService.newJobIfAbsent(Pipeline, JobConfig) for details.

Throws:

UnsupportedOperationException - for light jobs

See Also:

• start()