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

Class ScanQueryMatcher

java.lang.Object

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

All Implemented Interfaces:

ShipperListener

Direct Known Subclasses:

CompactionScanQueryMatcher, UserScanQueryMatcher

@Private
public abstract class ScanQueryMatcher
extends Object
implements ShipperListener

A query matcher that is specifically designed for the scan case.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ScanQueryMatcher.MatchCode	match(org.apache.hadoop.hbase.ExtendedCell) return codes.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ColumnTracker	columns	Keeps track of columns and versions
protected ExtendedCell	currentRow	Row the query is on
protected final long	now
protected final long	oldestUnexpiredTS	The oldest timestamp we are interested in, based on TTL
protected final CellComparator	rowComparator	Row comparator for the region this query is for
protected final ExtendedCell	startKey	Key to seek to in memstore and StoreFiles

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ScanQueryMatcher(ExtendedCell startKey, ScanInfo scanInfo, ColumnTracker columns, 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
(package private) static ScanQueryMatcher.MatchCode	checkColumn(ColumnTracker columnTracker, byte[] bytes, int offset, int length, long ttl, byte type, boolean ignoreCount)
protected final ScanQueryMatcher.MatchCode	checkDeleted(DeleteTracker deletes, ExtendedCell cell)
void	clearCurrentRow()	Make currentRow() return null.
int	compareKeyForNextColumn(ExtendedCell nextIndexed, ExtendedCell currentCell)
int	compareKeyForNextRow(ExtendedCell nextIndexed, ExtendedCell currentCell)
protected static ExtendedCell	createStartKeyFromRow(byte[] startRow, ScanInfo scanInfo)
ExtendedCell	currentRow()	Returns a cell represent the current row
abstract Filter	getFilter()	Returns the Filter
ExtendedCell	getKeyForNextColumn(ExtendedCell cell)
abstract ExtendedCell	getNextKeyHint(ExtendedCell cell)	Delegate to Filter.getNextCellHint(Cell).
ExtendedCell	getStartKey()	Returns the start key
protected static Pair<DeleteTracker,ColumnTracker>	getTrackers(RegionCoprocessorHost host, NavigableSet<byte[]> columns, ScanInfo scanInfo, long oldestUnexpiredTS, Scan userScan)
abstract boolean	hasNullColumnInQuery()	Returns whether there is an null column in the query
private static boolean	isCellTTLExpired(ExtendedCell cell, long oldestTimestamp, long now)	Returns true if the cell is expired
abstract boolean	isUserScan()
abstract ScanQueryMatcher.MatchCode	match(ExtendedCell cell)	Determines if the caller should do one of several things: seek/skip to the next row (MatchCode.SEEK_NEXT_ROW) seek/skip to the next column (MatchCode.SEEK_NEXT_COL) include the current KeyValue (MatchCode.INCLUDE) ignore the current KeyValue (MatchCode.SKIP) got to the next row (MatchCode.DONE)
abstract boolean	moreRowsMayExistAfter(ExtendedCell cell)
protected final ScanQueryMatcher.MatchCode	preCheck(ExtendedCell cell)	Check before the delete logic.
protected abstract void	reset()
void	setToNewRow(ExtendedCell currentRow)	Set the row when there is change in row

Methods inherited from class java.lang.Object

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

Field Details

rowComparator

protected final CellComparator rowComparator

Row comparator for the region this query is for

startKey

protected final ExtendedCell startKey

Key to seek to in memstore and StoreFiles

columns

protected final ColumnTracker columns

Keeps track of columns and versions

oldestUnexpiredTS

protected final long oldestUnexpiredTS

The oldest timestamp we are interested in, based on TTL

now

protected final long now

currentRow

protected ExtendedCell currentRow

Row the query is on

Constructor Details

ScanQueryMatcher

protected ScanQueryMatcher(ExtendedCell startKey,
 ScanInfo scanInfo,
 ColumnTracker columns,
 long oldestUnexpiredTS,
 long now)

Method Details

isCellTTLExpired

private static boolean isCellTTLExpired(ExtendedCell cell,
 long oldestTimestamp,
 long now)

Returns true if the cell is expired

preCheck

protected final ScanQueryMatcher.MatchCode preCheck(ExtendedCell cell)

Check before the delete logic.

Returns:

null means continue.

checkDeleted

protected final ScanQueryMatcher.MatchCode checkDeleted(DeleteTracker deletes,
 ExtendedCell cell)

match

public abstract ScanQueryMatcher.MatchCode match(ExtendedCell cell)
                                          throws IOException

Determines if the caller should do one of several things:

• seek/skip to the next row (MatchCode.SEEK_NEXT_ROW)
• seek/skip to the next column (MatchCode.SEEK_NEXT_COL)
• include the current KeyValue (MatchCode.INCLUDE)
• ignore the current KeyValue (MatchCode.SKIP)
• got to the next row (MatchCode.DONE)

Parameters:

cell - KeyValue to check

Returns:

The match code instance.

Throws:

IOException - in case there is an internal consistency problem caused by a data corruption.

getStartKey

public ExtendedCell getStartKey()

Returns the start key

hasNullColumnInQuery

public abstract boolean hasNullColumnInQuery()

Returns whether there is an null column in the query

currentRow

public ExtendedCell currentRow()

Returns a cell represent the current row

clearCurrentRow

public void clearCurrentRow()

Make currentRow() return null.

reset

protected abstract void reset()

setToNewRow

public void setToNewRow(ExtendedCell currentRow)

Set the row when there is change in row

isUserScan

public abstract boolean isUserScan()

moreRowsMayExistAfter

public abstract boolean moreRowsMayExistAfter(ExtendedCell cell)

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.

getKeyForNextColumn

public ExtendedCell getKeyForNextColumn(ExtendedCell cell)

compareKeyForNextRow

public int compareKeyForNextRow(ExtendedCell nextIndexed,
 ExtendedCell currentCell)

Parameters:

nextIndexed - the key of the next entry in the block index (if any)

currentCell - The Cell we're using to calculate the seek key

Returns:

result of the compare between the indexed key and the key portion of the passed cell

compareKeyForNextColumn

public int compareKeyForNextColumn(ExtendedCell nextIndexed,
 ExtendedCell currentCell)

Parameters:

nextIndexed - the key of the next entry in the block index (if any)

currentCell - The Cell we're using to calculate the seek key

Returns:

result of the compare between the indexed key and the key portion of the passed cell

getFilter

public abstract Filter getFilter()

Returns the Filter

getNextKeyHint

public abstract ExtendedCell getNextKeyHint(ExtendedCell cell)
                                     throws IOException

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

Throws:

IOException

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

Throws:

IOException

createStartKeyFromRow

protected static ExtendedCell createStartKeyFromRow(byte[] startRow,
 ScanInfo scanInfo)

getTrackers

protected static Pair<DeleteTracker,ColumnTracker> getTrackers(RegionCoprocessorHost host,
 NavigableSet<byte[]> columns,
 ScanInfo scanInfo,
 long oldestUnexpiredTS,
 Scan userScan)
                                                        throws IOException

Throws:

IOException

checkColumn

static ScanQueryMatcher.MatchCode checkColumn(ColumnTracker columnTracker,
 byte[] bytes,
 int offset,
 int length,
 long ttl,
 byte type,
 boolean ignoreCount)
                                       throws IOException

Throws:

IOException