Package org.apache.hadoop.hbase.regionserver.querymatcher

Class CompactionScanQueryMatcher

java.lang.Object

org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher

org.apache.hadoop.hbase.regionserver.querymatcher.CompactionScanQueryMatcher

All Implemented Interfaces:

ShipperListener

Direct Known Subclasses:

DropDeletesCompactionScanQueryMatcher, MinorCompactionScanQueryMatcher

@Private
public abstract class CompactionScanQueryMatcher
extends ScanQueryMatcher

Query matcher for compaction.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher

ScanQueryMatcher.MatchCode

Field Summary

Fields

Modifier and Type	Field	Description
protected final DeleteTracker	deletes	Keeps track of deletes
protected final KeepDeletedCells	keepDeletedCells	whether to return deleted rows
protected final long	maxReadPointToTrackVersions	readPoint over which the KVs are unconditionally included

Fields inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher

columns, currentRow, now, oldestUnexpiredTS, rowComparator, startKey

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CompactionScanQueryMatcher(ScanInfo scanInfo, DeleteTracker deletes, ColumnTracker columnTracker, long readPointToUse, long oldestUnexpiredTS, long now)

Method Summary

Modifier and Type	Method	Description
void	beforeShipped()	The action that needs to be performed before Shipper.shipped() is performed
static CompactionScanQueryMatcher	create(ScanInfo scanInfo, ScanType scanType, long readPointToUse, long earliestPutTs, long oldestUnexpiredTS, long now, byte[] dropDeletesFromRow, byte[] dropDeletesToRow, RegionCoprocessorHost regionCoprocessorHost)
Filter	getFilter()	Returns the Filter
ExtendedCell	getNextKeyHint(ExtendedCell cell)	Delegate to Filter.getNextCellHint(Cell).
boolean	hasNullColumnInQuery()	Returns whether there is an null column in the query
boolean	isUserScan()
boolean	moreRowsMayExistAfter(ExtendedCell cell)
protected void	reset()
protected final void	trackDelete(ExtendedCell cell)

Methods inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher

checkColumn, checkDeleted, clearCurrentRow, compareKeyForNextColumn, compareKeyForNextRow, createStartKeyFromRow, currentRow, getKeyForNextColumn, getStartKey, getTrackers, match, preCheck, setToNewRow

Methods inherited from class java.lang.Object

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

Field Details

maxReadPointToTrackVersions

protected final long maxReadPointToTrackVersions

readPoint over which the KVs are unconditionally included

deletes

protected final DeleteTracker deletes

Keeps track of deletes

keepDeletedCells

protected final KeepDeletedCells keepDeletedCells

whether to return deleted rows

Constructor Details

CompactionScanQueryMatcher

protected CompactionScanQueryMatcher(ScanInfo scanInfo,
 DeleteTracker deletes,
 ColumnTracker columnTracker,
 long readPointToUse,
 long oldestUnexpiredTS,
 long now)

Method Details

beforeShipped

public void beforeShipped()
                   throws IOException

Description copied from interface: ShipperListener

The action that needs to be performed before Shipper.shipped() is performed

Specified by:

beforeShipped in interface ShipperListener

Overrides:

beforeShipped in class ScanQueryMatcher

Throws:

IOException

hasNullColumnInQuery

public boolean hasNullColumnInQuery()

Description copied from class: ScanQueryMatcher

Returns whether there is an null column in the query

Specified by:

hasNullColumnInQuery in class ScanQueryMatcher

isUserScan

public boolean isUserScan()

Specified by:

isUserScan in class ScanQueryMatcher

moreRowsMayExistAfter

public boolean moreRowsMayExistAfter(ExtendedCell cell)

Specified by:

moreRowsMayExistAfter in class ScanQueryMatcher

Returns:

Returns false if we know there are no more rows to be scanned (We've reached the stopRow or we are scanning on row only because this Scan is for a Get, etc.

getFilter

public Filter getFilter()

Description copied from class: ScanQueryMatcher

Returns the Filter

Specified by:

getFilter in class ScanQueryMatcher

getNextKeyHint

public ExtendedCell getNextKeyHint(ExtendedCell cell)
                            throws IOException

Description copied from class: ScanQueryMatcher

Delegate to Filter.getNextCellHint(Cell). If no filter, return null.

Specified by:

getNextKeyHint in class ScanQueryMatcher

Throws:

IOException

reset

protected void reset()

Specified by:

reset in class ScanQueryMatcher

trackDelete

protected final void trackDelete(ExtendedCell cell)

create

public static CompactionScanQueryMatcher create(ScanInfo scanInfo,
 ScanType scanType,
 long readPointToUse,
 long earliestPutTs,
 long oldestUnexpiredTS,
 long now,
 byte[] dropDeletesFromRow,
 byte[] dropDeletesToRow,
 RegionCoprocessorHost regionCoprocessorHost)
                                         throws IOException

Throws:

IOException