Modifier and Type | Method and Description |
---|---|
Collection<ResourceProfile> |
MesosResourceManager.startNewWorker(ResourceProfile resourceProfile) |
Modifier and Type | Method and Description |
---|---|
Collection<ResourceProfile> |
MesosResourceManager.startNewWorker(ResourceProfile resourceProfile) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
MesosWorkerStore.Worker.profile()
Get the resource profile associated with the worker.
|
Modifier and Type | Method and Description |
---|---|
static MesosWorkerStore.Worker |
MesosWorkerStore.Worker.newWorker(org.apache.mesos.Protos.TaskID taskID,
ResourceProfile profile)
Create a new worker with the given taskID.
|
Modifier and Type | Field and Description |
---|---|
static ResourceProfile |
ResourceProfile.ANY
ResourceProfile which matches any other ResourceProfile.
|
static ResourceProfile |
ResourceProfile.UNKNOWN
A ResourceProfile that indicates an unknown set of resources.
|
static ResourceProfile |
ResourceProfile.ZERO
A ResourceProfile describing zero resources.
|
Modifier and Type | Method and Description |
---|---|
static ResourceProfile |
ResourceProfile.fromResourceSpec(ResourceSpec resourceSpec,
int networkMemory) |
ResourceProfile |
SlotProfile.getResourceProfile()
Returns the desired resource profile for the slot.
|
ResourceProfile |
ResourceProfile.merge(ResourceProfile other)
Calculates the sum of two resource profiles.
|
ResourceProfile |
ResourceProfile.subtract(ResourceProfile other)
Subtracts another piece of resource profile from this one.
|
Modifier and Type | Method and Description |
---|---|
int |
ResourceProfile.compareTo(ResourceProfile other) |
boolean |
ResourceProfile.isMatching(ResourceProfile required)
Check whether required resource profile can be matched.
|
ResourceProfile |
ResourceProfile.merge(ResourceProfile other)
Calculates the sum of two resource profiles.
|
static SlotProfile |
SlotProfile.noLocality(ResourceProfile resourceProfile)
Returns a slot profile for the given resource profile, without any locality requirements.
|
static SlotProfile |
SlotProfile.preferredLocality(ResourceProfile resourceProfile,
Collection<TaskManagerLocation> preferredLocations)
Returns a slot profile for the given resource profile and the preferred locations.
|
static SlotProfile |
SlotProfile.priorAllocation(ResourceProfile resourceProfile,
Collection<AllocationID> priorAllocations)
Returns a slot profile for the given resource profile and the prior allocations.
|
ResourceProfile |
ResourceProfile.subtract(ResourceProfile other)
Subtracts another piece of resource profile from this one.
|
Constructor and Description |
---|
ResourceProfile(ResourceProfile other)
Creates a copy of the given ResourceProfile.
|
SlotProfile(ResourceProfile resourceProfile,
Collection<TaskManagerLocation> preferredLocations,
Collection<AllocationID> preferredAllocations) |
SlotProfile(ResourceProfile resourceProfile,
Collection<TaskManagerLocation> preferredLocations,
Collection<AllocationID> preferredAllocations,
Set<AllocationID> previousExecutionGraphAllocations) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
ArchivedExecutionJobVertex.getResourceProfile() |
ResourceProfile |
ExecutionVertex.getResourceProfile() |
ResourceProfile |
AccessExecutionJobVertex.getResourceProfile()
Returns the resource profile for this job vertex.
|
ResourceProfile |
ExecutionJobVertex.getResourceProfile() |
Constructor and Description |
---|
ArchivedExecutionJobVertex(ArchivedExecutionVertex[] taskVertices,
JobVertexID id,
String name,
int parallelism,
int maxParallelism,
ResourceProfile resourceProfile,
StringifiedAccumulatorResult[] archivedUserAccumulators) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SimpleSlotContext.getResourceProfile() |
Constructor and Description |
---|
SimpleSlotContext(AllocationID allocationId,
TaskManagerLocation taskManagerLocation,
int physicalSlotNumber,
TaskManagerGateway taskManagerGateway,
ResourceProfile resourceProfile) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SlotInfo.getResourceProfile()
Returns the resource profile of the slot.
|
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SlotSelectionStrategy.SlotInfoAndResources.getRemainingResources() |
abstract ResourceProfile |
SlotSharingManager.TaskSlot.getReservedResources()
Gets the total reserved resources of the slot and its descendants.
|
ResourceProfile |
SlotSharingManager.MultiTaskSlot.getReservedResources() |
ResourceProfile |
SlotSharingManager.SingleTaskSlot.getReservedResources() |
ResourceProfile |
SlotInfoWithUtilization.getResourceProfile() |
ResourceProfile |
SlotPoolImpl.PendingRequest.getResourceProfile() |
Constructor and Description |
---|
SlotInfoAndResources(SlotInfo slotInfo,
ResourceProfile remainingResources,
double taskExecutorUtilization) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
SlotRequest.getResourceProfile()
Get the resource profile of the desired slot
|
Modifier and Type | Method and Description |
---|---|
static Collection<ResourceProfile> |
ResourceManager.createWorkerSlotProfiles(Configuration config) |
abstract Collection<ResourceProfile> |
ResourceManager.startNewWorker(ResourceProfile resourceProfile)
Allocates a resource using the resource profile.
|
Collection<ResourceProfile> |
StandaloneResourceManager.startNewWorker(ResourceProfile resourceProfile) |
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerServices.allocateResource(ResourceProfile resourceProfile)
Allocates a resource according to the resource profile.
|
abstract Collection<ResourceProfile> |
ResourceManager.startNewWorker(ResourceProfile resourceProfile)
Allocates a resource using the resource profile.
|
Collection<ResourceProfile> |
StandaloneResourceManager.startNewWorker(ResourceProfile resourceProfile) |
Constructor and Description |
---|
SlotRequest(JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress) |
Constructor and Description |
---|
UnfulfillableSlotRequestException(AllocationID allocationId,
ResourceProfile resourceProfile) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
TaskManagerSlotInformation.getResourceProfile()
Get resource profile of this slot.
|
ResourceProfile |
PendingTaskManagerSlot.getResourceProfile() |
ResourceProfile |
TaskManagerSlot.getResourceProfile() |
ResourceProfile |
PendingSlotRequest.getResourceProfile() |
Modifier and Type | Method and Description |
---|---|
Collection<ResourceProfile> |
ResourceActions.allocateResource(ResourceProfile resourceProfile)
Requests to allocate a resource with the given
ResourceProfile . |
Modifier and Type | Method and Description |
---|---|
Collection<ResourceProfile> |
ResourceActions.allocateResource(ResourceProfile resourceProfile)
Requests to allocate a resource with the given
ResourceProfile . |
<T extends TaskManagerSlotInformation> |
LeastUtilizationSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
<T extends TaskManagerSlotInformation> |
SlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup)
Finds a matching slot for the requested
ResourceProfile given the
collection of free slots and the total number of slots per TaskExecutor. |
<T extends TaskManagerSlotInformation> |
AnyMatchingSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
boolean |
TaskManagerSlotInformation.isMatchingRequirement(ResourceProfile required)
Returns true if the required
ResourceProfile can be fulfilled
by this slot. |
boolean |
TaskManagerSlot.isMatchingRequirement(ResourceProfile required)
Check whether required resource profile can be matched by this slot.
|
Constructor and Description |
---|
PendingTaskManagerSlot(ResourceProfile resourceProfile) |
TaskManagerSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection) |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
ExecutionVertexSchedulingRequirements.getResourceProfile() |
Modifier and Type | Method and Description |
---|---|
ExecutionVertexSchedulingRequirements.Builder |
ExecutionVertexSchedulingRequirements.Builder.withResourceProfile(ResourceProfile resourceProfile) |
Modifier and Type | Method and Description |
---|---|
static ResourceProfile |
TaskManagerServices.computeSlotResourceProfile(int numOfSlots,
long managedMemorySize) |
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 |
---|---|
Collection<ResourceProfile> |
YarnResourceManager.startNewWorker(ResourceProfile resourceProfile) |
Modifier and Type | Method and Description |
---|---|
Collection<ResourceProfile> |
YarnResourceManager.startNewWorker(ResourceProfile resourceProfile) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.