public static class OutputSink.WriterThread extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
private WALSplitter.PipelineController |
controller |
private EntryBuffers |
entryBuffers |
private OutputSink |
outputSink |
private boolean |
shouldStop |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
WriterThread(WALSplitter.PipelineController controller,
EntryBuffers entryBuffers,
OutputSink sink,
int i) |
WriterThread(WALSplitter.PipelineController controller,
EntryBuffers entryBuffers,
OutputSink sink,
String threadName) |
Modifier and Type | Method and Description |
---|---|
private void |
doRun() |
private void |
finish() |
void |
run() |
private void |
writeBuffer(EntryBuffers.RegionEntryBuffer buffer) |
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
private volatile boolean shouldStop
private WALSplitter.PipelineController controller
private EntryBuffers entryBuffers
private OutputSink outputSink
WriterThread(WALSplitter.PipelineController controller, EntryBuffers entryBuffers, OutputSink sink, int i)
WriterThread(WALSplitter.PipelineController controller, EntryBuffers entryBuffers, OutputSink sink, String threadName)
private void doRun() throws IOException
IOException
private void writeBuffer(EntryBuffers.RegionEntryBuffer buffer) throws IOException
IOException
private void finish()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.