org.apache.hadoop.hbase.regionserver

Class StripeMultiFileWriter.SizeMultiWriter

java.lang.Object

org.apache.hadoop.hbase.regionserver.StripeMultiFileWriter

org.apache.hadoop.hbase.regionserver.StripeMultiFileWriter.SizeMultiWriter

All Implemented Interfaces:

Compactor.CellSink

Enclosing class:

StripeMultiFileWriter

public static class StripeMultiFileWriter.SizeMultiWriter
extends StripeMultiFileWriter

MultiWriter that separates the cells based on target cell number per file and file count. New file is started every time the target number of KVs is reached, unless the fixed count of writers has already been created (in that case all the remaining KVs go into the last writer).

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.StripeMultiFileWriter

StripeMultiFileWriter.BoundaryMultiWriter, StripeMultiFileWriter.SizeMultiWriter, StripeMultiFileWriter.WriterFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected byte[]	lastRowInCurrentWriter

Fields inherited from class org.apache.hadoop.hbase.regionserver.StripeMultiFileWriter

boundaries, comparator, existingWriters, sourceScanner, writerFactory

Constructor Summary

Constructors

Constructor and Description
SizeMultiWriter(int targetCount, long targetKvs, byte[] left, byte[] right)

Method Summary

Modifier and Type	Method and Description
void	append(Cell cell)
protected void	commitWritersInternal() Subclasses override this method to be called at the end of a successful sequence of append; all appends are processed before this method is called.

Methods inherited from class org.apache.hadoop.hbase.regionserver.StripeMultiFileWriter

abortWriters, commitWriters, init, sanityCheckLeft, sanityCheckRight, setNoStripeMetadata

Methods inherited from class java.lang.Object

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

Field Detail

lastRowInCurrentWriter

protected byte[] lastRowInCurrentWriter

Constructor Detail

SizeMultiWriter

public SizeMultiWriter(int targetCount,
                       long targetKvs,
                       byte[] left,
                       byte[] right)

Parameters:

targetCount - The maximum count of writers that can be created.

targetKvs - The number of KVs to read from source before starting each new writer.

left - The left boundary of the first writer.

right - The right boundary of the last writer.

Method Detail

append

public void append(Cell cell)
            throws IOException

Throws:

IOException

commitWritersInternal

protected void commitWritersInternal()
                              throws IOException

Description copied from class: StripeMultiFileWriter

Subclasses override this method to be called at the end of a successful sequence of append; all appends are processed before this method is called.

Specified by:

commitWritersInternal in class StripeMultiFileWriter

Throws:

IOException