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

QueueMetrics.getUserMetrics介绍

暂无

代码示例

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

/**
 * Set available resources. To be called by scheduler periodically as
 * resources become available.
 * @param user
 * @param limit resource limit
 */
public void setAvailableResourcesToUser(String user, Resource limit) {
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.setAvailableResourcesToQueue(limit);
 }
}

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

public void submitAppAttempt(String user) {
 appsPending.incr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.submitAppAttempt(user);
 }
 if (parent != null) {
  parent.submitAppAttempt(user);
 }
}

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

public void deactivateApp(String user) {
 activeApplications.decr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.deactivateApp(user);
 }
 if (parent != null) {
  parent.deactivateApp(user);
 }
}

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

public void deactivateApp(String user) {
 activeApplications.decr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.deactivateApp(user);
 }
 if (parent != null) {
  parent.deactivateApp(user);
 }
}

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

public void deactivateApp(String user) {
 activeApplications.decr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.deactivateApp(user);
 }
 if (parent != null) {
  parent.deactivateApp(user);
 }
}

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

public void submitApp(String user) {
 appsSubmitted.incr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.submitApp(user);
 }
 if (parent != null) {
  parent.submitApp(user);
 }
}

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

public void submitAppAttempt(String user) {
 appsPending.incr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.submitAppAttempt(user);
 }
 if (parent != null) {
  parent.submitAppAttempt(user);
 }
}

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

public void submitApp(String user) {
 appsSubmitted.incr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.submitApp(user);
 }
 if (parent != null) {
  parent.submitApp(user);
 }
}

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

public void submitAppAttempt(String user) {
 appsPending.incr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.submitAppAttempt(user);
 }
 if (parent != null) {
  parent.submitAppAttempt(user);
 }
}

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

public void decrPendingResources(String user, int containers, Resource res) {
 _decrPendingResources(containers, res);
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.decrPendingResources(user, containers, res);
 }
 if (parent != null) {
  parent.decrPendingResources(user, containers, res);
 }
}

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

public void submitApp(String user) {
 appsSubmitted.incr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.submitApp(user);
 }
 if (parent != null) {
  parent.submitApp(user);
 }
}

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

public void activateApp(String user) {
 activeApplications.incr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.activateApp(user);
 }
 if (parent != null) {
  parent.activateApp(user);
 }
}

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

public void decrPendingResources(String user, int containers, Resource res) {
 _decrPendingResources(containers, res);
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.decrPendingResources(user, containers, res);
 }
 if (parent != null) {
  parent.decrPendingResources(user, containers, res);
 }
}

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

public void activateApp(String user) {
 activeApplications.incr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.activateApp(user);
 }
 if (parent != null) {
  parent.activateApp(user);
 }
}

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

public void runAppAttempt(ApplicationId appId, String user) {
 runBuckets.add(appId, System.currentTimeMillis());
 appsRunning.incr();
 appsPending.decr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.runAppAttempt(appId, user);
 }
 if (parent != null) {
  parent.runAppAttempt(appId, user);
 }
}

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

public void runAppAttempt(ApplicationId appId, String user) {
 runBuckets.add(appId, System.currentTimeMillis());
 appsRunning.incr();
 appsPending.decr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.runAppAttempt(appId, user);
 }
 if (parent != null) {
  parent.runAppAttempt(appId, user);
 }
}

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

public void runAppAttempt(ApplicationId appId, String user) {
 runBuckets.add(appId, System.currentTimeMillis());
 appsRunning.incr();
 appsPending.decr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.runAppAttempt(appId, user);
 }
 if (parent != null) {
  parent.runAppAttempt(appId, user);
 }
}

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

public void reserveResource(String user, Resource res) {
 reservedContainers.incr();
 reservedMB.incr(res.getMemorySize());
 reservedVCores.incr(res.getVirtualCores());
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.reserveResource(user, res);
 }
 if (parent != null) {
  parent.reserveResource(user, res);
 }
}

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

public void unreserveResource(String user, Resource res) {
 reservedContainers.decr();
 reservedMB.decr(res.getMemorySize());
 reservedVCores.decr(res.getVirtualCores());
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.unreserveResource(user, res);
 }
 if (parent != null) {
  parent.unreserveResource(user, res);
 }
}

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

public void unreserveResource(String user, Resource res) {
 reservedContainers.decr();
 reservedMB.decr(res.getMemory());
 reservedVCores.decr(res.getVirtualCores());
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.unreserveResource(user, res);
 }
 if (parent != null) {
  parent.unreserveResource(user, res);
 }
}