public class ResourceTrackerService
extends org.apache.hadoop.service.AbstractService
implements org.apache.hadoop.yarn.server.api.ResourceTracker
Constructor and Description |
---|
ResourceTrackerService(RMContext rmContext,
NodesListManager nodesListManager,
NMLivelinessMonitor nmLivelinessMonitor,
RMContainerTokenSecretManager containerTokenSecretManager,
NMTokenSecretManagerInRM nmTokenSecretManager) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.ipc.Server |
getServer() |
org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse |
nodeHeartbeat(org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest request) |
org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse |
registerNodeManager(org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest request) |
static org.apache.hadoop.net.Node |
resolve(String hostName)
resolving the network topology.
|
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStart() |
protected void |
serviceStop() |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public ResourceTrackerService(RMContext rmContext, NodesListManager nodesListManager, NMLivelinessMonitor nmLivelinessMonitor, RMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInRM nmTokenSecretManager)
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
public org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerResponse registerNodeManager(org.apache.hadoop.yarn.server.api.protocolrecords.RegisterNodeManagerRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
registerNodeManager
in interface org.apache.hadoop.yarn.server.api.ResourceTracker
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatResponse nodeHeartbeat(org.apache.hadoop.yarn.server.api.protocolrecords.NodeHeartbeatRequest request) throws org.apache.hadoop.yarn.exceptions.YarnException, IOException
nodeHeartbeat
in interface org.apache.hadoop.yarn.server.api.ResourceTracker
org.apache.hadoop.yarn.exceptions.YarnException
IOException
public static org.apache.hadoop.net.Node resolve(String hostName)
hostName
- the hostname of this node.Node
for this nodemanager.public org.apache.hadoop.ipc.Server getServer()
Copyright © 2019 Apache Software Foundation. All Rights Reserved.