org.apache.hadoop.hbase.regionserver

Class MobCompactionStoreScanner

java.lang.Object

org.apache.hadoop.hbase.regionserver.NonLazyKeyValueScanner

org.apache.hadoop.hbase.regionserver.NonReversedNonLazyKeyValueScanner

org.apache.hadoop.hbase.regionserver.StoreScanner

org.apache.hadoop.hbase.regionserver.MobCompactionStoreScanner

All Implemented Interfaces:

Closeable, AutoCloseable, ChangedReadersObserver, InternalScanner, KeyValueScanner

@InterfaceAudience.Private
public class MobCompactionStoreScanner
extends StoreScanner

Scanner scans the MOB Store. Coalesce KeyValue stream into List for a single row. It's only used in the compaction of mob-enabled columns. It outputs the normal cells and delete markers when outputDeleteMarkers is set as true.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	outputDeleteMarkers

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

cacheBlocks, cellsPerHeartbeatCheck, closing, columns, countPerRow, DEFAULT_HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, executor, explicitColumnQuery, HBASE_CELLS_SCANNED_PER_HEARTBEAT_CHECK, heap, isGet, isParallelSeekEnabled, lastTop, lazySeekEnabledGlobally, lock, matcher, maxRowSize, minVersions, now, oldestUnexpiredTS, readPt, scan, store, storeLimit, storeOffset, STORESCANNER_PARALLEL_SEEK_ENABLE, useRowColBloom

Constructor Summary

Constructors

Constructor and Description
MobCompactionStoreScanner(Store store, ScanInfo scanInfo, Scan scan, List<? extends KeyValueScanner> scanners, ScanType scanType, long smallestReadPoint, long earliestPutTs, boolean outputDeleteMarkers) Used for compactions.

Method Summary

Modifier and Type	Method and Description
boolean	isOutputDeleteMarkers() Gets whether the delete markers could be written to the del files.

Methods inherited from class org.apache.hadoop.hbase.regionserver.StoreScanner

checkReseek, checkScanOrder, close, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getScannersNoCompaction, getSequenceID, next, next, next, peek, reseek, resetKVHeap, resetScannerStack, seek, seekAsDirection, seekScanners, seekToNextRow, selectScannersFrom, updateReaders

Methods inherited from class org.apache.hadoop.hbase.regionserver.NonReversedNonLazyKeyValueScanner

backwardSeek, seekToLastRow, seekToPreviousRow

Methods inherited from class org.apache.hadoop.hbase.regionserver.NonLazyKeyValueScanner

doRealSeek, enforceSeek, isFileScanner, realSeekDone, requestSeek, shouldUseScanner

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.regionserver.KeyValueScanner

backwardSeek, enforceSeek, isFileScanner, realSeekDone, requestSeek, seekToLastRow, seekToPreviousRow, shouldUseScanner

Field Detail

outputDeleteMarkers

protected boolean outputDeleteMarkers

Constructor Detail

MobCompactionStoreScanner

public MobCompactionStoreScanner(Store store,
                                 ScanInfo scanInfo,
                                 Scan scan,
                                 List<? extends KeyValueScanner> scanners,
                                 ScanType scanType,
                                 long smallestReadPoint,
                                 long earliestPutTs,
                                 boolean outputDeleteMarkers)
                          throws IOException

Used for compactions.

Opens a scanner across specified StoreFiles.

Parameters:

store - who we scan

scan - the spec

scanners - ancillary scanners

smallestReadPoint - the readPoint that we should use for tracking versions

Throws:

IOException

Method Detail

isOutputDeleteMarkers

public boolean isOutputDeleteMarkers()

Gets whether the delete markers could be written to the del files.

Returns:

True if the delete markers could be written del files, false if it's not allowed.