public static class WALSplitter.PipelineController extends Object
Modifier and Type | Field and Description |
---|---|
Object |
dataAvailable |
(package private) AtomicReference<Throwable> |
thrown |
Constructor and Description |
---|
WALSplitter.PipelineController() |
Modifier and Type | Method and Description |
---|---|
(package private) void |
checkForErrors()
Check for errors in the writer threads.
|
(package private) void |
writerThreadError(Throwable t) |
AtomicReference<Throwable> thrown
public final Object dataAvailable
void writerThreadError(Throwable t)
void checkForErrors() throws IOException
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.