org.apache.hadoop.hive.ql.stats

Class StatsUpdaterThread

java.lang.Object

java.lang.Thread

org.apache.hadoop.hive.ql.stats.StatsUpdaterThread

All Implemented Interfaces:

Runnable, org.apache.hadoop.conf.Configurable, MetaStoreThread

public class StatsUpdaterThread
extends Thread
implements MetaStoreThread

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	StatsUpdaterThread.WorkerRunnable

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	conf
protected AtomicBoolean	looped
static String	SKIP_STATS_AUTOUPDATE_PROPERTY
protected AtomicBoolean	stop
protected int	threadId

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
StatsUpdaterThread()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.conf.Configuration	getConf()
int	getQueueLength()
void	init(AtomicBoolean stop, AtomicBoolean looped) Initialize the thread.
void	run()
boolean	runOneWorkerIteration(SessionState ss, String user, HiveConf conf, boolean doWait)
void	setConf(org.apache.hadoop.conf.Configuration conf)
void	setThreadId(int threadId) Set the id for this thread.
void	waitForQueuedCommands()

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

Methods inherited from interface org.apache.hadoop.hive.metastore.MetaStoreThread

start

Field Detail

SKIP_STATS_AUTOUPDATE_PROPERTY

public static final String SKIP_STATS_AUTOUPDATE_PROPERTY

See Also:

Constant Field Values

conf

protected org.apache.hadoop.conf.Configuration conf

threadId

protected int threadId

stop

protected AtomicBoolean stop

looped

protected AtomicBoolean looped

Constructor Detail

StatsUpdaterThread

public StatsUpdaterThread()

Method Detail

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setThreadId

public void setThreadId(int threadId)

Description copied from interface: MetaStoreThread

Set the id for this thread.

Specified by:

setThreadId in interface MetaStoreThread

Parameters:

threadId - id of the thread

init

public void init(AtomicBoolean stop,
                 AtomicBoolean looped)
          throws org.apache.hadoop.hive.metastore.api.MetaException

Description copied from interface: MetaStoreThread

Initialize the thread. This must not be called until after Configurable.setConf(Configuration) and MetaStoreThread.setThreadId(int) have been called.

Specified by:

init in interface MetaStoreThread

Parameters:

stop - a flag to watch for when to stop. If this value is set to true, the thread will terminate the next time through its main loop.

looped - a flag that is set to true everytime a thread goes through it's main loop. This is purely for testing so that tests can assure themselves that the thread has run through it's loop once. The test can set this value to false. The thread should then assure that the loop has been gone completely through at least once.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

runOneWorkerIteration

public boolean runOneWorkerIteration(SessionState ss,
                                     String user,
                                     HiveConf conf,
                                     boolean doWait)
                              throws InterruptedException

Throws:

InterruptedException

waitForQueuedCommands

public void waitForQueuedCommands()
                           throws InterruptedException

Throws:

InterruptedException

getQueueLength

public int getQueueLength()