tachyon

Class Users

java.lang.Object

tachyon.Users

public class Users
extends Object

Users represents and manages all users contacting to a worker.

Field Summary

Fields

Modifier and Type	Field and Description
static int	CHECKPOINT_USER_ID
static int	DATASERVER_USER_ID
static int	MIGRATE_DATA_USER_ID

Constructor Summary

Constructors

Constructor and Description
Users(String userUfsFolder)

Method Summary

Methods

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.

Methods inherited from class java.lang.Object

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

Field Detail

DATASERVER_USER_ID

public static final int DATASERVER_USER_ID

See Also:

Constant Field Values

CHECKPOINT_USER_ID

public static final int CHECKPOINT_USER_ID

See Also:

Constant Field Values

MIGRATE_DATA_USER_ID

public static final int MIGRATE_DATA_USER_ID

See Also:

Constant Field Values

Constructor Detail

Users

public Users(String userUfsFolder)

Method Detail

checkStatus

public List<Long> checkStatus()

Check the status of the users pool.

Returns:

the list of timeout users.

getUserUfsTempFolder

public String getUserUfsTempFolder(long userId)

Returns the user's temporary data folder in the under filesystem.

Parameters:

userId - The queried user.

Returns:

String contains the user's temporary data folder in the under filesystem.

removeUser

public void removeUser(long userId)

Remove userId from user pool.

Parameters:

userId - The user to be removed.

userHeartbeat

public void userHeartbeat(long userId)

Updates user's heartbeat.

Parameters:

userId - the id of the user