Package org.apache.hadoop.hbase.regionserver

Class StripeMultiFileWriter

java.lang.Object

org.apache.hadoop.hbase.regionserver.AbstractMultiFileWriter

org.apache.hadoop.hbase.regionserver.StripeMultiFileWriter

All Implemented Interfaces:

CellSink, ShipperListener

Direct Known Subclasses:

StripeMultiFileWriter.BoundaryMultiWriter, StripeMultiFileWriter.SizeMultiWriter

@Private
public abstract class StripeMultiFileWriter
extends AbstractMultiFileWriter

Base class for cell sink that separates the provided cells into multiple files for stripe compaction.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StripeMultiFileWriter.BoundaryMultiWriter	MultiWriter that separates the cells based on fixed row-key boundaries.
static class	StripeMultiFileWriter.SizeMultiWriter	MultiWriter that separates the cells based on target cell number per file and file count.

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

AbstractMultiFileWriter.WriterFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected List<byte[]>	boundaries
protected final CellComparator	comparator
private boolean	doWriteStripeMetadata	Whether to write stripe metadata
protected List<StoreFileWriter>	existingWriters
private static final org.slf4j.Logger	LOG

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

sourceScanner, writerFactory

Constructor Summary

Constructors

Constructor	Description
StripeMultiFileWriter(CellComparator comparator)

Method Summary

Modifier and Type	Method	Description
protected void	preCloseWriter(StoreFileWriter writer)	Subclasses override this method to be called before we close the give writer.
protected final 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.
protected abstract void	preCommitWritersInternal()
protected void	sanityCheckLeft(byte[] left, Cell cell)	Subclasses can call this method to make sure the first KV is within multi-writer range.
protected void	sanityCheckRight(byte[] right, Cell cell)	Subclasses can call this method to make sure the last KV is within multi-writer range.
void	setNoStripeMetadata()
protected Collection<StoreFileWriter>	writers()

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

abortWriters, beforeShipped, commitWriters, commitWriters, init

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.regionserver.CellSink

append, appendAll

Field Details

LOG

private static final org.slf4j.Logger LOG

comparator

protected final CellComparator comparator

existingWriters

protected List<StoreFileWriter> existingWriters

boundaries

protected List<byte[]> boundaries

doWriteStripeMetadata

private boolean doWriteStripeMetadata

Whether to write stripe metadata

Constructor Details

StripeMultiFileWriter

public StripeMultiFileWriter(CellComparator comparator)

Method Details

setNoStripeMetadata

public void setNoStripeMetadata()

writers

protected Collection<StoreFileWriter> writers()

Specified by:

writers in class AbstractMultiFileWriter

preCommitWritersInternal

protected abstract void preCommitWritersInternal()
                                          throws IOException

Throws:

IOException

preCommitWriters

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

preCloseWriter

protected void preCloseWriter(StoreFileWriter writer)
                       throws IOException

Description copied from class: AbstractMultiFileWriter

Subclasses override this method to be called before we close the give writer. Usually you can append extra metadata to the writer.

Overrides:

preCloseWriter in class AbstractMultiFileWriter

Throws:

IOException

sanityCheckLeft

protected void sanityCheckLeft(byte[] left,
 Cell cell)
                        throws IOException

Subclasses can call this method to make sure the first KV is within multi-writer range.

Parameters:

left - The left boundary of the writer.

cell - The cell whose row has to be checked.

Throws:

IOException

sanityCheckRight

protected void sanityCheckRight(byte[] right,
 Cell cell)
                         throws IOException

Subclasses can call this method to make sure the last KV is within multi-writer range.

Parameters:

right - The right boundary of the writer.

Throws:

IOException