Package org.apache.hadoop.yarn.server.resourcemanager.scheduler

Class ActiveUsersManager

java.lang.Object

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

All Implemented Interfaces:

AbstractUsersManager

@Private
public class ActiveUsersManager
extends Object
implements AbstractUsersManager

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

Constructors

Constructor	Description
ActiveUsersManager(QueueMetrics metrics)

Method Summary

Modifier and Type	Method	Description
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. users with applications which have pending resource requests.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ActiveUsersManager

public ActiveUsersManager(QueueMetrics metrics)

Method Details

activateApplication

@Lock({Queue.class,SchedulerApplicationAttempt.class})
public void activateApplication(String user,
 org.apache.hadoop.yarn.api.records.ApplicationId applicationId)

An application has new outstanding requests.

Specified by:

activateApplication in interface AbstractUsersManager

Parameters:

user - application user

applicationId - activated application

deactivateApplication

@Lock({Queue.class,SchedulerApplicationAttempt.class})
public void deactivateApplication(String user,
 org.apache.hadoop.yarn.api.records.ApplicationId applicationId)

An application has no more outstanding requests.

Specified by:

deactivateApplication in interface AbstractUsersManager

Parameters:

user - application user

applicationId - deactivated application

getNumActiveUsers

@Lock({Queue.class,SchedulerApplicationAttempt.class})
public int getNumActiveUsers()

Get number of active users i.e. users with applications which have pending resource requests.

Specified by:

getNumActiveUsers in interface AbstractUsersManager

Returns:

number of active users