alluxio

Class Sessions

java.lang.Object

alluxio.Sessions

@ThreadSafe
public class Sessions
extends Object

Sessions represents and manages all sessions contacting a worker.

Field Summary

Fields

Modifier and Type	Field and Description
static int	CACHE_UFS_SESSION_ID
static int	CACHE_WORKER_SESSION_ID
static long	INTERNAL_SESSION_ID_BASE
static int	LOAD_SESSION_ID
static int	MASTER_COMMAND_SESSION_ID
static int	MIGRATE_DATA_SESSION_ID

Constructor Summary

Constructors

Constructor and Description
Sessions() Creates a new instance of Sessions.

Method Summary

Modifier and Type	Method and Description
static long	createInternalSessionId()
List<Long>	getTimedOutSessions() Gets the sessions that timed out.
void	removeSession(long sessionId) Removes the given session from the session pool.

Methods inherited from class java.lang.Object

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

Field Detail

MIGRATE_DATA_SESSION_ID

public static final int MIGRATE_DATA_SESSION_ID

See Also:

Constant Field Values

MASTER_COMMAND_SESSION_ID

public static final int MASTER_COMMAND_SESSION_ID

See Also:

Constant Field Values

CACHE_WORKER_SESSION_ID

public static final int CACHE_WORKER_SESSION_ID

See Also:

Constant Field Values

CACHE_UFS_SESSION_ID

public static final int CACHE_UFS_SESSION_ID

See Also:

Constant Field Values

LOAD_SESSION_ID

public static final int LOAD_SESSION_ID

See Also:

Constant Field Values

INTERNAL_SESSION_ID_BASE

public static final long INTERNAL_SESSION_ID_BASE

See Also:

Constant Field Values

Constructor Detail

Sessions

public Sessions()

Creates a new instance of Sessions.

Method Detail

getTimedOutSessions

public List<Long> getTimedOutSessions()

Gets the sessions that timed out.

Returns:

the list of session ids of sessions that timed out

removeSession

public void removeSession(long sessionId)

Removes the given session from the session pool.

Parameters:

sessionId - the id of the session to be removed

createInternalSessionId

public static long createInternalSessionId()

Returns:

a session id used internally in workers