public static class StripeMultiFileWriter.BoundaryMultiWriter extends StripeMultiFileWriter
StripeMultiFileWriter.BoundaryMultiWriter, StripeMultiFileWriter.SizeMultiWriter
AbstractMultiFileWriter.WriterFactory
boundaries, comparator, existingWriters
sourceScanner, writerFactory
Constructor and Description |
---|
StripeMultiFileWriter.BoundaryMultiWriter(KeyValue.KVComparator comparator,
List<byte[]> targetBoundaries,
byte[] majorRangeFrom,
byte[] majorRangeTo) |
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.BoundaryMultiWriter(KeyValue.KVComparator comparator, List<byte[]> targetBoundaries, byte[] majorRangeFrom, byte[] majorRangeTo) throws IOException
targetBoundaries
- The boundaries on which writers/files are separated.majorRangeFrom
- Major range is the range for which at least one file should be written
(because all files are included in compaction). majorRangeFrom is the left boundary.majorRangeTo
- The right boundary of majorRange (see majorRangeFrom).IOException
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.