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

QueueMetrics.activateApp介绍

暂无

代码示例

代码示例来源：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 activateApp(String user) {
 activeApplications.incr();
 QueueMetrics userMetrics = getUserMetrics(user);
 if (userMetrics != null) {
  userMetrics.activateApp(user);
 }
 if (parent != null) {
  parent.activateApp(user);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/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

/**
 * An application has new outstanding requests.
 * 
 * @param user application user 
 * @param applicationId activated application
 */
@Lock({Queue.class, SchedulerApplicationAttempt.class})
synchronized public void activateApplication(
  String user, ApplicationId applicationId) {
 Set<ApplicationId> userApps = usersApplications.get(user);
 if (userApps == null) {
  userApps = new HashSet<ApplicationId>();
  usersApplications.put(user, userApps);
  ++activeUsers;
  metrics.incrActiveUsers();
  LOG.debug("User " + user + " added to activeUsers, currently: " + 
    activeUsers);
 }
 if (userApps.add(applicationId)) {
  metrics.activateApp(user);
 }
}

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

/**
 * An application has new outstanding requests.
 * 
 * @param user application user 
 * @param applicationId activated application
 */
@Lock({Queue.class, SchedulerApplicationAttempt.class})
synchronized public void activateApplication(
  String user, ApplicationId applicationId) {
 Set<ApplicationId> userApps = usersApplications.get(user);
 if (userApps == null) {
  userApps = new HashSet<ApplicationId>();
  usersApplications.put(user, userApps);
  ++activeUsers;
  metrics.incrActiveUsers();
  LOG.debug("User " + user + " added to activeUsers, currently: " + 
    activeUsers);
 }
 if (userApps.add(applicationId)) {
  metrics.activateApp(user);
 }
}

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

/**
 * An application has new outstanding requests.
 * 
 * @param user application user 
 * @param applicationId activated application
 */
@Lock({Queue.class, SchedulerApplicationAttempt.class})
@Override
synchronized public void activateApplication(
  String user, ApplicationId applicationId) {
 Set<ApplicationId> userApps = usersApplications.get(user);
 if (userApps == null) {
  userApps = new HashSet<ApplicationId>();
  usersApplications.put(user, userApps);
  ++activeUsers;
  metrics.incrActiveUsers();
  if (LOG.isDebugEnabled()) {
   LOG.debug("User " + user + " added to activeUsers, currently: "
     + activeUsers);
  }
 }
 if (userApps.add(applicationId)) {
  metrics.activateApp(user);
 }
}

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

@Override
public void activateApplication(String user, ApplicationId applicationId) {
 try {
  this.writeLock.lock();
  User userDesc = getUser(user);
  if (userDesc != null && userDesc.getActiveApplications() <= 0) {
   return;
  }
  Set<ApplicationId> userApps = usersApplications.get(user);
  if (userApps == null) {
   userApps = new HashSet<ApplicationId>();
   usersApplications.put(user, userApps);
   activeUsers.incrementAndGet();
   metrics.incrActiveUsers();
   // A user is added to active list. Invalidate user-limit cache.
   userLimitNeedsRecompute();
   updateActiveUsersResourceUsage(user);
   if (LOG.isDebugEnabled()) {
    LOG.debug("User " + user + " added to activeUsers, currently: "
      + activeUsers);
   }
  }
  if (userApps.add(applicationId)) {
   metrics.activateApp(user);
  }
 } finally {
  this.writeLock.unlock();
 }
}