Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,Container> |
NodeManager.NMContext.containers |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,Container> |
NodeManager.NMContext.getContainers() |
ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,Container> |
Context.getContainers() |
Modifier and Type | Method and Description |
---|---|
String[] |
LinuxContainerExecutor.getIpAndHost(Container container) |
String[] |
ContainerExecutor.getIpAndHost(Container container) |
static String[] |
ContainerExecutor.getLocalIpAndHost(Container container) |
void |
ContainerExecutor.pauseContainer(Container container)
Pause the container.
|
void |
ContainerExecutor.resumeContainer(Container container)
Resume the container from pause state.
|
Constructor and Description |
---|
ContainerExecutor.DelayedProcessKiller(Container container,
String user,
String pid,
long delayMS,
ContainerExecutor.Signal signal,
ContainerExecutor containerExecutor)
Basic constructor.
|
Modifier and Type | Method and Description |
---|---|
Container |
AuxServicesEvent.getContainer() |
Modifier and Type | Method and Description |
---|---|
protected void |
ContainerManagerImpl.authorizeGetAndStopContainerRequest(org.apache.hadoop.yarn.api.records.ContainerId containerId,
Container container,
boolean stopRequest,
org.apache.hadoop.yarn.security.NMTokenIdentifier identifier) |
Constructor and Description |
---|
AuxServicesEvent(AuxServicesEventType eventType,
Container container) |
AuxServicesEvent(AuxServicesEventType eventType,
String user,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
String serviceId,
ByteBuffer serviceData,
Container container) |
Modifier and Type | Method and Description |
---|---|
Map<org.apache.hadoop.yarn.api.records.ContainerId,Container> |
Application.getContainers() |
Map<org.apache.hadoop.yarn.api.records.ContainerId,Container> |
ApplicationImpl.getContainers() |
Constructor and Description |
---|
ApplicationContainerInitEvent(Container container) |
Modifier and Type | Class and Description |
---|---|
class |
ContainerImpl |
Modifier and Type | Field and Description |
---|---|
protected Container |
ContainerLaunch.container |
Modifier and Type | Method and Description |
---|---|
Container |
ContainersLauncherEvent.getContainer() |
Constructor and Description |
---|
ContainerLaunch(Context context,
org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.yarn.event.Dispatcher dispatcher,
ContainerExecutor exec,
Application app,
Container container,
LocalDirsHandlerService dirsHandler,
ContainerManagerImpl containerManager) |
ContainerRelaunch(Context context,
org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.yarn.event.Dispatcher dispatcher,
ContainerExecutor exec,
Application app,
Container container,
LocalDirsHandlerService dirsHandler,
ContainerManagerImpl containerManager) |
ContainersLauncherEvent(Container container,
ContainersLauncherEventType eventType) |
RecoveredContainerLaunch(Context context,
org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.yarn.event.Dispatcher dispatcher,
ContainerExecutor exec,
Application app,
Container container,
LocalDirsHandlerService dirsHandler,
ContainerManagerImpl containerManager) |
RecoverPausedContainerLaunch(Context context,
org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.yarn.event.Dispatcher dispatcher,
ContainerExecutor exec,
Application app,
Container container,
LocalDirsHandlerService dirsHandler,
ContainerManagerImpl containerManager) |
SignalContainersLauncherEvent(Container container,
org.apache.hadoop.yarn.api.records.SignalContainerCommand command) |
Modifier and Type | Method and Description |
---|---|
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
ResourceHandlerChain.preStart(Container container) |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
TrafficControlBandwidthHandlerImpl.preStart(Container container)
Pre-start hook for 'outbound-bandwidth' resource.
|
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
ResourceHandler.preStart(Container container)
Prepare a resource environment for container launch
|
Modifier and Type | Method and Description |
---|---|
String[] |
DelegatingLinuxContainerRuntime.getIpAndHost(Container container) |
String[] |
DockerLinuxContainerRuntime.getIpAndHost(Container container) |
String[] |
DefaultLinuxContainerRuntime.getIpAndHost(Container container) |
Modifier and Type | Method and Description |
---|---|
Container |
ContainerLocalizationEvent.getContainer() |
Constructor and Description |
---|
ContainerLocalizationCleanupEvent(Container c,
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> rsrc)
Event requesting the cleanup of the rsrc.
|
ContainerLocalizationEvent(LocalizationEventType event,
Container c) |
ContainerLocalizationRequestEvent(Container c,
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> rsrc)
Event requesting the localization of the rsrc.
|
Modifier and Type | Method and Description |
---|---|
Container |
ContainerRuntimeContext.getContainer() |
Modifier and Type | Method and Description |
---|---|
String[] |
ContainerRuntime.getIpAndHost(Container container)
Return the host and ip of the container
|
Constructor and Description |
---|
ContainerRuntimeContext.Builder(Container container) |
Modifier and Type | Method and Description |
---|---|
Container |
ContainerSchedulerEvent.getContainer()
Get the container associated with the event.
|
Modifier and Type | Method and Description |
---|---|
void |
AllocationBasedResourceUtilizationTracker.addContainerResources(Container container)
Add Container's resources to the accumulated Utilization.
|
void |
ResourceUtilizationTracker.addContainerResources(Container container)
Add Container's resources to Node Utilization.
|
boolean |
AllocationBasedResourceUtilizationTracker.hasResourcesAvailable(Container container)
Check if NM has resources available currently to run the container.
|
boolean |
ResourceUtilizationTracker.hasResourcesAvailable(Container container)
Check if NM has resources available currently to run the container.
|
void |
ContainerScheduler.recoverActiveContainer(Container container,
NMStateStoreService.RecoveredContainerStatus rcs)
Populates auxiliary data structures used by the ContainerScheduler on
recovery.
|
protected void |
ContainerScheduler.scheduleContainer(Container container) |
void |
AllocationBasedResourceUtilizationTracker.subtractContainerResource(Container container)
Subtract Container's resources to the accumulated Utilization.
|
void |
ResourceUtilizationTracker.subtractContainerResource(Container container)
Subtract Container's resources to Node Utilization.
|
Constructor and Description |
---|
ContainerSchedulerEvent(Container container,
ContainerSchedulerEventType eventType)
Create instance of Event.
|
UpdateContainerSchedulerEvent(Container container,
org.apache.hadoop.yarn.security.ContainerTokenIdentifier origToken,
UpdateContainerTokenEvent event)
Create instance of Event.
|
Modifier and Type | Method and Description |
---|---|
Container |
ContainerSignalContext.getContainer() |
Container |
ContainerReacquisitionContext.getContainer() |
Container |
ContainerLivenessContext.getContainer() |
Container |
ContainerStartContext.getContainer() |
Modifier and Type | Method and Description |
---|---|
ContainerSignalContext.Builder |
ContainerSignalContext.Builder.setContainer(Container container) |
ContainerReacquisitionContext.Builder |
ContainerReacquisitionContext.Builder.setContainer(Container container) |
ContainerLivenessContext.Builder |
ContainerLivenessContext.Builder.setContainer(Container container) |
ContainerStartContext.Builder |
ContainerStartContext.Builder.setContainer(Container container) |
Modifier and Type | Method and Description |
---|---|
void |
NMTimelinePublisher.reportContainerResourceUsage(Container container,
Long pmemUsage,
Float cpuUsagePercentPerCore) |
Constructor and Description |
---|
ContainerInfo(Context nmContext,
Container container) |
ContainerInfo(Context nmContext,
Container container,
String requestUri,
String pathPrefix,
String remoteUser) |
Copyright © 2018 Apache Software Foundation. All Rights Reserved.