alluxio.worker

Class SessionCleaner

java.lang.Object

alluxio.worker.SessionCleaner

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

@NotThreadSafe
public final class SessionCleaner
extends Object
implements Runnable, Closeable

SessionCleaner periodically checks if any session have become zombies, removes the zombie session and associated data when necessary. The syncing parameters (intervals) adopt directly from worker-to-master heartbeat configurations.

Constructor Summary

Constructors

Constructor and Description
SessionCleaner(Sessions sessions, SessionCleanable... sessionCleanable) Creates a new instance of SessionCleaner.

Method Summary

Modifier and Type	Method and Description
void	close() Stops the checking, once this method is called, the object should be discarded.
void	run() Main loop for the cleanup, continuously looks for zombie sessions.

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionCleaner

public SessionCleaner(Sessions sessions,
                      SessionCleanable... sessionCleanable)

Creates a new instance of SessionCleaner.

Parameters:

sessions - the worker's sessions will be clean up by callback if which has been timeout

sessionCleanable - who wants to cleanup the session

Method Detail

run

public void run()

Main loop for the cleanup, continuously looks for zombie sessions.

Specified by:

run in interface Runnable

close

public void close()

Stops the checking, once this method is called, the object should be discarded.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable