本文整理了Java中org.apache.hadoop.yarn.server.resourcemanager.scheduler.QueueMetrics.setAvailableResourcesToUser方法的一些代码示例，展示了QueueMetrics.setAvailableResourcesToUser的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueueMetrics.setAvailableResourcesToUser方法的具体详情如下：
包路径：org.apache.hadoop.yarn.server.resourcemanager.scheduler.QueueMetrics
类名称：QueueMetrics
方法名：setAvailableResourcesToUser

QueueMetrics.setAvailableResourcesToUser介绍

[英]Set available resources. To be called by scheduler periodically as resources become available.
[中]设置可用资源。在资源可用时由调度程序定期调用。

代码示例

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

synchronized void releaseResource(Resource clusterResource, 
  FiCaSchedulerApp application, Resource resource, Set<String> nodeLabels) {
 super.releaseResource(clusterResource, resource, nodeLabels);
 
 // Update user metrics
 String userName = application.getUser();
 User user = getUser(userName);
 user.releaseContainer(resource, nodeLabels);
 metrics.setAvailableResourcesToUser(userName, application.getHeadroom());
  
 LOG.info(getQueueName() +
   " used=" + queueUsage.getUsed() + " numContainers=" + numContainers +
   " user=" + userName + " user-resources=" + user.getUsed());
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

synchronized void releaseResource(Resource clusterResource, 
  FiCaSchedulerApp application, Resource resource, Set<String> nodeLabels) {
 super.releaseResource(clusterResource, resource, nodeLabels);
 
 // Update user metrics
 String userName = application.getUser();
 User user = getUser(userName);
 user.releaseContainer(resource, nodeLabels);
 metrics.setAvailableResourcesToUser(userName, application.getHeadroom());
  
 LOG.info(getQueueName() +
   " used=" + queueUsage.getUsed() + " numContainers=" + numContainers +
   " user=" + userName + " user-resources=" + user.getUsed());
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

synchronized void allocateResource(Resource clusterResource,
  SchedulerApplicationAttempt application, Resource resource,
  Set<String> nodeLabels) {
 super.allocateResource(clusterResource, resource, nodeLabels);
 
 // Update user metrics
 String userName = application.getUser();
 User user = getUser(userName);
 user.assignContainer(resource, nodeLabels);
 // Note this is a bit unconventional since it gets the object and modifies
 // it here, rather then using set routine
 Resources.subtractFrom(application.getHeadroom(), resource); // headroom
 metrics.setAvailableResourcesToUser(userName, application.getHeadroom());
 
 if (LOG.isDebugEnabled()) {
  LOG.info(getQueueName() + 
    " user=" + userName + 
    " used=" + queueUsage.getUsed() + " numContainers=" + numContainers +
    " headroom = " + application.getHeadroom() +
    " user-resources=" + user.getUsed()
    );
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

synchronized void allocateResource(Resource clusterResource,
  SchedulerApplicationAttempt application, Resource resource,
  Set<String> nodeLabels) {
 super.allocateResource(clusterResource, resource, nodeLabels);
 
 // Update user metrics
 String userName = application.getUser();
 User user = getUser(userName);
 user.assignContainer(resource, nodeLabels);
 // Note this is a bit unconventional since it gets the object and modifies
 // it here, rather then using set routine
 Resources.subtractFrom(application.getHeadroom(), resource); // headroom
 metrics.setAvailableResourcesToUser(userName, application.getHeadroom());
 
 if (LOG.isDebugEnabled()) {
  LOG.info(getQueueName() + 
    " user=" + userName + 
    " used=" + queueUsage.getUsed() + " numContainers=" + numContainers +
    " headroom = " + application.getHeadroom() +
    " user-resources=" + user.getUsed()
    );
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

metrics.setAvailableResourcesToUser(user, headroom);

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager

metrics.setAvailableResourcesToUser(user, headroom);

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

metrics.setAvailableResourcesToQueue(RMNodeLabelsManager.NO_LABEL,
  Resources.createResource(100*GB, 100));
parentMetrics.setAvailableResourcesToUser(RMNodeLabelsManager.NO_LABEL,
  user, Resources.createResource(10*GB, 10));
metrics.setAvailableResourcesToUser(RMNodeLabelsManager.NO_LABEL,
  user, Resources.createResource(10*GB, 10));
metrics.incrPendingResources(RMNodeLabelsManager.NO_LABEL,

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

parentMetrics.setAvailableResourcesToUser(user, Resources.createResource(10*GB, 10));
metrics.setAvailableResourcesToUser(user, Resources.createResource(10*GB, 10));
metrics.incrPendingResources(user, 5, Resources.createResource(3*GB, 3));
checkResources(queueSource, 0, 0, 0, 0, 0, 100*GB, 100, 15*GB, 15, 5, 0, 0, 0);

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

metrics.setAvailableResourcesToUser(RMNodeLabelsManager.NO_LABEL,
  user, Resources.createResource(10*GB, 10));
metrics.incrPendingResources(RMNodeLabelsManager.NO_LABEL,

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

metrics.setAvailableResourcesToUser(user, Resources.createResource(10*GB, 10));
metrics.incrPendingResources(user, 5, Resources.createResource(3*GB, 3));