public interface YarnScheduler extends EventHandler<SchedulerEvent>
Modifier and Type | Method and Description |
---|---|
Allocation |
allocate(ApplicationAttemptId appAttemptId,
List<ResourceRequest> ask,
List<ContainerId> release,
List<String> blacklistAdditions,
List<String> blacklistRemovals)
The main api between the ApplicationMaster and the Scheduler.
|
boolean |
checkAccess(UserGroupInformation callerUGI,
QueueACL acl,
String queueName)
Check if the user has permission to perform the operation.
|
Resource |
getMaximumResourceCapability()
Get maximum allocatable
Resource . |
Resource |
getMinimumResourceCapability()
Get minimum allocatable
Resource . |
SchedulerNodeReport |
getNodeReport(NodeId nodeId)
Get node resource usage report.
|
int |
getNumClusterNodes()
Get the number of nodes available in the cluster.
|
QueueInfo |
getQueueInfo(String queueName,
boolean includeChildQueues,
boolean recursive)
Get queue information
|
List<QueueUserACLInfo> |
getQueueUserAclInfo()
Get acls for queues for current user.
|
QueueMetrics |
getRootQueueMetrics()
Get the root queue for the scheduler.
|
SchedulerAppReport |
getSchedulerAppInfo(ApplicationAttemptId appAttemptId)
Get the Scheduler app for a given app attempt Id.
|
handle
@InterfaceAudience.Public @InterfaceStability.Stable QueueInfo getQueueInfo(String queueName, boolean includeChildQueues, boolean recursive) throws IOException
queueName
- queue nameincludeChildQueues
- include child queues?recursive
- get children queues?IOException
@InterfaceAudience.Public @InterfaceStability.Stable List<QueueUserACLInfo> getQueueUserAclInfo()
@InterfaceAudience.Public @InterfaceStability.Stable Resource getMinimumResourceCapability()
Resource
.@InterfaceAudience.Public @InterfaceStability.Stable Resource getMaximumResourceCapability()
Resource
.@InterfaceAudience.Public @InterfaceStability.Stable int getNumClusterNodes()
@InterfaceAudience.Public @InterfaceStability.Stable Allocation allocate(ApplicationAttemptId appAttemptId, List<ResourceRequest> ask, List<ContainerId> release, List<String> blacklistAdditions, List<String> blacklistRemovals)
appAttemptId
- ask
- release
- blacklistAdditions
- blacklistRemovals
- Allocation
for the application@InterfaceAudience.LimitedPrivate(value="yarn") @InterfaceStability.Stable SchedulerNodeReport getNodeReport(NodeId nodeId)
nodeId
- SchedulerNodeReport
for the node or null
if nodeId does not point to a defined node.@InterfaceAudience.LimitedPrivate(value="yarn") @InterfaceStability.Stable SchedulerAppReport getSchedulerAppInfo(ApplicationAttemptId appAttemptId)
appAttemptId
- the id of the application attempt@InterfaceAudience.LimitedPrivate(value="yarn") @InterfaceStability.Evolving QueueMetrics getRootQueueMetrics()
boolean checkAccess(UserGroupInformation callerUGI, QueueACL acl, String queueName)
QueueACL.ADMINISTER_QUEUE
permission,
this user can view/modify the applications in this queuecallerUGI
- acl
- queueName
- true
if the user has the permission,
false
otherwiseCopyright © 2013 Apache Software Foundation. All rights reserved.