Class DateTieredMultiFileWriter
java.lang.Object
org.apache.hadoop.hbase.regionserver.AbstractMultiFileWriter
org.apache.hadoop.hbase.regionserver.DateTieredMultiFileWriter
- All Implemented Interfaces:
CellSink
,ShipperListener
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
Modifier and TypeFieldDescriptionprivate final NavigableMap<Long,
StoreFileWriter> private final boolean
Fields inherited from class org.apache.hadoop.hbase.regionserver.AbstractMultiFileWriter
sourceScanner, writerFactory
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
append
(ExtendedCell cell) Append the given cellprotected void
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
-
Field Details
-
lowerBoundary2Writer
-
needEmptyFile
-
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
Description copied from interface:CellSink
Append the given cell- Parameters:
cell
- the cell to be added- Throws:
IOException
-
writers
- Specified by:
writers
in classAbstractMultiFileWriter
-
preCommitWriters
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 classAbstractMultiFileWriter
- Throws:
IOException
-