Modifier and Type | Method and Description |
---|---|
List<PrivilegedOperation> |
ResourceHandler.bootstrap(org.apache.hadoop.conf.Configuration configuration)
Bootstrap resource susbsystem.
|
List<PrivilegedOperation> |
ResourceHandlerChain.bootstrap(org.apache.hadoop.conf.Configuration configuration) |
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) |
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration conf) |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration conf) |
List<PrivilegedOperation> |
NetworkPacketTaggingHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration)
Bootstrapping network-tagging-handler - mounts net_cls
controller.
|
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
|
String |
CGroupsHandler.createCGroup(CGroupsHandler.CGroupController controller,
String cGroupId)
Creates a cgroup for a given controller.
|
void |
CGroupsHandler.deleteCGroup(CGroupsHandler.CGroupController controller,
String cGroupId)
Deletes the specified cgroup.
|
boolean |
CGroupsMountConfig.ensureMountPathIsDefined() |
Map<org.apache.hadoop.yarn.api.records.ContainerId,Integer> |
TrafficControlBandwidthHandlerImpl.getBytesSentPerContainer()
Returns total bytes sent per container to be used for metrics tracking
purposes.
|
String |
CGroupsHandler.getCGroupParam(CGroupsHandler.CGroupController controller,
String cGroupId,
String param)
reads a cgroup parameter value, given a controller, cgroup id, parameter.
|
static ResourceHandlerChain |
ResourceHandlerModule.getConfiguredResourceHandlerChain(org.apache.hadoop.conf.Configuration conf,
Context nmContext) |
static ResourceHandler |
ResourceHandlerModule.getNetworkTaggingHandler(org.apache.hadoop.conf.Configuration conf) |
static DiskResourceHandler |
ResourceHandlerModule.initDiskResourceHandler(org.apache.hadoop.conf.Configuration conf) |
void |
CGroupsHandler.initializeCGroupController(CGroupsHandler.CGroupController controller)
Mounts or initializes a cgroup controller.
|
static MemoryResourceHandler |
ResourceHandlerModule.initMemoryResourceHandler(org.apache.hadoop.conf.Configuration conf) |
static ResourceHandler |
ResourceHandlerModule.initNetworkResourceHandler(org.apache.hadoop.conf.Configuration conf) |
static OutboundBandwidthResourceHandler |
ResourceHandlerModule.initOutboundBandwidthResourceHandler(org.apache.hadoop.conf.Configuration conf) |
List<PrivilegedOperation> |
ResourceHandler.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId)
Perform any tasks necessary after container completion.
|
List<PrivilegedOperation> |
ResourceHandlerChain.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
NetworkPacketTaggingHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId)
Cleanup operation once container is completed - deletes cgroup.
|
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> |
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.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
Require state for container that was already launched
|
List<PrivilegedOperation> |
ResourceHandlerChain.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
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.
|
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> |
ResourceHandler.teardown()
Teardown environment for resource subsystem if requested.
|
List<PrivilegedOperation> |
ResourceHandlerChain.teardown() |
List<PrivilegedOperation> |
CGroupsBlkioResourceHandlerImpl.teardown() |
List<PrivilegedOperation> |
CGroupsMemoryResourceHandlerImpl.teardown() |
List<PrivilegedOperation> |
CGroupsCpuResourceHandlerImpl.teardown() |
List<PrivilegedOperation> |
NetworkPacketTaggingHandlerImpl.teardown() |
List<PrivilegedOperation> |
TrafficControlBandwidthHandlerImpl.teardown() |
void |
CGroupsHandler.updateCGroupParam(CGroupsHandler.CGroupController controller,
String cGroupId,
String param,
String value)
updates a cgroup parameter, given a controller, cgroup id, parameter name.
|
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 |
List<PrivilegedOperation> |
FpgaResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) |
List<PrivilegedOperation> |
FpgaResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
FpgaResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
FpgaResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
void |
FpgaResourceAllocator.recoverAssignedFpgas(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
FpgaResourceHandlerImpl.teardown() |
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.bootstrap(org.apache.hadoop.conf.Configuration configuration) |
List<PrivilegedOperation> |
GpuResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
GpuResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
GpuResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
void |
GpuResourceAllocator.recoverAssignedGpus(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
GpuResourceHandlerImpl.teardown() |
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.bootstrap(org.apache.hadoop.conf.Configuration configuration) |
List<PrivilegedOperation> |
NumaResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
NumaResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
NumaResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
NumaResourceHandlerImpl.teardown() |
List<PrivilegedOperation> |
NumaResourceHandlerImpl.updateContainer(Container container) |
Constructor and Description |
---|
NECVEPlugin() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.deviceframework.DeviceMappingManager.DeviceAllocation |
DeviceMappingManager.assignDevices(String resourceName,
Container container) |
List<PrivilegedOperation> |
DeviceResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) |
List<PrivilegedOperation> |
DeviceResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
DeviceResourceHandlerImpl.preStart(Container container) |
List<PrivilegedOperation> |
DeviceResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) |
void |
DeviceMappingManager.recoverAssignedDevices(String resourceName,
org.apache.hadoop.yarn.api.records.ContainerId containerId) |
List<PrivilegedOperation> |
DeviceResourceHandlerImpl.teardown() |
List<PrivilegedOperation> |
DeviceResourceHandlerImpl.updateContainer(Container container) |
Modifier and Type | Method and Description |
---|---|
List<FpgaDevice> |
FpgaDiscoverer.discover()
Get available devices minor numbers from toolchain or static configuration.
|
Modifier and Type | Method and Description |
---|---|
List<FpgaDevice> |
ScriptBasedFPGADiscoveryStrategy.discover() |
List<FpgaDevice> |
FPGADiscoveryStrategy.discover() |
List<FpgaDevice> |
AoclOutputBasedDiscoveryStrategy.discover() |
List<FpgaDevice> |
SettingsBasedFPGADiscoveryStrategy.discover() |
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.