public class Users extends Object
Users
represents and manages all users contacting to a worker.Modifier and Type | Field and Description |
---|---|
static int |
CHECKPOINT_USER_ID |
static int |
DATASERVER_USER_ID |
static int |
MIGRATE_DATA_USER_ID |
Modifier and Type | Method and Description |
---|---|
List<Long> |
checkStatus()
Check the status of the users pool.
|
String |
getUserUfsTempFolder(long userId)
Returns the user's temporary data folder in the under filesystem.
|
void |
removeUser(long userId)
Remove
userId from user pool. |
void |
userHeartbeat(long userId)
Updates user's heartbeat.
|
public static final int DATASERVER_USER_ID
public static final int CHECKPOINT_USER_ID
public static final int MIGRATE_DATA_USER_ID
public Users(String userUfsFolder)
public List<Long> checkStatus()
public String getUserUfsTempFolder(long userId)
userId
- The queried user.public void removeUser(long userId)
userId
from user pool.userId
- The user to be removed.public void userHeartbeat(long userId)
userId
- the id of the userCopyright © 2015. All Rights Reserved.