org.apache.hadoop.hbase.wal

Class WALSplitter.EntryBuffers

java.lang.Object

org.apache.hadoop.hbase.wal.WALSplitter.EntryBuffers

Enclosing class:

WALSplitter

public static class WALSplitter.EntryBuffers
extends Object

Class which accumulates edits and separates them into a buffer per region while simultaneously accounting RAM usage. Blocks if the RAM usage crosses a predefined threshold. Writer threads then pull region-specific buffers from this class.

Constructor Summary

Constructors

Constructor and Description
WALSplitter.EntryBuffers(WALSplitter.PipelineController controller, long maxHeapUsage)

Method Summary

Methods

Modifier and Type	Method and Description
void	appendEntry(WAL.Entry entry) Append a log entry into the corresponding region buffer.
void	waitUntilDrained()

Methods inherited from class java.lang.Object

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

Constructor Detail

WALSplitter.EntryBuffers

public WALSplitter.EntryBuffers(WALSplitter.PipelineController controller,
                        long maxHeapUsage)

Method Detail

appendEntry

public void appendEntry(WAL.Entry entry)
                 throws InterruptedException,
                        IOException

Append a log entry into the corresponding region buffer. Blocks if the total heap usage has crossed the specified threshold.

Throws:

InterruptedException

IOException

waitUntilDrained

public void waitUntilDrained()