org.apache.hadoop.hbase.regionserver

Class DateTieredMultiFileWriter

java.lang.Object

org.apache.hadoop.hbase.regionserver.AbstractMultiFileWriter

org.apache.hadoop.hbase.regionserver.DateTieredMultiFileWriter

All Implemented Interfaces:

CellSink, ShipperListener

@InterfaceAudience.Private
public class DateTieredMultiFileWriter
extends AbstractMultiFileWriter

class for cell sink that separates the provided cells into multiple files for date tiered compaction.

Nested Class Summary

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

AbstractMultiFileWriter.WriterFactory

Field Summary

Fields

Modifier and Type	Field and Description
private NavigableMap<Long,StoreFileWriter>	lowerBoundary2Writer
private boolean	needEmptyFile

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

sourceScanner, writerFactory

Constructor Summary

Constructors

Constructor and Description
DateTieredMultiFileWriter(List<Long> lowerBoundaries, boolean needEmptyFile)

Method Summary

Modifier and Type	Method and Description
void	append(Cell cell) Append the given cell
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.
protected Collection<StoreFileWriter>	writers()

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

abortWriters, beforeShipped, commitWriters, init, preCloseWriter

Methods inherited from class java.lang.Object

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

Field Detail

lowerBoundary2Writer

private final NavigableMap<Long,StoreFileWriter> lowerBoundary2Writer

needEmptyFile

private final boolean needEmptyFile

Constructor Detail

DateTieredMultiFileWriter

public DateTieredMultiFileWriter(List<Long> lowerBoundaries,
                                 boolean needEmptyFile)

Parameters:

needEmptyFile - whether need to create an empty store file if we haven't written out anything.

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

writers

protected Collection<StoreFileWriter> writers()

Specified by:

writers in class AbstractMultiFileWriter

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