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

QueueMetrics.decrActiveUsers介绍

暂无

代码示例

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

/**
 * An application has no more outstanding requests.
 * 
 * @param user application user 
 * @param applicationId deactivated application
 */
@Lock({Queue.class, SchedulerApplicationAttempt.class})
synchronized public void deactivateApplication(
  String user, ApplicationId applicationId) {
 Set<ApplicationId> userApps = usersApplications.get(user);
 if (userApps != null) {
  if (userApps.remove(applicationId)) {
   metrics.deactivateApp(user);
  }
  if (userApps.isEmpty()) {
   usersApplications.remove(user);
   --activeUsers;
   metrics.decrActiveUsers();
   LOG.debug("User " + user + " removed from activeUsers, currently: " + 
     activeUsers);
  }
 }
}

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

/**
 * An application has no more outstanding requests.
 * 
 * @param user application user 
 * @param applicationId deactivated application
 */
@Lock({Queue.class, SchedulerApplicationAttempt.class})
synchronized public void deactivateApplication(
  String user, ApplicationId applicationId) {
 Set<ApplicationId> userApps = usersApplications.get(user);
 if (userApps != null) {
  if (userApps.remove(applicationId)) {
   metrics.deactivateApp(user);
  }
  if (userApps.isEmpty()) {
   usersApplications.remove(user);
   --activeUsers;
   metrics.decrActiveUsers();
   LOG.debug("User " + user + " removed from activeUsers, currently: " + 
     activeUsers);
  }
 }
}

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

@Override
public void deactivateApplication(String user, ApplicationId applicationId) {
 try {
  this.writeLock.lock();
  Set<ApplicationId> userApps = usersApplications.get(user);
  if (userApps != null) {
   if (userApps.remove(applicationId)) {
    metrics.deactivateApp(user);
   }
   if (userApps.isEmpty()) {
    usersApplications.remove(user);
    activeUsers.decrementAndGet();
    metrics.decrActiveUsers();
    // A user is removed from active list. Invalidate user-limit cache.
    userLimitNeedsRecompute();
    updateNonActiveUsersResourceUsage(user);
    if (LOG.isDebugEnabled()) {
     LOG.debug("User " + user + " removed from activeUsers, currently: "
       + activeUsers);
    }
   }
  }
 } finally {
  this.writeLock.unlock();
 }
}

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

/**
 * An application has no more outstanding requests.
 * 
 * @param user application user 
 * @param applicationId deactivated application
 */
@Lock({Queue.class, SchedulerApplicationAttempt.class})
@Override
synchronized public void deactivateApplication(
  String user, ApplicationId applicationId) {
 Set<ApplicationId> userApps = usersApplications.get(user);
 if (userApps != null) {
  if (userApps.remove(applicationId)) {
   metrics.deactivateApp(user);
  }
  if (userApps.isEmpty()) {
   usersApplications.remove(user);
   --activeUsers;
   metrics.decrActiveUsers();
   if (LOG.isDebugEnabled()) {
    LOG.debug("User " + user + " removed from activeUsers, currently: "
      + activeUsers);
   }
  }
 }
}