Uses of Class
org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.privileged.PrivilegedOperation
Packages that use PrivilegedOperation
Package
Description
Package org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.
Package containing classes related to Docker commands and common operations
used within the @{link DockerLinuxContainerRuntime}.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of PrivilegedOperation in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.privileged
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.privileged that return PrivilegedOperationModifier and TypeMethodDescriptionstatic PrivilegedOperationPrivilegedOperationExecutor.squashCGroupOperations(List<PrivilegedOperation> ops) Squash operations for cgroups - e.g mount, add pid to cgroup etc ., For now, we only implement squashing for 'add pid to cgroup' since this is the only optimization relevant to launching containersMethods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.privileged with parameters of type PrivilegedOperationModifier and TypeMethodDescriptionorg.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPairPrivilegedOperationExecutor.executePrivilegedInteractiveOperation(List<String> prefixCommands, PrivilegedOperation operation) PrivilegedOperationExecutor.executePrivilegedOperation(List<String> prefixCommands, PrivilegedOperation operation, File workingDir, Map<String, String> env, boolean grabOutput, boolean inheritParentEnv) Executes a privileged operation.PrivilegedOperationExecutor.executePrivilegedOperation(PrivilegedOperation operation, boolean grabOutput) Executes a privileged operation.String[]PrivilegedOperationExecutor.getPrivilegedOperationExecutionCommand(List<String> prefixCommands, PrivilegedOperation operation) Method parameters in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.privileged with type arguments of type PrivilegedOperationModifier and TypeMethodDescriptionstatic PrivilegedOperationPrivilegedOperationExecutor.squashCGroupOperations(List<PrivilegedOperation> ops) Squash operations for cgroups - e.g mount, add pid to cgroup etc ., For now, we only implement squashing for 'add pid to cgroup' since this is the only optimization relevant to launching containers -
Uses of PrivilegedOperation in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources that return types with arguments of type PrivilegedOperationModifier and TypeMethodDescriptionAbstractCGroupsCpuResourceHandler.bootstrap(org.apache.hadoop.conf.Configuration conf) AbstractCGroupsMemoryResourceHandler.bootstrap(org.apache.hadoop.conf.Configuration conf) CGroupsBlkioResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) CGroupsMemoryResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration conf) NetworkPacketTaggingHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) Bootstrapping network-tagging-handler - mounts net_cls controller.ResourceHandler.bootstrap(org.apache.hadoop.conf.Configuration configuration) Bootstrap resource susbsystem.ResourceHandlerChain.bootstrap(org.apache.hadoop.conf.Configuration configuration) TrafficControlBandwidthHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) Bootstrapping 'outbound-bandwidth' resource handler - mounts net_cls controller and bootstraps a traffic control bandwidth shaping hierarchyAbstractCGroupsCpuResourceHandler.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) AbstractCGroupsMemoryResourceHandler.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) CGroupsBlkioResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) NetworkPacketTaggingHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) Cleanup operation once container is completed - deletes cgroup.ResourceHandler.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) Perform any tasks necessary after container completion.ResourceHandlerChain.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) TrafficControlBandwidthHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) Cleanup operations once container is completed - deletes cgroup and removes traffic shaping rule(s).Pre-start hook for network-tagging-handler.Prepare a resource environment for container launchPre-start hook for 'outbound-bandwidth' resource.AbstractCGroupsCpuResourceHandler.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) AbstractCGroupsMemoryResourceHandler.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) CGroupsBlkioResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) NetworkPacketTaggingHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) Reacquires state for a container - reads the classid from the cgroup being used for the container being reacquired.ResourceHandler.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) Require state for container that was already launchedResourceHandlerChain.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) TrafficControlBandwidthHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) Reacquires state for a container - reads the classid from the cgroup being used for the container being reacquiredAbstractCGroupsCpuResourceHandler.teardown()AbstractCGroupsMemoryResourceHandler.teardown()CGroupsBlkioResourceHandlerImpl.teardown()NetworkPacketTaggingHandlerImpl.teardown()ResourceHandler.teardown()Teardown environment for resource subsystem if requested.ResourceHandlerChain.teardown()TrafficControlBandwidthHandlerImpl.teardown()AbstractCGroupsCpuResourceHandler.updateContainer(Container container) AbstractCGroupsMemoryResourceHandler.updateContainer(Container container) CGroupsBlkioResourceHandlerImpl.updateContainer(Container container) NetworkPacketTaggingHandlerImpl.updateContainer(Container container) ResourceHandler.updateContainer(Container container) Update state for container that was already launchedResourceHandlerChain.updateContainer(Container container) TrafficControlBandwidthHandlerImpl.updateContainer(Container container) -
Uses of PrivilegedOperation in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.fpga
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.fpga that return types with arguments of type PrivilegedOperationModifier and TypeMethodDescriptionFpgaResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) FpgaResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) FpgaResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) FpgaResourceHandlerImpl.teardown()FpgaResourceHandlerImpl.updateContainer(Container container) -
Uses of PrivilegedOperation in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.gpu
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.gpu that return types with arguments of type PrivilegedOperationModifier and TypeMethodDescriptionGpuResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) GpuResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) GpuResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) GpuResourceHandlerImpl.teardown()GpuResourceHandlerImpl.updateContainer(Container container) -
Uses of PrivilegedOperation in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.numa
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.numa that return types with arguments of type PrivilegedOperationModifier and TypeMethodDescriptionNumaResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) NumaResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) NumaResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) NumaResourceHandlerImpl.teardown()NumaResourceHandlerImpl.updateContainer(Container container) -
Uses of PrivilegedOperation in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.runtime.docker
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.runtime.docker that return PrivilegedOperationModifier and TypeMethodDescriptionDockerCommand.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.DockerInspectCommand.preparePrivilegedOperation(DockerCommand dockerCommand, String containerName, Map<String, String> env, Context nmContext) DockerRmCommand.preparePrivilegedOperation(DockerCommand dockerCommand, String containerName, Map<String, String> env, Context nmContext) -
Uses of PrivilegedOperation in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.deviceframework
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.deviceframework that return types with arguments of type PrivilegedOperationModifier and TypeMethodDescriptionDeviceResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) DeviceResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) DeviceResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) DeviceResourceHandlerImpl.teardown()DeviceResourceHandlerImpl.updateContainer(Container container)