org.apache.hadoop.hbase.regionserver

Class StripeMultiFileWriter.BoundaryMultiWriter

java.lang.Object

org.apache.hadoop.hbase.regionserver.AbstractMultiFileWriter

org.apache.hadoop.hbase.regionserver.StripeMultiFileWriter

org.apache.hadoop.hbase.regionserver.StripeMultiFileWriter.BoundaryMultiWriter

All Implemented Interfaces:

CellSink, ShipperListener

Enclosing class:

StripeMultiFileWriter

public static class StripeMultiFileWriter.BoundaryMultiWriter
extends StripeMultiFileWriter

MultiWriter that separates the cells based on fixed row-key boundaries. All the KVs between each pair of neighboring boundaries from the list supplied to ctor will end up in one file, and separate from all other such pairs.

Nested Class Summary

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

StripeMultiFileWriter.BoundaryMultiWriter, StripeMultiFileWriter.SizeMultiWriter

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

AbstractMultiFileWriter.WriterFactory

Field Summary

Fields

Modifier and Type	Field and Description
private long	cellsInCurrentWriter
private StoreFileWriter	currentWriter
private byte[]	currentWriterEndKey
private boolean	hasAnyWriter
private Cell	lastCell
private int	majorRangeFromIndex
private int	majorRangeToIndex

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

boundaries, comparator, existingWriters

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

sourceScanner, writerFactory

Constructor Summary

Constructors

Constructor and Description
BoundaryMultiWriter(CellComparator comparator, List<byte[]> targetBoundaries, byte[] majorRangeFrom, byte[] majorRangeTo)

Method Summary

Modifier and Type	Method and Description
void	append(Cell cell) Append the given cell
private void	checkCanCreateWriter()
private void	createEmptyWriter() Called if there are no cells for some stripe.
private boolean	isCellAfterCurrentWriter(Cell cell)
protected void	preCommitWritersInternal()
private void	prepareWriterFor(Cell cell)
private void	stopUsingCurrentWriter()

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

preCloseWriter, preCommitWriters, sanityCheckLeft, sanityCheckRight, setNoStripeMetadata, writers

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

abortWriters, beforeShipped, commitWriters, init

Methods inherited from class java.lang.Object

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

Field Detail

currentWriter

private StoreFileWriter currentWriter

currentWriterEndKey

private byte[] currentWriterEndKey

lastCell

private Cell lastCell

cellsInCurrentWriter

private long cellsInCurrentWriter

majorRangeFromIndex

private int majorRangeFromIndex

majorRangeToIndex

private int majorRangeToIndex

hasAnyWriter

private boolean hasAnyWriter

Constructor Detail

BoundaryMultiWriter

public BoundaryMultiWriter(CellComparator comparator,
                           List<byte[]> targetBoundaries,
                           byte[] majorRangeFrom,
                           byte[] majorRangeTo)
                    throws IOException

Parameters:

targetBoundaries - The boundaries on which writers/files are separated.

majorRangeFrom - Major range is the range for which at least one file should be written (because all files are included in compaction). majorRangeFrom is the left boundary.

majorRangeTo - The right boundary of majorRange (see majorRangeFrom).

Throws:

IOException

Method Detail

append

public void append(Cell cell)
            throws IOException

Description copied from interface: CellSink

Append the given cell

Parameters:

cell - the cell to be added

Throws:

IOException

isCellAfterCurrentWriter

private boolean isCellAfterCurrentWriter(Cell cell)

preCommitWritersInternal

protected void preCommitWritersInternal()
                                 throws IOException

Specified by:

preCommitWritersInternal in class StripeMultiFileWriter

Throws:

IOException

prepareWriterFor

private void prepareWriterFor(Cell cell)
                       throws IOException

Throws:

IOException

createEmptyWriter

private void createEmptyWriter()
                        throws IOException

Called if there are no cells for some stripe. We need to have something in the writer list for this stripe, so that writer-boundary list indices correspond to each other. We can insert null in the writer list for that purpose, except in the following cases where we actually need a file: 1) If we are in range for which we are compacting all the files, we need to create an empty file to preserve stripe metadata. 2) If we have not produced any file at all for this compactions, and this is the last chance (the last stripe), we need to preserve last seqNum (see also HBASE-6059).

Throws:

IOException

checkCanCreateWriter

private void checkCanCreateWriter()
                           throws IOException

Throws:

IOException

stopUsingCurrentWriter

private void stopUsingCurrentWriter()