org.apache.hadoop.hbase.wal

Class BoundedEntryBuffers

java.lang.Object

org.apache.hadoop.hbase.wal.EntryBuffers

org.apache.hadoop.hbase.wal.BoundedEntryBuffers

@InterfaceAudience.Private
public class BoundedEntryBuffers
extends EntryBuffers

Used for BoundedRecoveredEditsOutputSink. The core part of limiting opening writers is it doesn't return chunk only if the heap size is over maxHeapUsage. Thus it doesn't need to create a writer for each region during splitting. The returned EntryBuffers.RegionEntryBuffer will be write to recovered edits file and close the writer immediately. See BoundedRecoveredEditsOutputSink.append(EntryBuffers.RegionEntryBuffer) for more details.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.wal.EntryBuffers

EntryBuffers.RegionEntryBuffer

Field Summary

Fields inherited from class org.apache.hadoop.hbase.wal.EntryBuffers

buffers, maxHeapUsage, totalBuffered

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
(package private) EntryBuffers.RegionEntryBuffer	getChunkToWrite()

Methods inherited from class org.apache.hadoop.hbase.wal.EntryBuffers

appendEntry, doneWriting, isRegionCurrentlyWriting, waitUntilDrained

Methods inherited from class java.lang.Object

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

Constructor Detail

BoundedEntryBuffers

public BoundedEntryBuffers(WALSplitter.PipelineController controller,
                           long maxHeapUsage)

Method Detail

getChunkToWrite

EntryBuffers.RegionEntryBuffer getChunkToWrite()

Overrides:

getChunkToWrite in class EntryBuffers

Returns:

RegionEntryBuffer a buffer of edits to be written.