org.apache.hadoop.yarn.server.resourcemanager
Class ResourceTrackerService

java.lang.Object
  extended by org.apache.hadoop.service.AbstractService
      extended by 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 Class Summary
 
Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service
org.apache.hadoop.service.Service.STATE
 
Constructor Summary
ResourceTrackerService(RMContext rmContext, NodesListManager nodesListManager, NMLivelinessMonitor nmLivelinessMonitor, RMContainerTokenSecretManager containerTokenSecretManager, NMTokenSecretManagerInRM nmTokenSecretManager)
           
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ResourceTrackerService

public ResourceTrackerService(RMContext rmContext,
                              NodesListManager nodesListManager,
                              NMLivelinessMonitor nmLivelinessMonitor,
                              RMContainerTokenSecretManager containerTokenSecretManager,
                              NMTokenSecretManagerInRM nmTokenSecretManager)
Method Detail

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.