@InterfaceAudience.Private public class BoundedEntryBuffers extends EntryBuffers
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.EntryBuffers.RegionEntryBuffer
buffers, maxHeapUsage, totalBuffered
Constructor and Description |
---|
BoundedEntryBuffers(WALSplitter.PipelineController controller,
long maxHeapUsage) |
Modifier and Type | Method and Description |
---|---|
(package private) EntryBuffers.RegionEntryBuffer |
getChunkToWrite()
Returns RegionEntryBuffer a buffer of edits to be written.
|
appendEntry, doneWriting, isRegionCurrentlyWriting, waitUntilDrained
public BoundedEntryBuffers(WALSplitter.PipelineController controller, long maxHeapUsage)
EntryBuffers.RegionEntryBuffer getChunkToWrite()
EntryBuffers
getChunkToWrite
in class EntryBuffers
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.