Package org.apache.hadoop.hbase.wal

Class WALSplitter.PipelineController

java.lang.Object

org.apache.hadoop.hbase.wal.WALSplitter.PipelineController

Enclosing class:

WALSplitter

public static class WALSplitter.PipelineController
extends Object

Contains some methods to control WAL-entries producer / consumer interactions

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Object	dataAvailable
(package private) AtomicReference<Throwable>	thrown

Constructor Summary

Constructors

Constructor	Description
PipelineController()

Method Summary

Modifier and Type	Method	Description
(package private) void	checkForErrors()	Check for errors in the writer threads.
(package private) void	writerThreadError(Throwable t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

thrown

AtomicReference<Throwable> thrown

dataAvailable

final Object dataAvailable

Constructor Details

PipelineController

public PipelineController()

Method Details

writerThreadError

void writerThreadError(Throwable t)

checkForErrors

void checkForErrors()
             throws IOException

Check for errors in the writer threads. If any is found, rethrow it.

Throws:

IOException