Modifier and Type | Method and Description |
---|---|
static PrivilegedOperation |
PrivilegedOperationExecutor.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
|
Modifier and Type | Method and Description |
---|---|
String |
PrivilegedOperationExecutor.executePrivilegedOperation(List<String> prefixCommands,
PrivilegedOperation operation,
File workingDir,
Map<String,String> env,
boolean grabOutput,
boolean inheritParentEnv)
Executes a privileged operation.
|
String |
PrivilegedOperationExecutor.executePrivilegedOperation(PrivilegedOperation operation,
boolean grabOutput)
Executes a privileged operation.
|
String[] |
PrivilegedOperationExecutor.getPrivilegedOperationExecutionCommand(List<String> prefixCommands,
PrivilegedOperation operation) |
Modifier and Type | Method and Description |
---|---|
static PrivilegedOperation |
PrivilegedOperationExecutor.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
|
Modifier and Type | Method and Description |
---|---|
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) |
List<PrivilegedOperation> |
ResourceHandlerChain.bootstrap(org.apache.hadoop.conf.Configuration configuration) |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration conf) |
List<PrivilegedOperation> |
TrafficControlBandwidthHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration)
Bootstrapping 'outbound-bandwidth' resource handler - mounts net_cls
controller and bootstraps a traffic control bandwidth shaping hierarchy
|
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration conf) |
List<PrivilegedOperation> |
ResourceHandler.bootstrap(org.apache.hadoop.conf.Configuration configuration)
Bootstrap resource susbsystem.
|
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
ResourceHandlerChain.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
TrafficControlBandwidthHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId)
Cleanup operations once container is completed - deletes cgroup and
removes traffic shaping rule(s).
|
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
ResourceHandler.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId)
Perform any tasks necessary after container completion
|
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
|
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
ResourceHandlerChain.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
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 reacquired
|
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
ResourceHandler.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
Require state for container that was already launched
|
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.teardown() |
List<PrivilegedOperation> |
ResourceHandlerChain.teardown() |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.teardown() |
List<PrivilegedOperation> |
TrafficControlBandwidthHandlerImpl.teardown() |
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.teardown() |
List<PrivilegedOperation> |
ResourceHandler.teardown()
Teardown environment for resource subsystem if requested.
|
Copyright © 2018 Apache Software Foundation. All Rights Reserved.