org.apache.flink.runtime.jobmaster.factories

Interface JobMasterServiceFactory

All Known Implementing Classes:

DefaultJobMasterServiceFactory

public interface JobMasterServiceFactory

Factory for the JobMasterService.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<JobMasterService>	createJobMasterService(UUID leaderSessionId, OnCompletionActions onCompletionActions) Creates a new JobMasterService for the given leaderSessionId and onCompletionActions.

Method Detail

createJobMasterService

CompletableFuture<JobMasterService> createJobMasterService(UUID leaderSessionId,
                                                           OnCompletionActions onCompletionActions)

Creates a new JobMasterService for the given leaderSessionId and onCompletionActions.

Parameters:

leaderSessionId - leaderSessionId for which to create a JobMasterService

onCompletionActions - onCompletionActions which are given to the created JobMasterService

Returns:

Future which contains the newly created JobMasterService