public class CompactionIterator extends CompactionInfo.Holder implements UnfilteredPartitionIterator
On top of the actual merging the source iterators, this class:
Constructor and Description |
---|
CompactionIterator(OperationType type,
java.util.List<ISSTableScanner> scanners,
CompactionController controller,
int nowInSec,
java.util.UUID compactionId) |
CompactionIterator(OperationType type,
java.util.List<ISSTableScanner> scanners,
CompactionController controller,
int nowInSec,
java.util.UUID compactionId,
CompactionMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
CompactionInfo |
getCompactionInfo() |
long[] |
getMergedRowCounts() |
long |
getTotalSourceCQLRows() |
boolean |
hasNext() |
CFMetaData |
metadata() |
UnfilteredRowIterator |
next() |
void |
remove() |
java.lang.String |
toString() |
isStopRequested, stop
public CompactionIterator(OperationType type, java.util.List<ISSTableScanner> scanners, CompactionController controller, int nowInSec, java.util.UUID compactionId)
public CompactionIterator(OperationType type, java.util.List<ISSTableScanner> scanners, CompactionController controller, int nowInSec, java.util.UUID compactionId, CompactionMetrics metrics)
public CFMetaData metadata()
metadata
in interface UnfilteredPartitionIterator
public CompactionInfo getCompactionInfo()
getCompactionInfo
in class CompactionInfo.Holder
public long[] getMergedRowCounts()
public long getTotalSourceCQLRows()
public boolean hasNext()
hasNext
in interface java.util.Iterator<UnfilteredRowIterator>
public UnfilteredRowIterator next()
next
in interface java.util.Iterator<UnfilteredRowIterator>
public void remove()
remove
in interface java.util.Iterator<UnfilteredRowIterator>
public void close()
close
in interface java.lang.AutoCloseable
close
in interface BasePartitionIterator<UnfilteredRowIterator>
close
in interface CloseableIterator<UnfilteredRowIterator>
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2018 The Apache Software Foundation