public interface ResourceManagerGateway extends FencedRpcGateway<ResourceManagerId>
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 . |
CompletableFuture<Integer> |
getNumberOfRegisteredTaskManagers()
Gets the currently registered number of TaskManagers.
|
void |
heartbeatFromJobManager(ResourceID heartbeatOrigin)
Sends the heartbeat to resource manager from job manager
|
void |
heartbeatFromTaskManager(ResourceID heartbeatOrigin,
SlotReport slotReport)
Sends the heartbeat to resource manager from task manager
|
void |
notifySlotAvailable(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
|
CompletableFuture<RegistrationResponse> |
registerJobManager(JobMasterId jobMasterId,
ResourceID jobMasterResourceId,
String jobMasterAddress,
JobID jobId,
Time timeout)
Register a
JobMaster at the resource manager. |
CompletableFuture<RegistrationResponse> |
registerTaskExecutor(String taskExecutorAddress,
ResourceID resourceId,
SlotReport slotReport,
Time timeout)
Register a
TaskExecutor at the resource manager. |
CompletableFuture<ResourceOverview> |
requestResourceOverview(Time timeout)
Requests the resource overview.
|
CompletableFuture<Acknowledge> |
requestSlot(JobMasterId jobMasterId,
SlotRequest slotRequest,
Time timeout)
Requests a slot from the resource manager.
|
CompletableFuture<Collection<Tuple2<ResourceID,String>>> |
requestTaskManagerMetricQueryServicePaths(Time timeout)
Requests the paths for the TaskManager's
MetricQueryService to query. |
void |
shutDownCluster(ApplicationStatus finalStatus,
String optionalDiagnostics)
shutdown cluster
|
void |
unRegisterInfoMessageListener(String infoMessageListenerAddress)
Unregisters an infoMessage listener
|
getFencingToken
getAddress, getHostname
CompletableFuture<RegistrationResponse> registerJobManager(JobMasterId jobMasterId, ResourceID jobMasterResourceId, String jobMasterAddress, JobID jobId, Time timeout)
JobMaster
at the resource manager.jobMasterId
- 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 completeCompletableFuture<Acknowledge> requestSlot(JobMasterId jobMasterId, SlotRequest slotRequest, Time timeout)
jobMasterId
- id of the JobMasterslotRequest
- The slot to requestCompletableFuture<RegistrationResponse> registerTaskExecutor(String taskExecutorAddress, ResourceID resourceId, SlotReport slotReport, Time timeout)
TaskExecutor
at the resource manager.taskExecutorAddress
- 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(InstanceID instanceId, SlotID slotID, AllocationID oldAllocationId)
instanceId
- 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
- CompletableFuture<Integer> getNumberOfRegisteredTaskManagers()
void heartbeatFromTaskManager(ResourceID heartbeatOrigin, SlotReport slotReport)
heartbeatOrigin
- unique id of the task managerslotReport
- Current slot allocation on the originating TaskManagervoid 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 JobManagerCompletableFuture<ResourceOverview> requestResourceOverview(Time timeout)
timeout
- of the requestCompletableFuture<Collection<Tuple2<ResourceID,String>>> requestTaskManagerMetricQueryServicePaths(Time timeout)
MetricQueryService
to query.timeout
- for the asynchronous operationCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.