Interface JobMasterService
-
- All Superinterfaces:
AutoCloseable
,AutoCloseableAsync
- All Known Implementing Classes:
JobMaster
public interface JobMasterService extends AutoCloseableAsync
Interface which specifies the JobMaster service.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description String
getAddress()
Get the address of the JobMaster service under which it is reachable.JobMasterGateway
getGateway()
Get theJobMasterGateway
belonging to this service.CompletableFuture<Void>
getTerminationFuture()
Get the termination future of this job master service.-
Methods inherited from interface org.apache.flink.util.AutoCloseableAsync
close, closeAsync
-
-
-
-
Method Detail
-
getGateway
JobMasterGateway getGateway()
Get theJobMasterGateway
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
-
getTerminationFuture
CompletableFuture<Void> getTerminationFuture()
Get the termination future of this job master service.- Returns:
- future which is completed once the JobMasterService completes termination
-
-