alluxio

Class Sessions

java.lang.Object

alluxio.Sessions

@ThreadSafe
public final class Sessions
extends Object

Sessions represents and manages all sessions contacting a worker.

Field Summary

Fields

Modifier and Type	Field and Description
static int	ACCESS_BLOCK_SESSION_ID
static int	ASYNC_CACHE_SESSION_ID
static int	CHECKPOINT_SESSION_ID
static int	DATASERVER_SESSION_ID
static long	INTERNAL_SESSION_ID_BASE
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.
void	sessionHeartbeat(long sessionId) Performs session heartbeat.

Methods inherited from class java.lang.Object

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

Field Detail

DATASERVER_SESSION_ID

public static final int DATASERVER_SESSION_ID

See Also:

Constant Field Values

CHECKPOINT_SESSION_ID

public static final int CHECKPOINT_SESSION_ID

See Also:

Constant Field Values

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

ACCESS_BLOCK_SESSION_ID

public static final int ACCESS_BLOCK_SESSION_ID

See Also:

Constant Field Values

ASYNC_CACHE_SESSION_ID

public static final int ASYNC_CACHE_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

sessionHeartbeat

public void sessionHeartbeat(long sessionId)

Performs session heartbeat.

Parameters:

sessionId - the id of the session

createInternalSessionId

public static long createInternalSessionId()

Returns:

a session id used internally in workers