org.apache.hive.hcatalog.templeton.tool

Class HDFSCleanup

java.lang.Object

java.lang.Thread

org.apache.hive.hcatalog.templeton.tool.HDFSCleanup

All Implemented Interfaces:

java.lang.Runnable

public class HDFSCleanup
extends java.lang.Thread

This does periodic cleanup

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	appConf
static java.lang.String	HDFS_CLEANUP_INTERVAL
static java.lang.String	HDFS_CLEANUP_MAX_AGE
protected static long	interval
protected static long	maxage

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method and Description
void	exit()
static HDFSCleanup	getInstance(Configuration appConf)
void	run() Run the cleanup loop.
static void	startInstance(Configuration appConf)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

appConf

protected Configuration appConf

HDFS_CLEANUP_INTERVAL

public static final java.lang.String HDFS_CLEANUP_INTERVAL

See Also:

Constant Field Values

HDFS_CLEANUP_MAX_AGE

public static final java.lang.String HDFS_CLEANUP_MAX_AGE

See Also:

Constant Field Values

interval

protected static long interval

maxage

protected static long maxage

Method Detail

getInstance

public static HDFSCleanup getInstance(Configuration appConf)

startInstance

public static void startInstance(Configuration appConf)
                          throws java.io.IOException

Throws:

java.io.IOException

run

public void run()

Run the cleanup loop.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

exit

public void exit()