Package 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

@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	Description
private final Map<Long,String>	lowerBoundariesPolicies
private final NavigableMap<Long,StoreFileWriter>	lowerBoundary2Writer
private final boolean	needEmptyFile

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

sourceScanner, writerFactory

Constructor Summary

Constructors

Constructor	Description
DateTieredMultiFileWriter(List<Long> lowerBoundaries, Map<Long,String> lowerBoundariesPolicies, boolean needEmptyFile)

Method Summary

Modifier and Type	Method	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, commitWriters, init, preCloseWriter

Methods inherited from class java.lang.Object

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

Field Details

lowerBoundary2Writer

private final NavigableMap<Long,StoreFileWriter> lowerBoundary2Writer

needEmptyFile

private final boolean needEmptyFile

lowerBoundariesPolicies

private final Map<Long,String> lowerBoundariesPolicies

Constructor Details

DateTieredMultiFileWriter

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

Parameters:

lowerBoundariesPolicies - each window to storage policy map.

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

Method Details

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