public abstract class RMCommunicator extends AbstractService implements RMHeartbeatHandler
Service.STATE
Modifier and Type | Field and Description |
---|---|
protected Thread |
allocatorThread |
protected Map<ApplicationAccessType,String> |
applicationACLs |
protected ApplicationId |
applicationId |
protected EventHandler |
eventHandler |
protected boolean |
isSignalled |
protected int |
lastResponseID |
protected ApplicationMasterProtocol |
scheduler |
Constructor and Description |
---|
RMCommunicator(ClientService clientService,
AppContext context) |
Modifier and Type | Method and Description |
---|---|
protected ApplicationMasterProtocol |
createSchedulerProxy() |
protected void |
doUnregistration() |
protected float |
getApplicationProgress()
Get the appProgress.
|
protected AppContext |
getContext() |
protected Job |
getJob() |
long |
getLastHeartbeatTime() |
protected Resource |
getMaxContainerCapability() |
protected abstract void |
heartbeat() |
protected void |
register() |
void |
runOnNextHeartbeat(Runnable callback) |
protected void |
serviceInit(Configuration conf)
All initialization code needed by a service.
|
protected void |
serviceStart()
Actions called during the INITED to STARTED transition.
|
protected void |
serviceStop()
Actions called during the transition to the STOPPED state.
|
void |
setShouldUnregister(boolean shouldUnregister) |
void |
setSignalled(boolean isSignalled) |
protected void |
startAllocatorThread() |
protected void |
unregister() |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
protected ApplicationId applicationId
protected Thread allocatorThread
protected EventHandler eventHandler
protected ApplicationMasterProtocol scheduler
protected int lastResponseID
protected Map<ApplicationAccessType,String> applicationACLs
protected volatile boolean isSignalled
public RMCommunicator(ClientService clientService, AppContext context)
protected void serviceInit(Configuration conf) throws Exception
AbstractService
AbstractService.init(Configuration)
prevents re-entrancy.
The base implementation checks to see if the subclass has created
a new configuration instance, and if so, updates the base class valueserviceInit
in class AbstractService
conf
- configurationException
- on a failure -these will be caught,
possibly wrapped, and wil; trigger a service stopprotected void serviceStart() throws Exception
AbstractService
AbstractService.start()
prevents re-entrancy.serviceStart
in class AbstractService
Exception
- if needed -these will be caught,
wrapped, and trigger a service stopprotected AppContext getContext()
protected Job getJob()
protected float getApplicationProgress()
protected void register()
protected void unregister()
protected void doUnregistration() throws YarnException, IOException, InterruptedException
protected Resource getMaxContainerCapability()
protected void serviceStop() throws Exception
AbstractService
AbstractService.stop()
prevents re-entrancy.
Implementations MUST write this to be robust against failures, including
checks for null references -and for the first failure to not stop other
attempts to shut down parts of the service.serviceStop
in class AbstractService
Exception
- if needed -these will be caught and logged.protected void startAllocatorThread()
protected ApplicationMasterProtocol createSchedulerProxy()
public long getLastHeartbeatTime()
getLastHeartbeatTime
in interface RMHeartbeatHandler
public void runOnNextHeartbeat(Runnable callback)
runOnNextHeartbeat
in interface RMHeartbeatHandler
public void setShouldUnregister(boolean shouldUnregister)
public void setSignalled(boolean isSignalled)
Copyright © 2013 Apache Software Foundation. All rights reserved.