@InterfaceAudience.Private public class MemStoreCompactorSegmentsIterator extends MemStoreSegmentsIterator
Modifier and Type | Field and Description |
---|---|
private InternalScanner |
compactingScanner |
private boolean |
hasMore |
private List<Cell> |
kvs |
private Iterator<Cell> |
kvsIterator |
private static org.slf4j.Logger |
LOG |
scannerContext
Constructor and Description |
---|
MemStoreCompactorSegmentsIterator(List<ImmutableSegment> segments,
CellComparator comparator,
int compactionKVMax,
HStore store) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
private InternalScanner |
createScanner(HStore store,
List<KeyValueScanner> scanners)
Creates the scanner for compacting the pipeline.
|
boolean |
hasNext() |
Cell |
next() |
private boolean |
refillKVS() |
void |
remove() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
private static final org.slf4j.Logger LOG
private boolean hasMore
private Iterator<Cell> kvsIterator
private InternalScanner compactingScanner
public MemStoreCompactorSegmentsIterator(List<ImmutableSegment> segments, CellComparator comparator, int compactionKVMax, HStore store) throws IOException
IOException
public boolean hasNext()
public void close()
close
in class MemStoreSegmentsIterator
public void remove()
private InternalScanner createScanner(HStore store, List<KeyValueScanner> scanners) throws IOException
IOException
private boolean refillKVS()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.