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> |
Context.getContainers() |
ConcurrentMap<org.apache.hadoop.yarn.api.records.ContainerId,Container> |
NodeManager.NMContext.getContainers() |
Modifier and Type | Method and Description |
---|---|
void |
ContainerExecutor.cleanupBeforeRelaunch(Container container)
Perform any cleanup before the next launch of the container.
|
String |
LinuxContainerExecutor.getExposedPorts(Container container) |
String |
ContainerExecutor.getExposedPorts(Container container) |
String[] |
LinuxContainerExecutor.getIpAndHost(Container container) |
String[] |
ContainerExecutor.getIpAndHost(Container container) |
static String[] |
ContainerExecutor.getLocalIpAndHost(Container container) |
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> |
LinuxContainerExecutor.getLocalResources(Container container) |
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> |
ContainerExecutor.getLocalResources(Container container) |
void |
ContainerExecutor.pauseContainer(Container container)
Pause the container.
|
void |
ContainerExecutor.resumeContainer(Container container)
Resume the container from pause state.
|
Constructor and Description |
---|
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,
String remoteUser) |
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> |
ApplicationImpl.getContainers() |
Map<org.apache.hadoop.yarn.api.records.ContainerId,Container> |
Application.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 |
---|
ContainerCleanup(Context context,
org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.yarn.event.Dispatcher dispatcher,
ContainerExecutor exec,
Container container,
ContainerLaunch containerLaunch) |
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 |
---|---|
String |
NetworkTagMappingJsonManager.getNetworkTagHexID(Container container) |
String |
NetworkTagMappingManager.getNetworkTagHexID(Container container)
Get networkTagHexID for the given container.
|
List<PrivilegedOperation> |
ResourceHandler.preStart(Container container)
Prepare a resource environment for container launch
|
List<PrivilegedOperation> |
ResourceHandlerChain.preStart(Container container) |
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
NetworkPacketTaggingHandlerImpl.preStart(Container container)
Pre-start hook for network-tagging-handler.
|
List<PrivilegedOperation> |
TrafficControlBandwidthHandlerImpl.preStart(Container container)
Pre-start hook for 'outbound-bandwidth' resource.
|
List<PrivilegedOperation> |
ResourceHandler.updateContainer(Container container)
Update state for container that was already launched
|
List<PrivilegedOperation> |
ResourceHandlerChain.updateContainer(Container container) |
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.updateContainer(Container container) |
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.updateContainer(Container container) |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.updateContainer(Container container) |
List<PrivilegedOperation> |
NetworkPacketTaggingHandlerImpl.updateContainer(Container container) |
List<PrivilegedOperation> |
TrafficControlBandwidthHandlerImpl.updateContainer(Container container) |
Modifier and Type | Method and Description |
---|---|
FpgaResourceAllocator.FpgaAllocation |
FpgaResourceAllocator.assignFpga(String type,
long count,
Container container,
String ipidHash)
Assign
FpgaResourceAllocator.FpgaAllocation with preferred IPID, if no, with random FPGAs |
String |
FpgaResourceHandlerImpl.getRequestedIPID(Container container) |
List<PrivilegedOperation> |
FpgaResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
FpgaResourceHandlerImpl.updateContainer(Container container) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.gpu.GpuResourceAllocator.GpuAllocation |
GpuResourceAllocator.assignGpus(Container container)
Assign GPU to the specified container.
|
List<PrivilegedOperation> |
GpuResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
GpuResourceHandlerImpl.updateContainer(Container container) |
Modifier and Type | Method and Description |
---|---|
NumaResourceAllocation |
NumaResourceAllocator.allocateNumaNodes(Container container)
Allocates the available NUMA nodes for the requested containerId with
resource in a round robin fashion.
|
List<PrivilegedOperation> |
NumaResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
NumaResourceHandlerImpl.updateContainer(Container container) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
OCIContainerRuntime.allowHostPidNamespace(Container container)
Return whether the YARN container is allowed to run using the host's PID
namespace for the OCI-compliant container.
|
protected boolean |
OCIContainerRuntime.allowPrivilegedContainerExecution(Container container)
Return whether the YARN container is allowed to run in a privileged
OCI-compliant container.
|
String |
RuncContainerRuntime.getExposedPorts(Container container) |
String |
DelegatingLinuxContainerRuntime.getExposedPorts(Container container) |
String |
DockerLinuxContainerRuntime.getExposedPorts(Container container) |
String |
DefaultLinuxContainerRuntime.getExposedPorts(Container container) |
String[] |
RuncContainerRuntime.getIpAndHost(Container container) |
String[] |
DelegatingLinuxContainerRuntime.getIpAndHost(Container container) |
String[] |
DockerLinuxContainerRuntime.getIpAndHost(Container container) |
String[] |
DefaultLinuxContainerRuntime.getIpAndHost(Container container) |
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> |
RuncContainerRuntime.getLocalResources(Container container) |
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> |
DelegatingLinuxContainerRuntime.getLocalResources(Container container) |
default Map<String,org.apache.hadoop.yarn.api.records.LocalResource> |
LinuxContainerRuntime.getLocalResources(Container container) |
protected boolean |
OCIContainerRuntime.isContainerRequestedAsPrivileged(Container container)
This function only returns whether a privileged container was requested,
not whether the container was or will be launched as privileged.
|
String |
RuncContainerRuntime.writeCommandToFile(RuncContainerExecutorConfig runcContainerExecutorConfig,
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 |
---|---|
DockerVolumeCommand |
DockerCommandPlugin.getCleanupDockerVolumesCommand(Container container)
Cleanup volumes created for one docker container
|
DockerVolumeCommand |
DockerCommandPlugin.getCreateDockerVolumeCommand(Container container)
Create volume when needed.
|
void |
DockerCommandPlugin.updateDockerRunCommand(DockerRunCommand dockerRunCommand,
Container container)
Update docker run command
|
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.deviceframework.DeviceMappingManager.DeviceAllocation |
DeviceMappingManager.assignDevices(String resourceName,
Container container) |
DockerVolumeCommand |
DeviceResourceDockerRuntimePluginImpl.getCleanupDockerVolumesCommand(Container container) |
DockerVolumeCommand |
DeviceResourceDockerRuntimePluginImpl.getCreateDockerVolumeCommand(Container container) |
DeviceRuntimeSpec |
DeviceResourceDockerRuntimePluginImpl.getRuntimeSpec(Container container) |
List<PrivilegedOperation> |
DeviceResourceHandlerImpl.preStart(Container container) |
protected boolean |
DeviceResourceDockerRuntimePluginImpl.requestedDevice(String resName,
Container container) |
List<PrivilegedOperation> |
DeviceResourceHandlerImpl.updateContainer(Container container) |
void |
DeviceResourceDockerRuntimePluginImpl.updateDockerRunCommand(DockerRunCommand dockerRunCommand,
Container container) |
Modifier and Type | Method and Description |
---|---|
DockerVolumeCommand |
NvidiaDockerV1CommandPlugin.getCleanupDockerVolumesCommand(Container container) |
DockerVolumeCommand |
NvidiaDockerV2CommandPlugin.getCleanupDockerVolumesCommand(Container container) |
DockerVolumeCommand |
NvidiaDockerV1CommandPlugin.getCreateDockerVolumeCommand(Container container) |
DockerVolumeCommand |
NvidiaDockerV2CommandPlugin.getCreateDockerVolumeCommand(Container container) |
protected boolean |
NvidiaDockerV1CommandPlugin.requestsGpu(Container container) |
protected boolean |
NvidiaDockerV2CommandPlugin.requestsGpu(Container container) |
void |
NvidiaDockerV1CommandPlugin.updateDockerRunCommand(DockerRunCommand dockerRunCommand,
Container container) |
void |
NvidiaDockerV2CommandPlugin.updateDockerRunCommand(DockerRunCommand dockerRunCommand,
Container container) |
Modifier and Type | Method and Description |
---|---|
Container |
ContainerRuntimeContext.getContainer() |
Modifier and Type | Method and Description |
---|---|
String |
ContainerRuntime.getExposedPorts(Container container)
Return the exposed ports of the container.
|
String[] |
ContainerRuntime.getIpAndHost(Container container)
Return the host and ip of the container.
|
Constructor and Description |
---|
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 |
ResourceUtilizationTracker.addContainerResources(Container container)
Add Container's resources to Node Utilization.
|
void |
AllocationBasedResourceUtilizationTracker.addContainerResources(Container container)
Add Container's resources to the accumulated Utilization.
|
boolean |
ResourceUtilizationTracker.hasResourcesAvailable(Container container)
Check if NM has resources available currently to run the container.
|
boolean |
AllocationBasedResourceUtilizationTracker.hasResourcesAvailable(Container container)
Check if NM has resources available currently to run the container.
|
void |
ContainerScheduler.recoverActiveContainer(Container container,
NMStateStoreService.RecoveredContainerState rcs)
Populates auxiliary data structures used by the ContainerScheduler on
recovery.
|
protected void |
ContainerScheduler.scheduleContainer(Container container) |
void |
ResourceUtilizationTracker.subtractContainerResource(Container container)
Subtract Container's resources to Node Utilization.
|
void |
AllocationBasedResourceUtilizationTracker.subtractContainerResource(Container container)
Subtract Container's resources to the accumulated 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.
|
Constructor and Description |
---|
ContainerVolumePublisher(Container container,
String localMountRoot,
OCIContainerRuntime runtime) |
Modifier and Type | Method and Description |
---|---|
Container |
ContainerReacquisitionContext.getContainer() |
Container |
ContainerPrepareContext.getContainer() |
Container |
ContainerReapContext.getContainer()
Get the container set for the context.
|
Container |
ContainerSignalContext.getContainer() |
Container |
ContainerLivenessContext.getContainer() |
Container |
ContainerStartContext.getContainer() |
Container |
ContainerExecContext.getContainer() |
Modifier and Type | Method and Description |
---|---|
ContainerReacquisitionContext.Builder |
ContainerReacquisitionContext.Builder.setContainer(Container container) |
ContainerPrepareContext.Builder |
ContainerPrepareContext.Builder.setContainer(Container container) |
ContainerReapContext.Builder |
ContainerReapContext.Builder.setContainer(Container container)
Set the container within the context.
|
ContainerSignalContext.Builder |
ContainerSignalContext.Builder.setContainer(Container container) |
ContainerLivenessContext.Builder |
ContainerLivenessContext.Builder.setContainer(Container container) |
ContainerStartContext.Builder |
ContainerStartContext.Builder.setContainer(Container container) |
ContainerExecContext.Builder |
ContainerExecContext.Builder.setContainer(Container c) |
Modifier and Type | Method and Description |
---|---|
abstract void |
NMStateStoreService.storeAssignedResources(Container container,
String resourceType,
List<Serializable> assignedResources)
Store the assigned resources to a container.
|
void |
NMNullStateStoreService.storeAssignedResources(Container container,
String resourceType,
List<Serializable> assignedResources) |
void |
NMLeveldbStateStoreService.storeAssignedResources(Container container,
String resourceType,
List<Serializable> assignedResources) |
protected void |
NMStateStoreService.updateContainerResourceMapping(Container container,
String resourceType,
List<Serializable> assignedResources) |
Modifier and Type | Method and Description |
---|---|
void |
NMTimelinePublisher.reportContainerResourceUsage(Container container,
Long pmemUsage,
Float cpuUsagePercentPerCore) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ContainerShellWebSocket.checkAuthorization(org.eclipse.jetty.websocket.api.Session session,
Container container)
Check if user is authorized to access container.
|
Constructor and Description |
---|
ContainerInfo(Context nmContext,
Container container) |
ContainerInfo(Context nmContext,
Container container,
String requestUri,
String pathPrefix,
String remoteUser) |
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.