public static class WALSplitter.PipelineController extends Object
Modifier and Type | Field and Description |
---|---|
(package private) Object |
dataAvailable |
(package private) AtomicReference<Throwable> |
thrown |
Constructor and Description |
---|
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
final Object dataAvailable
public PipelineController()
void writerThreadError(Throwable t)
void checkForErrors() throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.