public interface ResourceManagerGateway extends RpcGateway
ResourceManager
's RPC gateway interface.Modifier and Type | Method and Description |
---|---|
void |
disconnectJobManager(JobID jobId,
Exception cause)
Disconnects a JobManager specified by the given resourceID from the
ResourceManager . |
void |
disconnectTaskManager(ResourceID resourceID,
Exception cause)
Disconnects a TaskManager specified by the given resourceID from the
ResourceManager . |
Future<Integer> |
getNumberOfRegisteredTaskManagers(UUID leaderSessionId)
Gets the currently registered number of TaskManagers.
|
void |
heartbeatFromJobManager(ResourceID heartbeatOrigin)
Sends the heartbeat to resource manager from job manager
|
void |
heartbeatFromTaskManager(ResourceID heartbeatOrigin)
Sends the heartbeat to resource manager from task manager
|
void |
notifySlotAvailable(UUID resourceManagerLeaderId,
InstanceID instanceId,
SlotID slotID,
AllocationID oldAllocationId)
Sent by the TaskExecutor to notify the ResourceManager that a slot has become available.
|
void |
registerInfoMessageListener(String infoMessageListenerAddress)
Registers an infoMessage listener
|
Future<RegistrationResponse> |
registerJobManager(UUID resourceManagerLeaderId,
UUID jobMasterLeaderId,
ResourceID jobMasterResourceId,
String jobMasterAddress,
JobID jobID,
Time timeout)
Register a
JobMaster at the resource manager. |
Future<RegistrationResponse> |
registerTaskExecutor(UUID resourceManagerLeaderId,
String taskExecutorAddress,
ResourceID resourceID,
SlotReport slotReport,
Time timeout)
Register a
TaskExecutor at the resource manager. |
Future<Acknowledge> |
requestSlot(UUID resourceManagerLeaderID,
UUID jobMasterLeaderID,
SlotRequest slotRequest,
Time timeout)
Requests a slot from the resource manager.
|
void |
shutDownCluster(ApplicationStatus finalStatus,
String optionalDiagnostics)
shutdown cluster
|
void |
unRegisterInfoMessageListener(String infoMessageListenerAddress)
Unregisters an infoMessage listener
|
getAddress, getHostname
Future<RegistrationResponse> registerJobManager(UUID resourceManagerLeaderId, UUID jobMasterLeaderId, ResourceID jobMasterResourceId, String jobMasterAddress, JobID jobID, Time timeout)
JobMaster
at the resource manager.resourceManagerLeaderId
- The fencing token for the ResourceManager leaderjobMasterLeaderId
- The fencing token for the JobMaster leaderjobMasterResourceId
- The resource ID of the JobMaster that registersjobMasterAddress
- The address of the JobMaster that registersjobID
- The Job ID of the JobMaster that registerstimeout
- Timeout for the future to completeFuture<Acknowledge> requestSlot(UUID resourceManagerLeaderID, UUID jobMasterLeaderID, SlotRequest slotRequest, Time timeout)
resourceManagerLeaderID
- leader if of the ResourceMasterjobMasterLeaderID
- leader if of the JobMasterslotRequest
- The slot to requestFuture<RegistrationResponse> registerTaskExecutor(UUID resourceManagerLeaderId, String taskExecutorAddress, ResourceID resourceID, SlotReport slotReport, Time timeout)
TaskExecutor
at the resource manager.resourceManagerLeaderId
- The fencing token for the ResourceManager leadertaskExecutorAddress
- The address of the TaskExecutor that registersresourceID
- The resource ID of the TaskExecutor that registersslotReport
- The slot report containing free and allocated task slotstimeout
- The timeout for the response.void notifySlotAvailable(UUID resourceManagerLeaderId, InstanceID instanceId, SlotID slotID, AllocationID oldAllocationId)
resourceManagerLeaderId
- The ResourceManager leader idinstanceId
- TaskExecutor's instance idslotID
- The SlotID of the freed slotoldAllocationId
- to which the slot has been allocatedvoid registerInfoMessageListener(String infoMessageListenerAddress)
infoMessageListenerAddress
- address of infoMessage listener to register to this resource managervoid unRegisterInfoMessageListener(String infoMessageListenerAddress)
infoMessageListenerAddress
- address of infoMessage listener to unregister from this resource managervoid shutDownCluster(ApplicationStatus finalStatus, String optionalDiagnostics)
finalStatus
- optionalDiagnostics
- Future<Integer> getNumberOfRegisteredTaskManagers(UUID leaderSessionId)
leaderSessionId
- The leader session ID with which to address the ResourceManager.void heartbeatFromTaskManager(ResourceID heartbeatOrigin)
heartbeatOrigin
- unique id of the task managervoid heartbeatFromJobManager(ResourceID heartbeatOrigin)
heartbeatOrigin
- unique id of the job managervoid disconnectTaskManager(ResourceID resourceID, Exception cause)
ResourceManager
.resourceID
- identifying the TaskManager to disconnectcause
- for the disconnection of the TaskManagervoid disconnectJobManager(JobID jobId, Exception cause)
ResourceManager
.jobId
- JobID for which the JobManager was the leadercause
- for the disconnection of the JobManagerCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.