@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 and Description |
---|
ActiveUsersManager(QueueMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
activateApplication(String user,
ApplicationId applicationId)
An application has new outstanding requests.
|
void |
deactivateApplication(String user,
ApplicationId applicationId)
An application has no more outstanding requests.
|
int |
getNumActiveUsers()
Get number of active users i.e.
|
public ActiveUsersManager(QueueMetrics metrics)
@Lock(value={Queue.class,SchedulerApplication.class}) public void activateApplication(String user, ApplicationId applicationId)
user
- application userapplicationId
- activated application@Lock(value={Queue.class,SchedulerApplication.class}) public void deactivateApplication(String user, ApplicationId applicationId)
user
- application userapplicationId
- deactivated application@Lock(value={Queue.class,SchedulerApplication.class}) public int getNumActiveUsers()
Copyright © 2013 Apache Software Foundation. All rights reserved.