public static class StripeMultiFileWriter.SizeMultiWriter extends StripeMultiFileWriter
StripeMultiFileWriter.BoundaryMultiWriter, StripeMultiFileWriter.SizeMultiWriterAbstractMultiFileWriter.WriterFactory| Modifier and Type | Field and Description |
|---|---|
protected byte[] |
lastRowInCurrentWriter |
boundaries, comparator, existingWriterssourceScanner, writerFactory| Constructor and Description |
|---|
StripeMultiFileWriter.SizeMultiWriter(KeyValue.KVComparator comparator,
int targetCount,
long targetKvs,
byte[] left,
byte[] right) |
| Modifier and Type | Method and Description |
|---|---|
void |
append(Cell cell) |
protected void |
preCommitWritersInternal() |
preCloseWriter, preCommitWriters, sanityCheckLeft, sanityCheckRight, setNoStripeMetadata, writersabortWriters, commitWriters, commitWriters, initpublic StripeMultiFileWriter.SizeMultiWriter(KeyValue.KVComparator comparator, int targetCount, long targetKvs, byte[] left, byte[] right)
targetCount - The maximum count of writers that can be created.targetKvs - The number of KVs to read from source before starting each new writer.left - The left boundary of the first writer.right - The right boundary of the last writer.public void append(Cell cell) throws IOException
IOExceptionprotected void preCommitWritersInternal()
throws IOException
preCommitWritersInternal in class StripeMultiFileWriterIOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.