org.apache.hadoop.hbase.regionserver

Class MemStoreCompactorSegmentsIterator

java.lang.Object

org.apache.hadoop.hbase.regionserver.MemStoreSegmentsIterator

org.apache.hadoop.hbase.regionserver.MemStoreCompactorSegmentsIterator

All Implemented Interfaces:

Iterator<Cell>

@InterfaceAudience.Private
public class MemStoreCompactorSegmentsIterator
extends MemStoreSegmentsIterator

The MemStoreCompactorSegmentsIterator extends MemStoreSegmentsIterator and performs the scan for compaction operation meaning it is based on SQM

Field Summary

Fields

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

Fields inherited from class org.apache.hadoop.hbase.regionserver.MemStoreSegmentsIterator

scannerContext

Constructor Summary

Constructors

Constructor and Description
MemStoreCompactorSegmentsIterator(List<ImmutableSegment> segments, CellComparator comparator, int compactionKVMax, HStore store)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining

Field Detail

LOG

private static final org.slf4j.Logger LOG

kvs

private final List<Cell> kvs

hasMore

private boolean hasMore

kvsIterator

private Iterator<Cell> kvsIterator

compactingScanner

private InternalScanner compactingScanner

Constructor Detail

MemStoreCompactorSegmentsIterator

public MemStoreCompactorSegmentsIterator(List<ImmutableSegment> segments,
                                         CellComparator comparator,
                                         int compactionKVMax,
                                         HStore store)
                                  throws IOException

Throws:

IOException

Method Detail

hasNext

public boolean hasNext()

next

public Cell next()

close

public void close()

Specified by:

close in class MemStoreSegmentsIterator

remove

public void remove()

createScanner

private InternalScanner createScanner(HStore store,
                                      List<KeyValueScanner> scanners)
                               throws IOException

Creates the scanner for compacting the pipeline.

Returns:

the scanner

Throws:

IOException

refillKVS

private boolean refillKVS()