@InterfaceAudience.Private public class DateTieredMultiFileWriter extends AbstractMultiFileWriter
AbstractMultiFileWriter.WriterFactory
Modifier and Type | Field and Description |
---|---|
private Map<Long,String> |
lowerBoundariesPolicies |
private NavigableMap<Long,StoreFileWriter> |
lowerBoundary2Writer |
private boolean |
needEmptyFile |
sourceScanner, writerFactory
Constructor and Description |
---|
DateTieredMultiFileWriter(List<Long> lowerBoundaries,
Map<Long,String> lowerBoundariesPolicies,
boolean needEmptyFile) |
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() |
abortWriters, beforeShipped, commitWriters, commitWriters, init, preCloseWriter
private final NavigableMap<Long,StoreFileWriter> lowerBoundary2Writer
private final boolean needEmptyFile
private final Map<Long,String> lowerBoundariesPolicies
public DateTieredMultiFileWriter(List<Long> lowerBoundaries, Map<Long,String> lowerBoundariesPolicies, boolean needEmptyFile)
lowerBoundariesPolicies
- each window to storage policy map.needEmptyFile
- whether need to create an empty store file if we haven't written
out anything.public void append(Cell cell) throws IOException
CellSink
cell
- the cell to be added nIOException
protected Collection<StoreFileWriter> writers()
writers
in class AbstractMultiFileWriter
protected void preCommitWriters() throws IOException
AbstractMultiFileWriter
preCommitWriters
in class AbstractMultiFileWriter
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.