Package | Description |
---|---|
org.apache.hadoop.yarn.server.nodemanager | |
org.apache.hadoop.yarn.server.nodemanager.containermanager.container | |
org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.runtime | |
org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.runtime.docker |
Package containing classes related to Docker commands and common operations
used within the @{link DockerLinuxContainerRuntime}.
|
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.deviceframework |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.gpu |
Package for GPU support classes.
|
org.apache.hadoop.yarn.server.nodemanager.containermanager.runtime |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair |
LinuxContainerExecutor.execContainer(ContainerExecContext ctx)
Performs container exec.
|
abstract org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair |
ContainerExecutor.execContainer(ContainerExecContext ctx)
Perform interactive docker command into running container.
|
org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair |
DefaultContainerExecutor.execContainer(ContainerExecContext ctx) |
String |
LinuxContainerExecutor.getExposedPorts(Container container) |
String |
ContainerExecutor.getExposedPorts(Container container) |
String[] |
LinuxContainerExecutor.getIpAndHost(Container container) |
String[] |
ContainerExecutor.getIpAndHost(Container container) |
Modifier and Type | Method and Description |
---|---|
<T> T |
ContainerImpl.getContainerRuntimeData(Class<T> runtimeClass) |
<T> T |
Container.getContainerRuntimeData(Class<T> runtimeClazz) |
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.
|
protected RuncImageTagToManifestPlugin |
RuncContainerRuntime.chooseImageTagToManifestPlugin() |
protected RuncManifestToResourcesPlugin |
RuncContainerRuntime.chooseManifestToResourcesPlugin() |
org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair |
RuncContainerRuntime.execContainer(ContainerExecContext ctx) |
org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair |
DelegatingLinuxContainerRuntime.execContainer(ContainerExecContext ctx) |
org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair |
DockerLinuxContainerRuntime.execContainer(ContainerExecContext ctx)
Perform docker exec command into running container.
|
org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair |
DefaultLinuxContainerRuntime.execContainer(ContainerExecContext ctx) |
String |
DelegatingLinuxContainerRuntime.getExposedPorts(Container container) |
protected String[] |
OCIContainerRuntime.getGroupIdInfo(String userName) |
String[] |
DelegatingLinuxContainerRuntime.getIpAndHost(Container container) |
protected String |
OCIContainerRuntime.getUserIdInfo(String userName) |
void |
RuncContainerRuntime.initialize(org.apache.hadoop.conf.Configuration configuration,
Context nmCtx) |
void |
OCIContainerRuntime.initialize(org.apache.hadoop.conf.Configuration conf,
Context nmContext) |
void |
DelegatingLinuxContainerRuntime.initialize(org.apache.hadoop.conf.Configuration conf,
Context nmContext) |
void |
LinuxContainerRuntime.initialize(org.apache.hadoop.conf.Configuration conf,
Context nmContext)
Initialize the runtime.
|
void |
DockerLinuxContainerRuntime.initialize(org.apache.hadoop.conf.Configuration conf,
Context nmContext) |
void |
JavaSandboxLinuxContainerRuntime.initialize(org.apache.hadoop.conf.Configuration conf,
Context nmContext) |
void |
DefaultLinuxContainerRuntime.initialize(org.apache.hadoop.conf.Configuration conf,
Context nmContext) |
protected void |
OCIContainerRuntime.initiateCsiClients(org.apache.hadoop.conf.Configuration config)
Initiate CSI clients to talk to the CSI adaptors on this node and
cache the clients for easier fetch.
|
void |
RuncContainerRuntime.launchContainer(ContainerRuntimeContext ctx) |
void |
DelegatingLinuxContainerRuntime.launchContainer(ContainerRuntimeContext ctx) |
void |
DockerLinuxContainerRuntime.launchContainer(ContainerRuntimeContext ctx) |
void |
JavaSandboxLinuxContainerRuntime.launchContainer(ContainerRuntimeContext ctx) |
void |
DefaultLinuxContainerRuntime.launchContainer(ContainerRuntimeContext ctx) |
protected String |
OCIContainerRuntime.mountReadOnlyPath(String mount,
Map<org.apache.hadoop.fs.Path,List<String>> localizedResources) |
void |
OCIContainerRuntime.prepareContainer(ContainerRuntimeContext ctx) |
void |
DelegatingLinuxContainerRuntime.prepareContainer(ContainerRuntimeContext ctx) |
void |
JavaSandboxLinuxContainerRuntime.prepareContainer(ContainerRuntimeContext ctx)
Prior to environment from being written locally need to generate
policy file which limits container access to a small set of directories.
|
void |
DefaultLinuxContainerRuntime.prepareContainer(ContainerRuntimeContext ctx) |
void |
DockerLinuxContainerRuntime.pullImageFromRemote(String containerIdStr,
String imageName) |
void |
RuncContainerRuntime.reapContainer(ContainerRuntimeContext ctx) |
void |
DelegatingLinuxContainerRuntime.reapContainer(ContainerRuntimeContext ctx) |
void |
DockerLinuxContainerRuntime.reapContainer(ContainerRuntimeContext ctx)
Reap the docker container.
|
void |
DefaultLinuxContainerRuntime.reapContainer(ContainerRuntimeContext ctx) |
void |
RuncContainerRuntime.relaunchContainer(ContainerRuntimeContext ctx) |
void |
DelegatingLinuxContainerRuntime.relaunchContainer(ContainerRuntimeContext ctx) |
void |
DockerLinuxContainerRuntime.relaunchContainer(ContainerRuntimeContext ctx) |
void |
JavaSandboxLinuxContainerRuntime.relaunchContainer(ContainerRuntimeContext ctx) |
void |
DefaultLinuxContainerRuntime.relaunchContainer(ContainerRuntimeContext ctx) |
void |
RuncContainerRuntime.signalContainer(ContainerRuntimeContext ctx) |
void |
DelegatingLinuxContainerRuntime.signalContainer(ContainerRuntimeContext ctx) |
void |
DockerLinuxContainerRuntime.signalContainer(ContainerRuntimeContext ctx)
Signal the docker container.
|
void |
DefaultLinuxContainerRuntime.signalContainer(ContainerRuntimeContext ctx) |
protected void |
OCIContainerRuntime.validateContainerNetworkType(String network) |
protected void |
OCIContainerRuntime.validateContainerRuntimeType(String runtime) |
protected static void |
OCIContainerRuntime.validateHostname(String hostname) |
static void |
DockerLinuxContainerRuntime.validateImageName(String imageName) |
String |
RuncContainerRuntime.writeCommandToFile(RuncContainerExecutorConfig runcContainerExecutorConfig,
Container container) |
Modifier and Type | Method and Description |
---|---|
static String |
DockerCommandExecutor.executeDockerCommand(DockerCommand dockerCommand,
String containerId,
Map<String,String> env,
PrivilegedOperationExecutor privilegedOperationExecutor,
boolean disableFailureLogging,
Context nmContext)
Execute a docker command and return the output.
|
PrivilegedOperation |
DockerCommand.preparePrivilegedOperation(DockerCommand dockerCommand,
String containerName,
Map<String,String> env,
Context nmContext)
Prepare the privileged operation object that will be used to invoke
the container-executor.
|
String |
DockerClient.writeCommandToTempFile(DockerCommand cmd,
org.apache.hadoop.yarn.api.records.ContainerId containerId,
Context nmContext) |
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 |
---|---|
DockerVolumeCommand |
DeviceResourceDockerRuntimePluginImpl.getCleanupDockerVolumesCommand(Container container) |
DockerVolumeCommand |
DeviceResourceDockerRuntimePluginImpl.getCreateDockerVolumeCommand(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) |
void |
NvidiaDockerV1CommandPlugin.updateDockerRunCommand(DockerRunCommand dockerRunCommand,
Container container) |
void |
NvidiaDockerV2CommandPlugin.updateDockerRunCommand(DockerRunCommand dockerRunCommand,
Container container) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair |
ContainerRuntime.execContainer(ContainerExecContext ctx)
Run a program in container.
|
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.
|
void |
ContainerRuntime.launchContainer(ContainerRuntimeContext ctx)
Launch a container.
|
void |
ContainerRuntime.prepareContainer(ContainerRuntimeContext ctx)
Prepare a container to be ready for launch.
|
void |
ContainerRuntime.reapContainer(ContainerRuntimeContext ctx)
Perform any container cleanup that may be required.
|
void |
ContainerRuntime.relaunchContainer(ContainerRuntimeContext ctx)
Relaunch a container.
|
void |
ContainerRuntime.signalContainer(ContainerRuntimeContext ctx)
Signal a container.
|
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.