org.apache.hadoop.yarn.client.api.async.impl
Class NMClientAsyncImpl
java.lang.Object
org.apache.hadoop.service.AbstractService
org.apache.hadoop.yarn.client.api.async.NMClientAsync
org.apache.hadoop.yarn.client.api.async.impl.NMClientAsyncImpl
- All Implemented Interfaces:
- Closeable, org.apache.hadoop.service.Service
@InterfaceAudience.Private
@InterfaceStability.Unstable
public class NMClientAsyncImpl
- extends NMClientAsync
Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service |
org.apache.hadoop.service.Service.STATE |
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 |
INITIAL_THREAD_POOL_SIZE
protected static final int INITIAL_THREAD_POOL_SIZE
- See Also:
- Constant Field Values
threadPool
protected ThreadPoolExecutor threadPool
maxThreadPoolSize
protected int maxThreadPoolSize
eventDispatcherThread
protected Thread eventDispatcherThread
stopped
protected AtomicBoolean stopped
events
protected BlockingQueue<NMClientAsyncImpl.ContainerEvent> events
containers
protected ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,NMClientAsyncImpl.StatefulContainer> containers
NMClientAsyncImpl
public NMClientAsyncImpl(NMClientAsync.CallbackHandler callbackHandler)
NMClientAsyncImpl
public NMClientAsyncImpl(String name,
NMClientAsync.CallbackHandler callbackHandler)
NMClientAsyncImpl
@InterfaceAudience.Private
protected NMClientAsyncImpl(String name,
NMClient client,
NMClientAsync.CallbackHandler callbackHandler)
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
startContainerAsync
public void startContainerAsync(org.apache.hadoop.yarn.api.records.Container container,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext containerLaunchContext)
- Specified by:
startContainerAsync
in class NMClientAsync
stopContainerAsync
public void stopContainerAsync(org.apache.hadoop.yarn.api.records.ContainerId containerId,
org.apache.hadoop.yarn.api.records.NodeId nodeId)
- Specified by:
stopContainerAsync
in class NMClientAsync
getContainerStatusAsync
public void getContainerStatusAsync(org.apache.hadoop.yarn.api.records.ContainerId containerId,
org.apache.hadoop.yarn.api.records.NodeId nodeId)
- Specified by:
getContainerStatusAsync
in class NMClientAsync
isCompletelyDone
protected boolean isCompletelyDone(NMClientAsyncImpl.StatefulContainer container)
getContainerEventProcessor
protected NMClientAsyncImpl.ContainerEventProcessor getContainerEventProcessor(NMClientAsyncImpl.ContainerEvent event)
Copyright © 2014 Apache Software Foundation. All Rights Reserved.