org.apache.hive.hcatalog.templeton.tool

Class ZooKeeperCleanup

java.lang.Object

java.lang.Thread

org.apache.hive.hcatalog.templeton.tool.ZooKeeperCleanup

All Implemented Interfaces:

java.lang.Runnable

public class ZooKeeperCleanup
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
protected static long	interval
protected static long	maxage
static java.lang.String	ZK_CLEANUP_INTERVAL
static java.lang.String	ZK_CLEANUP_MAX_AGE

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method and Description
boolean	checkAndDelete(java.lang.String node, org.apache.zookeeper.ZooKeeper zk) Check to see if a job is more than maxage old, and delete it if so.
void	exit()
java.util.List<java.lang.String>	getChildList(org.apache.zookeeper.ZooKeeper zk) Get the list of jobs from JobState
static ZooKeeperCleanup	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

ZK_CLEANUP_INTERVAL

public static final java.lang.String ZK_CLEANUP_INTERVAL

See Also:

Constant Field Values

ZK_CLEANUP_MAX_AGE

public static final java.lang.String ZK_CLEANUP_MAX_AGE

See Also:

Constant Field Values

interval

protected static long interval

maxage

protected static long maxage

Method Detail

getInstance

public static ZooKeeperCleanup 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

Throws:

java.io.IOException

getChildList

public java.util.List<java.lang.String> getChildList(org.apache.zookeeper.ZooKeeper zk)

Get the list of jobs from JobState

Throws:

java.io.IOException

checkAndDelete

public boolean checkAndDelete(java.lang.String node,
                              org.apache.zookeeper.ZooKeeper zk)

Check to see if a job is more than maxage old, and delete it if so.

exit

public void exit()