Modifier and Type | Field and Description |
---|---|
static ResourceProfile |
ResourceProfile.UNKNOWN |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
TaskManagerSlot.getResourceProfile() |
Modifier and Type | Method and Description |
---|---|
int |
ResourceProfile.compareTo(ResourceProfile other) |
boolean |
ResourceProfile.isMatching(ResourceProfile required)
Check whether required resource profile can be matched
|
boolean |
TaskManagerSlot.isMatchingRequirement(ResourceProfile required)
Check whether required resource profile can be matched by this slot.
|
Constructor and Description |
---|
ResourceProfile(ResourceProfile other)
Creates a copy of the given ResourceProfile.
|
TaskManagerSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection,
AllocationID allocationId) |
Modifier and Type | Method and Description |
---|---|
Future<SimpleSlot> |
SlotPool.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences) |
Future<SimpleSlot> |
SlotPoolGateway.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
AllocatedSlot.getResourceProfile()
Gets the resource profile of the slot.
|
Constructor and Description |
---|
AllocatedSlot(AllocationID slotAllocationId,
JobID jobID,
TaskManagerLocation location,
int slotNumber,
ResourceProfile resourceProfile,
TaskManagerGateway taskManagerGateway) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SlotRequest.getResourceProfile()
Get the resource profile of the desired slot
|
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerServices.allocateResource(ResourceProfile resourceProfile)
Allocates a resource according to the resource profile.
|
void |
StandaloneResourceManager.startNewWorker(ResourceProfile resourceProfile) |
abstract void |
ResourceManager.startNewWorker(ResourceProfile resourceProfile)
Allocates a resource using the resource profile.
|
Constructor and Description |
---|
SlotRequest(JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
PendingSlotRequest.getResourceProfile() |
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerActions.allocateResource(ResourceProfile resourceProfile) |
protected PendingSlotRequest |
SlotManager.findMatchingRequest(ResourceProfile slotResourceProfile)
Finds a matching slot request for a given resource profile.
|
protected TaskManagerSlot |
SlotManager.findMatchingSlot(ResourceProfile requestResourceProfile)
Finds a matching slot for a given resource profile.
|
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SlotStatus.getResourceProfile()
Get the resource profile of this slot
|
Constructor and Description |
---|
SlotStatus(SlotID slotID,
ResourceProfile resourceProfile) |
SlotStatus(SlotID slotID,
ResourceProfile resourceProfile,
JobID jobID,
AllocationID allocationID) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
TaskSlot.getResourceProfile() |
ResourceProfile |
SlotOffer.getResourceProfile() |
Constructor and Description |
---|
SlotOffer(AllocationID allocationID,
int index,
ResourceProfile resourceProfile) |
Constructor and Description |
---|
TaskSlotTable(Collection<ResourceProfile> resourceProfiles,
TimerService<AllocationID> timerService) |
Modifier and Type | Method and Description |
---|---|
void |
YarnResourceManager.startNewWorker(ResourceProfile resourceProfile) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.