public abstract class StripeMultiFileWriter extends AbstractMultiFileWriter
Modifier and Type | Class and Description |
---|---|
static class |
StripeMultiFileWriter.BoundaryMultiWriter
MultiWriter that separates the cells based on fixed row-key boundaries.
|
static class |
StripeMultiFileWriter.SizeMultiWriter
MultiWriter that separates the cells based on target cell number per file and file count.
|
AbstractMultiFileWriter.WriterFactory
Modifier and Type | Field and Description |
---|---|
protected java.util.List<byte[]> |
boundaries |
protected CellComparator |
comparator |
protected java.util.List<StoreFileWriter> |
existingWriters |
sourceScanner, writerFactory
Constructor and Description |
---|
StripeMultiFileWriter(CellComparator comparator) |
Modifier and Type | Method and Description |
---|---|
protected void |
preCloseWriter(StoreFileWriter writer)
Subclasses override this method to be called before we close the give writer.
|
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 abstract void |
preCommitWritersInternal() |
protected void |
sanityCheckLeft(byte[] left,
Cell cell)
Subclasses can call this method to make sure the first KV is within multi-writer range.
|
protected void |
sanityCheckRight(byte[] right,
Cell cell)
Subclasses can call this method to make sure the last KV is within multi-writer range.
|
void |
setNoStripeMetadata() |
protected java.util.Collection<StoreFileWriter> |
writers() |
abortWriters, beforeShipped, commitWriters, init
protected final CellComparator comparator
protected java.util.List<StoreFileWriter> existingWriters
protected java.util.List<byte[]> boundaries
public void setNoStripeMetadata()
protected java.util.Collection<StoreFileWriter> writers()
writers
in class AbstractMultiFileWriter
protected abstract void preCommitWritersInternal() throws java.io.IOException
java.io.IOException
protected final void preCommitWriters() throws java.io.IOException
AbstractMultiFileWriter
preCommitWriters
in class AbstractMultiFileWriter
java.io.IOException
protected void preCloseWriter(StoreFileWriter writer) throws java.io.IOException
AbstractMultiFileWriter
preCloseWriter
in class AbstractMultiFileWriter
java.io.IOException
protected void sanityCheckLeft(byte[] left, Cell cell) throws java.io.IOException
left
- The left boundary of the writer.cell
- The cell whose row has to be checked.java.io.IOException
protected void sanityCheckRight(byte[] right, Cell cell) throws java.io.IOException
right
- The right boundary of the writer.java.io.IOException