Package 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<ExtendedCell>

@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	Description
private InternalScanner	compactingScanner
private boolean	hasMore
private final List<ExtendedCell>	kvs
private Iterator<ExtendedCell>	kvsIterator
private static final org.slf4j.Logger	LOG

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

scannerContext

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
private InternalScanner	createScanner(HStore store, List<KeyValueScanner> scanners)	Creates the scanner for compacting the pipeline.
boolean	hasNext()
ExtendedCell	next()
private boolean	refillKVS()	Refill kev-value set (should be invoked only when KVS is empty) Returns true if KVS is non-empty
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 Details

LOG

private static final org.slf4j.Logger LOG

kvs

private final List<ExtendedCell> kvs

hasMore

private boolean hasMore

kvsIterator

private Iterator<ExtendedCell> kvsIterator

compactingScanner

private InternalScanner compactingScanner

Constructor Details

MemStoreCompactorSegmentsIterator

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

Throws:

IOException

Method Details

hasNext

public boolean hasNext()

next

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

Refill kev-value set (should be invoked only when KVS is empty) Returns true if KVS is non-empty