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

Direct Known Subclasses:

CustomTieringMultiFileWriter

@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
protected final NavigableMap<Long,StoreFileWriter>	lowerBoundary2Writer
private final boolean	needEmptyFile
protected Function<ExtendedCell,Long>	tieringFunction

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)
DateTieredMultiFileWriter(List<Long> lowerBoundaries, Map<Long,String> lowerBoundariesPolicies, boolean needEmptyFile, Function<ExtendedCell,Long> tieringFunction)

Method Summary

Modifier and Type	Method	Description
void	append(ExtendedCell 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

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

appendAll

Field Details

lowerBoundary2Writer

protected final NavigableMap<Long,StoreFileWriter> lowerBoundary2Writer

needEmptyFile

private final boolean needEmptyFile

lowerBoundariesPolicies

private final Map<Long,String> lowerBoundariesPolicies

tieringFunction

protected Function<ExtendedCell,Long> tieringFunction

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.

DateTieredMultiFileWriter

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

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