org.apache.hive.hcatalog.templeton.tool

Class ZooKeeperCleanup

java.lang.Object

java.lang.Thread

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

All Implemented Interfaces:

Runnable

public class ZooKeeperCleanup
extends Thread

This does periodic cleanup

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.conf.Configuration	appConf
protected static long	interval
protected static long	maxage
static String	ZK_CLEANUP_INTERVAL
static String	ZK_CLEANUP_MAX_AGE

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Methods

Modifier and Type	Method and Description
boolean	checkAndDelete(String node, org.apache.curator.framework.CuratorFramework zk) Check to see if a job is more than maxage old, and delete it if so.
void	exit()
List<String>	getChildList(org.apache.curator.framework.CuratorFramework zk) Get the list of jobs from JobState
static ZooKeeperCleanup	getInstance(org.apache.hadoop.conf.Configuration appConf)
void	run() Run the cleanup loop.
static void	startInstance(org.apache.hadoop.conf.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 org.apache.hadoop.conf.Configuration appConf

ZK_CLEANUP_INTERVAL

public static final String ZK_CLEANUP_INTERVAL

See Also:

Constant Field Values

ZK_CLEANUP_MAX_AGE

public static final 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(org.apache.hadoop.conf.Configuration appConf)

startInstance

public static void startInstance(org.apache.hadoop.conf.Configuration appConf)
                          throws IOException

Throws:

IOException

run

public void run()

Run the cleanup loop.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

Throws:

IOException

getChildList

public List<String> getChildList(org.apache.curator.framework.CuratorFramework zk)

Get the list of jobs from JobState

Throws:

IOException

checkAndDelete

public boolean checkAndDelete(String node,
                     org.apache.curator.framework.CuratorFramework zk)

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

exit

public void exit()