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.