org.apache.hadoop.mapreduce.v2.app.rm

Class RMContainerRequestor

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator

org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor

All Implemented Interfaces:

Closeable, AutoCloseable, RMHeartbeatHandler, Service

Direct Known Subclasses:

RMContainerAllocator

public abstract class RMContainerRequestor
extends RMCommunicator

Keeps the data structures to send container requests to RM.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

Service.STATE

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator

allocatorThread, applicationACLs, applicationId, eventHandler, isSignalled, scheduler

Constructor Summary

Constructors

Constructor and Description
RMContainerRequestor(ClientService clientService, AppContext context)

Method Summary

Methods

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.

Methods inherited from class org.apache.hadoop.mapreduce.v2.app.rm.RMCommunicator

createSchedulerProxy, doUnregistration, getApplicationProgress, getContext, getJob, getLastHeartbeatTime, getMaxContainerCapability, heartbeat, register, runOnNextHeartbeat, serviceStart, serviceStop, setShouldUnregister, setSignalled, startAllocatorThread, unregister

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

RMContainerRequestor

public RMContainerRequestor(ClientService clientService,
                    AppContext context)

Method Detail

serviceInit

protected void serviceInit(Configuration conf)
                    throws Exception

Description copied from class: AbstractService

All initialization code needed by a service. This method will only ever be called once during the lifecycle of a specific service instance. Implementations do not need to be synchronized as the logic in 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 value

Overrides:

serviceInit in class RMCommunicator

Parameters:

conf - configuration

Throws:

Exception - on a failure -these will be caught, possibly wrapped, and wil; trigger a service stop

makeRemoteRequest

protected AllocateResponse makeRemoteRequest()
                                      throws IOException

Throws:

IOException

computeIgnoreBlacklisting

protected void computeIgnoreBlacklisting()

containerFailedOnHost

protected void containerFailedOnHost(String hostName)

getAvailableResources

protected Resource getAvailableResources()

addContainerReq

protected void addContainerReq(org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest req)

decContainerReq

protected void decContainerReq(org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest req)

release

protected void release(ContainerId containerId)

isNodeBlacklisted

protected boolean isNodeBlacklisted(String hostname)

getFilteredContainerRequest

protected org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest getFilteredContainerRequest(org.apache.hadoop.mapreduce.v2.app.rm.RMContainerRequestor.ContainerRequest orig)

getBlacklistedNodes

public Set<String> getBlacklistedNodes()