Modifier and Type | Method and Description |
---|---|
abstract List<ResourceRequest> |
AllocateRequest.getAskList()
Get the list of
ResourceRequest to update the
ResourceManager about the application's resource requirements. |
Modifier and Type | Method and Description |
---|---|
static AllocateRequest |
AllocateRequest.newInstance(int responseID,
float appProgress,
List<ResourceRequest> resourceAsk,
List<ContainerId> containersToBeReleased,
ResourceBlacklistRequest resourceBlacklistRequest) |
abstract void |
AllocateRequest.setAskList(List<ResourceRequest> resourceRequests)
Set list of
ResourceRequest to update the
ResourceManager about the application's resource requirements. |
Modifier and Type | Method and Description |
---|---|
List<ResourceRequest> |
AllocateRequestPBImpl.getAskList() |
Modifier and Type | Method and Description |
---|---|
void |
AllocateRequestPBImpl.setAskList(List<ResourceRequest> resourceRequests) |
Modifier and Type | Method and Description |
---|---|
abstract ResourceRequest |
PreemptionResourceRequest.getResourceRequest() |
static ResourceRequest |
ResourceRequest.newInstance(Priority priority,
String hostName,
Resource capability,
int numContainers) |
static ResourceRequest |
ResourceRequest.newInstance(Priority priority,
String hostName,
Resource capability,
int numContainers,
boolean relaxLocality) |
Modifier and Type | Method and Description |
---|---|
int |
ResourceRequest.ResourceRequestComparator.compare(ResourceRequest r1,
ResourceRequest r2) |
int |
ResourceRequest.compareTo(ResourceRequest other) |
static PreemptionResourceRequest |
PreemptionResourceRequest.newInstance(ResourceRequest req) |
abstract void |
PreemptionResourceRequest.setResourceRequest(ResourceRequest req) |
Modifier and Type | Class and Description |
---|---|
class |
ResourceRequestPBImpl |
Modifier and Type | Method and Description |
---|---|
ResourceRequest |
PreemptionResourceRequestPBImpl.getResourceRequest() |
Modifier and Type | Method and Description |
---|---|
void |
PreemptionResourceRequestPBImpl.setResourceRequest(ResourceRequest rr) |
Modifier and Type | Field and Description |
---|---|
protected Set<ResourceRequest> |
AMRMClientImpl.ask |
Modifier and Type | Method and Description |
---|---|
static void |
RMServerUtils.validateResourceRequests(List<ResourceRequest> ask,
Resource maximumResource)
Utility method to validate a list resource requests, by insuring that the
requested memory/vcore is non-negative and not greater than max
|
Modifier and Type | Method and Description |
---|---|
ResourceRequest |
AppSchedulingInfo.getResourceRequest(Priority priority,
String resourceName) |
Modifier and Type | Method and Description |
---|---|
List<ResourceRequest> |
AppSchedulingInfo.getAllResourceRequests() |
List<ResourceRequest> |
Allocation.getResourcePreemptions() |
Map<String,ResourceRequest> |
AppSchedulingInfo.getResourceRequests(Priority priority) |
Modifier and Type | Method and Description |
---|---|
void |
AppSchedulingInfo.allocate(NodeType type,
SchedulerNode node,
Priority priority,
ResourceRequest request,
Container container)
Resources have been allocated to this application by the resource
scheduler.
|
static void |
SchedulerUtils.normalizeRequest(ResourceRequest ask,
ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource minimumResource,
Resource maximumResource)
Utility method to normalize a resource request, by insuring that the
requested memory is a multiple of minMemory and is not zero.
|
static void |
SchedulerUtils.normalizeRequest(ResourceRequest ask,
ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource minimumResource,
Resource maximumResource,
Resource incrementResource)
Utility method to normalize a resource request, by insuring that the
requested memory is a multiple of minMemory and is not zero.
|
static void |
SchedulerUtils.validateResourceRequest(ResourceRequest resReq,
Resource maximumResource)
Utility method to validate a resource request, by insuring that the
requested memory/vcore is non-negative and not greater than max
|
Modifier and Type | Method and Description |
---|---|
Allocation |
YarnScheduler.allocate(ApplicationAttemptId appAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals)
The main api between the ApplicationMaster and the Scheduler.
|
static void |
SchedulerUtils.normalizeRequests(List<ResourceRequest> asks,
ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource minimumResource,
Resource maximumResource)
Utility method to normalize a list of resource requests, by insuring that
the memory for each request is a multiple of minMemory and is not zero.
|
static void |
SchedulerUtils.normalizeRequests(List<ResourceRequest> asks,
ResourceCalculator resourceCalculator,
Resource clusterResource,
Resource minimumResource,
Resource maximumResource,
Resource incrementResource)
Utility method to normalize a list of resource requests, by insuring that
the memory for each request is a multiple of minMemory and is not zero.
|
void |
AppSchedulingInfo.updateResourceRequests(List<ResourceRequest> requests)
The ApplicationMaster is updating resource requirements for the
application, by asking for more resources and releasing resources acquired
by the application.
|
Constructor and Description |
---|
Allocation(List<Container> containers,
Resource resourceLimit,
Set<ContainerId> strictContainers,
Set<ContainerId> fungibleContainers,
List<ResourceRequest> fungibleResources) |
Modifier and Type | Method and Description |
---|---|
Allocation |
CapacityScheduler.allocate(ApplicationAttemptId applicationAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals) |
Modifier and Type | Method and Description |
---|---|
ResourceRequest |
FiCaSchedulerApp.getResourceRequest(Priority priority,
String resourceName) |
Modifier and Type | Method and Description |
---|---|
Map<String,ResourceRequest> |
FiCaSchedulerApp.getResourceRequests(Priority priority) |
Modifier and Type | Method and Description |
---|---|
RMContainer |
FiCaSchedulerApp.allocate(NodeType type,
FiCaSchedulerNode node,
Priority priority,
ResourceRequest request,
Container container) |
Modifier and Type | Method and Description |
---|---|
void |
FiCaSchedulerApp.updateResourceRequests(List<ResourceRequest> requests) |
Modifier and Type | Method and Description |
---|---|
ResourceRequest |
FSSchedulerApp.getResourceRequest(Priority priority,
String nodeAddress) |
Modifier and Type | Method and Description |
---|---|
Map<String,ResourceRequest> |
FSSchedulerApp.getResourceRequests(Priority priority) |
Modifier and Type | Method and Description |
---|---|
RMContainer |
FSSchedulerApp.allocate(NodeType type,
FSSchedulerNode node,
Priority priority,
ResourceRequest request,
Container container) |
Modifier and Type | Method and Description |
---|---|
Allocation |
FairScheduler.allocate(ApplicationAttemptId appAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals) |
void |
FSSchedulerApp.updateResourceRequests(List<ResourceRequest> requests) |
Modifier and Type | Method and Description |
---|---|
Allocation |
FifoScheduler.allocate(ApplicationAttemptId applicationAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals) |
Modifier and Type | Method and Description |
---|---|
static ResourceRequest |
BuilderUtils.newResourceRequest(Priority priority,
String hostName,
Resource capability,
int numContainers) |
static ResourceRequest |
BuilderUtils.newResourceRequest(ResourceRequest r) |
Modifier and Type | Method and Description |
---|---|
static ResourceRequest |
BuilderUtils.newResourceRequest(ResourceRequest r) |
Copyright © 2013 Apache Software Foundation. All rights reserved.