org.apache.hadoop.yarn.server.resourcemanager
Class ResourceTrackerService
java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.server.resourcemanager.ResourceTrackerService
- All Implemented Interfaces:
- Closeable, org.apache.hadoop.service.Service, org.apache.hadoop.yarn.server.api.ResourceTracker
public class ResourceTrackerService
- extends org.apache.hadoop.service.AbstractService
- implements org.apache.hadoop.yarn.server.api.ResourceTracker
Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service |
org.apache.hadoop.service.Service.STATE |
Method Summary |
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()
|
Methods inherited from class org.apache.hadoop.service.AbstractService |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop |
ResourceTrackerService
public ResourceTrackerService(RMContext rmContext,
NodesListManager nodesListManager,
NMLivelinessMonitor nmLivelinessMonitor,
RMContainerTokenSecretManager containerTokenSecretManager,
NMTokenSecretManagerInRM nmTokenSecretManager)
serviceInit
protected void serviceInit(org.apache.hadoop.conf.Configuration conf)
throws Exception
- Overrides:
serviceInit
in class org.apache.hadoop.service.AbstractService
- Throws:
Exception
serviceStart
protected void serviceStart()
throws Exception
- Overrides:
serviceStart
in class org.apache.hadoop.service.AbstractService
- Throws:
Exception
serviceStop
protected void serviceStop()
throws Exception
- Overrides:
serviceStop
in class org.apache.hadoop.service.AbstractService
- Throws:
Exception
registerNodeManager
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
- Specified by:
registerNodeManager
in interface org.apache.hadoop.yarn.server.api.ResourceTracker
- Throws:
org.apache.hadoop.yarn.exceptions.YarnException
IOException
nodeHeartbeat
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
- Specified by:
nodeHeartbeat
in interface org.apache.hadoop.yarn.server.api.ResourceTracker
- Throws:
org.apache.hadoop.yarn.exceptions.YarnException
IOException
resolve
public static org.apache.hadoop.net.Node resolve(String hostName)
- resolving the network topology.
- Parameters:
hostName
- the hostname of this node.
- Returns:
- the resolved
Node
for this nodemanager.
Copyright © 2014 Apache Software Foundation. All Rights Reserved.