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 and Description
(package private) Object	dataAvailable
(package private) AtomicReference<Throwable>	thrown

Constructor Summary

Constructors

Constructor and Description
PipelineController()

Method Summary

Modifier and Type	Method and 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 Detail

thrown

AtomicReference<Throwable> thrown

dataAvailable

final Object dataAvailable

Constructor Detail

PipelineController

public PipelineController()

Method Detail

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