public static class StripeMultiFileWriter.SizeMultiWriter extends StripeMultiFileWriter
StripeMultiFileWriter.BoundaryMultiWriter, StripeMultiFileWriter.SizeMultiWriter
AbstractMultiFileWriter.WriterFactory
Modifier and Type | Field and Description |
---|---|
protected byte[] |
lastRowInCurrentWriter |
boundaries, comparator, existingWriters
sourceScanner, 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, writers
abortWriters, commitWriters, commitWriters, init
public 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
IOException
protected void preCommitWritersInternal() throws IOException
preCommitWritersInternal
in class StripeMultiFileWriter
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.