org.apache.flink.runtime.jobmaster

Interface JobMasterService

All Superinterfaces:

AutoCloseable, AutoCloseableAsync

All Known Implementing Classes:

JobMaster

public interface JobMasterService
extends AutoCloseableAsync

Interface which specifies the JobMaster service.

Method Summary

Modifier and Type	Method and Description
String	getAddress() Get the address of the JobMaster service under which it is reachable.
JobMasterGateway	getGateway() Get the JobMasterGateway belonging to this service.
CompletableFuture<Acknowledge>	start(JobMasterId jobMasterId) Start the JobMaster service with the given JobMasterId.
CompletableFuture<Acknowledge>	suspend(Exception cause) Suspend the JobMaster service.

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close, closeAsync

Method Detail

start

CompletableFuture<Acknowledge> start(JobMasterId jobMasterId)
                              throws Exception

Start the JobMaster service with the given JobMasterId.

Parameters:

jobMasterId - to start the service with

Returns:

Future which is completed once the JobMaster service has been started

Throws:

Exception - if the JobMaster service could not be started

suspend

CompletableFuture<Acknowledge> suspend(Exception cause)

Suspend the JobMaster service. This means that the service will stop to react to messages.

Parameters:

cause - for the suspension

Returns:

Future which is completed once the JobMaster service has been suspended

getGateway

JobMasterGateway getGateway()

Get the JobMasterGateway belonging to this service.

Returns:

JobMasterGateway belonging to this service

getAddress

String getAddress()

Get the address of the JobMaster service under which it is reachable.

Returns:

Address of the JobMaster service