Package org.apache.hadoop.hbase.regionserver

Class CustomTieringMultiFileWriter

java.lang.Object

org.apache.hadoop.hbase.regionserver.AbstractMultiFileWriter

org.apache.hadoop.hbase.regionserver.DateTieredMultiFileWriter

org.apache.hadoop.hbase.regionserver.CustomTieringMultiFileWriter

All Implemented Interfaces:

CellSink, ShipperListener

@Private
public class CustomTieringMultiFileWriter
extends DateTieredMultiFileWriter

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
static final byte[]	CUSTOM_TIERING_TIME_RANGE
private NavigableMap<Long,TimeRangeTracker>	lowerBoundary2TimeRanger

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

lowerBoundary2Writer, tieringFunction

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

sourceScanner, writerFactory

Constructor Summary

Constructors

Constructor	Description
CustomTieringMultiFileWriter(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
List<org.apache.hadoop.fs.Path>	commitWriters(long maxSeqId, boolean majorCompaction, Collection<HStoreFile> storeFiles)

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

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

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

appendAll

Field Details

CUSTOM_TIERING_TIME_RANGE

public static final byte[] CUSTOM_TIERING_TIME_RANGE

lowerBoundary2TimeRanger

private NavigableMap<Long,TimeRangeTracker> lowerBoundary2TimeRanger

Constructor Details

CustomTieringMultiFileWriter

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

Method Details

append

public void append(ExtendedCell cell)
            throws IOException

Description copied from interface: CellSink

Append the given cell

Specified by:

append in interface CellSink

Overrides:

append in class DateTieredMultiFileWriter

Parameters:

cell - the cell to be added

Throws:

IOException

commitWriters

public List<org.apache.hadoop.fs.Path> commitWriters(long maxSeqId,
 boolean majorCompaction,
 Collection<HStoreFile> storeFiles)
                                              throws IOException

Overrides:

commitWriters in class AbstractMultiFileWriter

Throws:

IOException