org.apache.hadoop.yarn.server.resourcemanager.scheduler
Class ActiveUsersManager

java.lang.Object
  extended by org.apache.hadoop.yarn.server.resourcemanager.scheduler.ActiveUsersManager

@InterfaceAudience.Private
public class ActiveUsersManager
extends Object

ActiveUsersManager tracks active users in the system. A user is deemed to be active if he has any running applications with outstanding resource requests. An active user is defined as someone with outstanding resource requests.


Constructor Summary
ActiveUsersManager(QueueMetrics metrics)
           
 
Method Summary
 void activateApplication(String user, org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
          An application has new outstanding requests.
 void deactivateApplication(String user, org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
          An application has no more outstanding requests.
 int getNumActiveUsers()
          Get number of active users i.e.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ActiveUsersManager

public ActiveUsersManager(QueueMetrics metrics)
Method Detail

activateApplication

@Lock(value={Queue.class,SchedulerApplication.class})
public void activateApplication(String user,
                                                                          org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
An application has new outstanding requests.

Parameters:
user - application user
applicationId - activated application

deactivateApplication

@Lock(value={Queue.class,SchedulerApplication.class})
public void deactivateApplication(String user,
                                                                            org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
An application has no more outstanding requests.

Parameters:
user - application user
applicationId - deactivated application

getNumActiveUsers

@Lock(value={Queue.class,SchedulerApplication.class})
public int getNumActiveUsers()
Get number of active users i.e. users with applications which have pending resource requests.

Returns:
number of active users


Copyright © 2014 Apache Software Foundation. All Rights Reserved.