public class ContainerLauncherImpl extends AbstractService implements ContainerLauncher
ContainerLauncher.EventType
Service.STATE
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<ContainerLauncherEvent> |
eventQueue |
protected static int |
INITIAL_POOL_SIZE |
protected ThreadPoolExecutor |
launcherPool |
Constructor and Description |
---|
ContainerLauncherImpl(AppContext context) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl.EventProcessor |
createEventProcessor(ContainerLauncherEvent event) |
ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData |
getCMProxy(String containerMgrBindAddr,
ContainerId containerId) |
void |
handle(ContainerLauncherEvent event) |
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.
|
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
protected ThreadPoolExecutor launcherPool
protected static final int INITIAL_POOL_SIZE
protected BlockingQueue<ContainerLauncherEvent> eventQueue
public ContainerLauncherImpl(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 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 org.apache.hadoop.mapreduce.v2.app.launcher.ContainerLauncherImpl.EventProcessor createEventProcessor(ContainerLauncherEvent event)
public void handle(ContainerLauncherEvent event)
handle
in interface EventHandler<ContainerLauncherEvent>
public ContainerManagementProtocolProxy.ContainerManagementProtocolProxyData getCMProxy(String containerMgrBindAddr, ContainerId containerId) throws IOException
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.