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:

Compactor.CellSink

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 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

StripeMultiFileWriter.BoundaryMultiWriter(KeyValue.KVComparator comparator, List<byte[]> targetBoundaries, byte[] majorRangeFrom, byte[] majorRangeTo)

Method Summary

void	append(KeyValue kv)
protected void	preCommitWriters() 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

preCloseWriter, sanityCheckLeft, sanityCheckRight, setNoStripeMetadata, writers

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

abortWriters, commitWriters, init

Methods inherited from class java.lang.Object

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

Constructor Detail

StripeMultiFileWriter.BoundaryMultiWriter

public StripeMultiFileWriter.BoundaryMultiWriter(KeyValue.KVComparator 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(KeyValue kv)
            throws IOException

Throws:

IOException

preCommitWriters

protected void preCommitWriters()
                         throws IOException

Description copied from class: AbstractMultiFileWriter

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.

Overrides:

preCommitWriters in class AbstractMultiFileWriter

Throws:

IOException