public class ContainersLauncher extends org.apache.hadoop.service.AbstractService implements AbstractContainersLauncher
ResourceLocalizationService
is started as it depends on creation
of system directories on the local file-system.Modifier and Type | Field and Description |
---|---|
ExecutorService |
containerLauncher |
Map<org.apache.hadoop.yarn.api.records.ContainerId,ContainerLaunch> |
running |
Constructor and Description |
---|
ContainersLauncher() |
ContainersLauncher(Context context,
org.apache.hadoop.yarn.event.Dispatcher dispatcher,
ContainerExecutor exec,
LocalDirsHandlerService dirsHandler,
ContainerManagerImpl containerManager) |
Modifier and Type | Method and Description |
---|---|
void |
handle(ContainersLauncherEvent event) |
void |
init(Context nmContext,
org.apache.hadoop.yarn.event.Dispatcher nmDispatcher,
ContainerExecutor containerExec,
LocalDirsHandlerService nmDirsHandler,
ContainerManagerImpl nmContainerManager) |
protected void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
protected void |
serviceStop() |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceStart, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public ExecutorService containerLauncher
public final Map<org.apache.hadoop.yarn.api.records.ContainerId,ContainerLaunch> running
public ContainersLauncher()
public ContainersLauncher(Context context, org.apache.hadoop.yarn.event.Dispatcher dispatcher, ContainerExecutor exec, LocalDirsHandlerService dirsHandler, ContainerManagerImpl containerManager)
public void init(Context nmContext, org.apache.hadoop.yarn.event.Dispatcher nmDispatcher, ContainerExecutor containerExec, LocalDirsHandlerService nmDirsHandler, ContainerManagerImpl nmContainerManager)
init
in interface AbstractContainersLauncher
protected void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.AbstractService
Exception
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
public void handle(ContainersLauncherEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<ContainersLauncherEvent>
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.