Package | Description |
---|---|
org.apache.hadoop.yarn.server.nodemanager.api.deviceplugin |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.com.nec |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.com.nvidia |
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.webapp.dao |
Modifier and Type | Method and Description |
---|---|
Device |
Device.Builder.build() |
Modifier and Type | Method and Description |
---|---|
Set<Device> |
DevicePluginScheduler.allocateDevices(Set<Device> availableDevices,
int count,
Map<String,String> env)
Called when allocating devices.
|
Set<Device> |
DevicePlugin.getDevices()
Called when update node resource.
|
Modifier and Type | Method and Description |
---|---|
Set<Device> |
DevicePluginScheduler.allocateDevices(Set<Device> availableDevices,
int count,
Map<String,String> env)
Called when allocating devices.
|
DeviceRuntimeSpec |
DevicePlugin.onDevicesAllocated(Set<Device> allocatedDevices,
YarnRuntimeType yarnRuntime)
Asking how these devices should be prepared/used
before/when container launch.
|
void |
DevicePlugin.onDevicesReleased(Set<Device> releasedDevices)
Called after device released.
|
Modifier and Type | Method and Description |
---|---|
Set<Device> |
NECVEPlugin.allocateDevices(Set<Device> availableDevices,
int count,
Map<String,String> env) |
Set<Device> |
NECVEPlugin.getDevices() |
Modifier and Type | Method and Description |
---|---|
Set<Device> |
NECVEPlugin.allocateDevices(Set<Device> availableDevices,
int count,
Map<String,String> env) |
DeviceRuntimeSpec |
NECVEPlugin.onDevicesAllocated(Set<Device> set,
YarnRuntimeType yarnRuntimeType) |
void |
NECVEPlugin.onDevicesReleased(Set<Device> releasedDevices) |
Modifier and Type | Method and Description |
---|---|
Set<Device> |
NvidiaGPUPluginForRuntimeV2.allocateDevices(Set<Device> availableDevices,
int count,
Map<String,String> envs) |
Map<Integer,List<Map.Entry<Set<Device>,Integer>>> |
NvidiaGPUPluginForRuntimeV2.getCostTable() |
Set<Device> |
NvidiaGPUPluginForRuntimeV2.getDevices() |
Modifier and Type | Method and Description |
---|---|
int |
NvidiaGPUPluginForRuntimeV2.computeCostOfDevices(Device[] devices)
The cost function used to calculate costs of a sub set of devices.
|
Modifier and Type | Method and Description |
---|---|
Set<Device> |
NvidiaGPUPluginForRuntimeV2.allocateDevices(Set<Device> availableDevices,
int count,
Map<String,String> envs) |
void |
NvidiaGPUPluginForRuntimeV2.basicSchedule(Set<Device> allocation,
int count,
Set<Device> availableDevices) |
void |
NvidiaGPUPluginForRuntimeV2.basicSchedule(Set<Device> allocation,
int count,
Set<Device> availableDevices) |
DeviceRuntimeSpec |
NvidiaGPUPluginForRuntimeV2.onDevicesAllocated(Set<Device> allocatedDevices,
YarnRuntimeType yarnRuntime) |
void |
NvidiaGPUPluginForRuntimeV2.onDevicesReleased(Set<Device> releasedDevices) |
void |
NvidiaGPUPluginForRuntimeV2.topologyAwareSchedule(Set<Device> allocation,
int count,
Map<String,String> envs,
Set<Device> availableDevices,
Map<Integer,List<Map.Entry<Set<Device>,Integer>>> cTable)
Topology Aware schedule algorithm.
|
void |
NvidiaGPUPluginForRuntimeV2.topologyAwareSchedule(Set<Device> allocation,
int count,
Map<String,String> envs,
Set<Device> availableDevices,
Map<Integer,List<Map.Entry<Set<Device>,Integer>>> cTable)
Topology Aware schedule algorithm.
|
void |
NvidiaGPUPluginForRuntimeV2.topologyAwareSchedule(Set<Device> allocation,
int count,
Map<String,String> envs,
Set<Device> availableDevices,
Map<Integer,List<Map.Entry<Set<Device>,Integer>>> cTable)
Topology Aware schedule algorithm.
|
Modifier and Type | Method and Description |
---|---|
Device |
AssignedDevice.getDevice() |
Modifier and Type | Method and Description |
---|---|
Map<String,Set<Device>> |
DeviceMappingManager.getAllAllowedDevices() |
Set<Device> |
DeviceMappingManager.getAllocatedDevices(String resourceName,
org.apache.hadoop.yarn.api.records.ContainerId cId) |
Map<String,Map<Device,org.apache.hadoop.yarn.api.records.ContainerId>> |
DeviceMappingManager.getAllUsedDevices() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.deviceframework.DeviceResourceHandlerImpl.DeviceType |
DeviceResourceHandlerImpl.getDeviceType(Device device) |
Modifier and Type | Method and Description |
---|---|
void |
DeviceMappingManager.addDeviceSet(String resourceName,
Set<Device> deviceSet) |
Constructor and Description |
---|
AssignedDevice(org.apache.hadoop.yarn.api.records.ContainerId cId,
Device dev) |
Modifier and Type | Method and Description |
---|---|
List<Device> |
NMDeviceResourceInfo.getTotalDevices() |
Modifier and Type | Method and Description |
---|---|
void |
NMDeviceResourceInfo.setTotalDevices(List<Device> totalDevices) |
Constructor and Description |
---|
NMDeviceResourceInfo(List<Device> totalDevices,
List<AssignedDevice> assignedDevices) |
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.