org.apache.hive.service.server

Class ThreadWithGarbageCleanup

java.lang.Object

java.lang.Thread

org.apache.hive.service.server.ThreadWithGarbageCleanup

All Implemented Interfaces:

Runnable

public class ThreadWithGarbageCleanup
extends Thread

A HiveServer2 thread used to construct new server threads. In particular, this thread ensures an orderly cleanup, when killed by its corresponding ExecutorService.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ThreadWithGarbageCleanup(Runnable runnable)

Method Summary

Methods

Modifier and Type	Method and Description
void	cacheThreadLocalRawStore() Cache the ThreadLocal RawStore object.
void	finalize() Add any Thread specific garbage cleanup code here.

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, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadWithGarbageCleanup

public ThreadWithGarbageCleanup(Runnable runnable)

Method Detail

finalize

public void finalize()
              throws Throwable

Add any Thread specific garbage cleanup code here. Currently, it shuts down the RawStore object for this thread if it is not null.

Overrides:

finalize in class Object

Throws:

Throwable

cacheThreadLocalRawStore

public void cacheThreadLocalRawStore()

Cache the ThreadLocal RawStore object. Called from the corresponding thread.