public class Cleaner extends MetaStoreCompactorThread
Thread.State, Thread.UncaughtExceptionHandler
cycleUpdaterExecutorService, txnHandler
conf, hostName, runtimeVersion, stop
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
Cleaner() |
Modifier and Type | Method and Description |
---|---|
void |
init(AtomicBoolean stop)
Initialize the thread.
|
void |
run() |
startCycleUpdater, stopCycleUpdater, updateCycleDurationMetric
createLockRequest, getConf, getRuntimeVersion, initializeAndStartThread, isMinorCompactionSupported, replIsCompactionDisabledForTable, resolvePartition, resolveStorageDescriptor, runJobAsSelf, setConf, tableName
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
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
start
public void init(AtomicBoolean stop) throws Exception
MetaStoreThread
Configurable.setConf(Configuration)
has been called.init
in interface MetaStoreThread
init
in class MetaStoreCompactorThread
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.Exception
Copyright © 2022 The Apache Software Foundation. All rights reserved.