public abstract class RMContainerRequestor extends RMCommunicator
Service.STATE
allocatorThread, applicationACLs, applicationId, eventHandler, isSignalled, scheduler
Constructor and Description |
---|
RMContainerRequestor(ClientService clientService,
AppContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
addContainerReq(org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest req) |
protected void |
computeIgnoreBlacklisting() |
protected void |
containerFailedOnHost(String hostName) |
protected void |
decContainerReq(org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest req) |
protected Resource |
getAvailableResources() |
Set<String> |
getBlacklistedNodes() |
protected org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest |
getFilteredContainerRequest(org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest orig) |
protected boolean |
isNodeBlacklisted(String hostname) |
protected AllocateResponse |
makeRemoteRequest() |
protected void |
release(ContainerId containerId) |
protected void |
serviceInit(Configuration conf)
All initialization code needed by a service.
|
createSchedulerProxy, doUnregistration, getApplicationProgress, getContext, getJob, getLastHeartbeatTime, getMaxContainerCapability, heartbeat, register, runOnNextHeartbeat, serviceStart, serviceStop, setShouldUnregister, setSignalled, startAllocatorThread, unregister
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public RMContainerRequestor(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 RMCommunicator
conf
- configurationException
- on a failure -these will be caught,
possibly wrapped, and wil; trigger a service stopprotected AllocateResponse makeRemoteRequest() throws IOException
IOException
protected void computeIgnoreBlacklisting()
protected void containerFailedOnHost(String hostName)
protected Resource getAvailableResources()
protected void addContainerReq(org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest req)
protected void decContainerReq(org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest req)
protected void release(ContainerId containerId)
protected boolean isNodeBlacklisted(String hostname)
protected org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest getFilteredContainerRequest(org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest orig)
Copyright © 2013 Apache Software Foundation. All rights reserved.