Modifier and Type | Field and Description |
---|---|
static Priority |
Priority.UNDEFINED |
Modifier and Type | Method and Description |
---|---|
abstract Priority |
ResourceRequest.getPriority()
Get the
Priority of the request. |
abstract Priority |
ApplicationSubmissionContext.getPriority()
Get the
Priority of the application. |
abstract Priority |
Container.getPriority()
Get the
Priority at which the Container was
allocated. |
static Priority |
Priority.newInstance(int p) |
Modifier and Type | Method and Description |
---|---|
int |
Priority.compareTo(Priority other) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource) |
static ApplicationSubmissionContext |
ApplicationSubmissionContext.newInstance(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType) |
static Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
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) |
abstract void |
ResourceRequest.setPriority(Priority priority)
Set the
Priority of the request |
abstract void |
ApplicationSubmissionContext.setPriority(Priority priority)
Set the
Priority of the application. |
abstract void |
Container.setPriority(Priority priority) |
Modifier and Type | Class and Description |
---|---|
class |
PriorityPBImpl |
Modifier and Type | Method and Description |
---|---|
Priority |
ContainerPBImpl.getPriority() |
Priority |
ApplicationSubmissionContextPBImpl.getPriority() |
Priority |
ResourceRequestPBImpl.getPriority() |
Modifier and Type | Method and Description |
---|---|
void |
ContainerPBImpl.setPriority(Priority priority) |
void |
ApplicationSubmissionContextPBImpl.setPriority(Priority priority) |
void |
ResourceRequestPBImpl.setPriority(Priority priority) |
Modifier and Type | Method and Description |
---|---|
Priority |
AMRMClient.ContainerRequest.getPriority() |
Modifier and Type | Method and Description |
---|---|
abstract List<? extends Collection<T>> |
AMRMClient.getMatchingRequests(Priority priority,
String resourceName,
Resource capability)
Get outstanding
ContainerRequest s matching the given
parameters. |
Constructor and Description |
---|
AMRMClient.ContainerRequest(Resource capability,
String[] nodes,
String[] racks,
Priority priority)
Instantiates a
AMRMClient.ContainerRequest with the given constraints and
locality relaxation enabled. |
AMRMClient.ContainerRequest(Resource capability,
String[] nodes,
String[] racks,
Priority priority,
boolean relaxLocality)
Instantiates a
AMRMClient.ContainerRequest with the given constraints. |
Modifier and Type | Method and Description |
---|---|
abstract List<? extends Collection<T>> |
AMRMClientAsync.getMatchingRequests(Priority priority,
String resourceName,
Resource capability) |
Modifier and Type | Method and Description |
---|---|
List<? extends Collection<T>> |
AMRMClientAsyncImpl.getMatchingRequests(Priority priority,
String resourceName,
Resource capability) |
Modifier and Type | Field and Description |
---|---|
protected Map<Priority,Map<String,TreeMap<Resource,org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl.ResourceRequestInfo>>> |
AMRMClientImpl.remoteRequestsTable |
Modifier and Type | Method and Description |
---|---|
List<? extends Collection<T>> |
AMRMClientImpl.getMatchingRequests(Priority priority,
String resourceName,
Resource capability) |
Modifier and Type | Method and Description |
---|---|
static Priority |
Priority.create(int prio) |
Modifier and Type | Method and Description |
---|---|
int |
Priority.Comparator.compare(Priority o1,
Priority o2) |
Modifier and Type | Field and Description |
---|---|
static Priority |
RMAppAttemptImpl.AM_CONTAINER_PRIORITY |
Modifier and Type | Method and Description |
---|---|
Priority |
RMContainerImpl.getReservedPriority() |
Priority |
RMContainer.getReservedPriority() |
Priority |
RMContainerReservedEvent.getReservedPriority() |
Constructor and Description |
---|
RMContainerReservedEvent(ContainerId containerId,
Resource reservedResource,
NodeId reservedNode,
Priority reservedPriority) |
Modifier and Type | Method and Description |
---|---|
Collection<Priority> |
AppSchedulingInfo.getPriorities() |
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.
|
Resource |
AppSchedulingInfo.getResource(Priority priority) |
ResourceRequest |
AppSchedulingInfo.getResourceRequest(Priority priority,
String resourceName) |
Map<String,ResourceRequest> |
AppSchedulingInfo.getResourceRequests(Priority priority) |
Modifier and Type | Method and Description |
---|---|
Collection<Priority> |
FiCaSchedulerApp.getPriorities() |
Modifier and Type | Method and Description |
---|---|
void |
FiCaSchedulerApp.addSchedulingOpportunity(Priority priority) |
RMContainer |
FiCaSchedulerApp.allocate(NodeType type,
FiCaSchedulerNode node,
Priority priority,
ResourceRequest request,
Container container) |
float |
FiCaSchedulerApp.getLocalityWaitFactor(Priority priority,
int clusterNodes) |
int |
FiCaSchedulerApp.getNumReservedContainers(Priority priority) |
int |
FiCaSchedulerApp.getReReservations(Priority priority) |
Resource |
FiCaSchedulerApp.getResource(Priority priority) |
ResourceRequest |
FiCaSchedulerApp.getResourceRequest(Priority priority,
String resourceName) |
Map<String,ResourceRequest> |
FiCaSchedulerApp.getResourceRequests(Priority priority) |
int |
FiCaSchedulerApp.getSchedulingOpportunities(Priority priority) |
int |
FiCaSchedulerApp.getTotalRequiredResources(Priority priority) |
boolean |
FiCaSchedulerApp.isReserved(FiCaSchedulerNode node,
Priority priority)
Has the application reserved the given
node at the
given priority ? |
RMContainer |
FiCaSchedulerApp.reserve(FiCaSchedulerNode node,
Priority priority,
RMContainer rmContainer,
Container container) |
void |
FiCaSchedulerNode.reserveResource(SchedulerApplication application,
Priority priority,
RMContainer reservedContainer) |
void |
FiCaSchedulerApp.resetSchedulingOpportunities(Priority priority) |
void |
FiCaSchedulerApp.subtractSchedulingOpportunity(Priority priority) |
boolean |
FiCaSchedulerApp.unreserve(FiCaSchedulerNode node,
Priority priority) |
Modifier and Type | Method and Description |
---|---|
Priority |
AppSchedulable.getPriority() |
Priority |
FSQueue.getPriority() |
abstract Priority |
Schedulable.getPriority()
Job priority for jobs in FIFO queues; meaningless for QueueSchedulables.
|
Modifier and Type | Method and Description |
---|---|
Collection<Priority> |
FSSchedulerApp.getPriorities() |
Modifier and Type | Method and Description |
---|---|
void |
FSSchedulerApp.addSchedulingOpportunity(Priority priority) |
RMContainer |
FSSchedulerApp.allocate(NodeType type,
FSSchedulerNode node,
Priority priority,
ResourceRequest request,
Container container) |
Container |
AppSchedulable.createContainer(FSSchedulerApp application,
FSSchedulerNode node,
Resource capability,
Priority priority)
Create and return a container object reflecting an allocation for the
given appliction on the given node with the given capability and
priority.
|
NodeType |
FSSchedulerApp.getAllowedLocalityLevel(Priority priority,
int numNodes,
double nodeLocalityThreshold,
double rackLocalityThreshold)
Return the level at which we are allowed to schedule containers, given the
current size of the cluster and thresholds indicating how many nodes to
fail at (as a fraction of cluster size) before relaxing scheduling
constraints.
|
float |
FSSchedulerApp.getLocalityWaitFactor(Priority priority,
int clusterNodes) |
int |
FSSchedulerApp.getNumReservedContainers(Priority priority) |
int |
FSSchedulerApp.getReReservations(Priority priority) |
Resource |
FSSchedulerApp.getResource(Priority priority) |
ResourceRequest |
FSSchedulerApp.getResourceRequest(Priority priority,
String nodeAddress) |
Map<String,ResourceRequest> |
FSSchedulerApp.getResourceRequests(Priority priority) |
int |
FSSchedulerApp.getSchedulingOpportunities(Priority priority)
Return the number of times the application has been given an opportunity
to schedule a task at the given priority since the last time it
successfully did so.
|
int |
FSSchedulerApp.getTotalRequiredResources(Priority priority) |
boolean |
AppSchedulable.hasContainerForNode(Priority prio,
FSSchedulerNode node)
Whether this app has containers requests that could be satisfied on the
given node, if the node had full space.
|
boolean |
FSSchedulerApp.isReserved(FSSchedulerNode node,
Priority priority)
Has the application reserved the given
node at the
given priority ? |
RMContainer |
FSSchedulerApp.reserve(FSSchedulerNode node,
Priority priority,
RMContainer rmContainer,
Container container) |
void |
FSSchedulerNode.reserveResource(FSSchedulerApp application,
Priority priority,
RMContainer reservedContainer) |
void |
FSSchedulerApp.resetAllowedLocalityLevel(Priority priority,
NodeType level)
Should be called when the scheduler assigns a container at a higher
degree of locality than the current threshold.
|
void |
FSSchedulerApp.resetSchedulingOpportunities(Priority priority)
Should be called when an application has successfully scheduled a container,
or when the scheduling locality threshold is relaxed.
|
void |
FSSchedulerApp.unreserve(FSSchedulerNode node,
Priority priority) |
void |
AppSchedulable.unreserve(Priority priority,
FSSchedulerNode node)
Remove the reservation on
node at the given
Priority . |
Modifier and Type | Method and Description |
---|---|
static Priority |
BuilderUtils.newPriority(int p) |
Modifier and Type | Method and Description |
---|---|
static ApplicationSubmissionContext |
BuilderUtils.newApplicationSubmissionContext(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource) |
static ApplicationSubmissionContext |
BuilderUtils.newApplicationSubmissionContext(ApplicationId applicationId,
String applicationName,
String queue,
Priority priority,
ContainerLaunchContext amContainer,
boolean isUnmanagedAM,
boolean cancelTokensWhenComplete,
int maxAppAttempts,
Resource resource,
String applicationType) |
static Container |
BuilderUtils.newContainer(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
static ResourceRequest |
BuilderUtils.newResourceRequest(Priority priority,
String hostName,
Resource capability,
int numContainers) |
Copyright © 2013 Apache Software Foundation. All rights reserved.