org.apache.hadoop.hbase.regionserver.querymatcher

Class NormalUserScanQueryMatcher

java.lang.Object

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

org.apache.hadoop.hbase.regionserver.querymatcher.UserScanQueryMatcher

org.apache.hadoop.hbase.regionserver.querymatcher.NormalUserScanQueryMatcher

All Implemented Interfaces:

ShipperListener

@InterfaceAudience.Private
public abstract class NormalUserScanQueryMatcher
extends UserScanQueryMatcher

Query matcher for normal user scan.

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 and Description
private DeleteTracker	deletes Keeps track of deletes
private boolean	get True if we are doing a 'Get' Scan.
protected boolean	seePastDeleteMarkers whether time range queries can see rows "behind" a delete

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

filter, hasNullColumn, stopRow, tr

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

columns, currentRow, now, oldestUnexpiredTS, rowComparator, startKey

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	NormalUserScanQueryMatcher(Scan scan, ScanInfo scanInfo, ColumnTracker columns, boolean hasNullColumn, DeleteTracker deletes, long oldestUnexpiredTS, long now)

Method Summary

Modifier and Type	Method and Description
void	beforeShipped() The action that needs to be performed before Shipper.shipped() is performed
static NormalUserScanQueryMatcher	create(Scan scan, ScanInfo scanInfo, ColumnTracker columns, DeleteTracker deletes, boolean hasNullColumn, long oldestUnexpiredTS, long now)
protected boolean	isGet()
ScanQueryMatcher.MatchCode	match(Cell 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)
protected void	reset()

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

create, getFilter, getNextKeyHint, hasNullColumnInQuery, isUserScan, matchColumn, moreRowsMayExistAfter, moreRowsMayExistsAfter

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

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

Methods inherited from class java.lang.Object

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

Field Detail

deletes

private final DeleteTracker deletes

Keeps track of deletes

get

private final boolean get

True if we are doing a 'Get' Scan. Every Get is actually a one-row Scan.

seePastDeleteMarkers

protected final boolean seePastDeleteMarkers

whether time range queries can see rows "behind" a delete

Constructor Detail

NormalUserScanQueryMatcher

protected NormalUserScanQueryMatcher(Scan scan,
                                     ScanInfo scanInfo,
                                     ColumnTracker columns,
                                     boolean hasNullColumn,
                                     DeleteTracker deletes,
                                     long oldestUnexpiredTS,
                                     long now)

Method Detail

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 UserScanQueryMatcher

Throws:

IOException

match

public ScanQueryMatcher.MatchCode match(Cell cell)
                                 throws IOException

Description copied from class: ScanQueryMatcher

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)

Specified by:

match in class ScanQueryMatcher

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.

reset

protected void reset()

Specified by:

reset in class ScanQueryMatcher

isGet

protected boolean isGet()

Specified by:

isGet in class UserScanQueryMatcher

create

public static NormalUserScanQueryMatcher create(Scan scan,
                                                ScanInfo scanInfo,
                                                ColumnTracker columns,
                                                DeleteTracker deletes,
                                                boolean hasNullColumn,
                                                long oldestUnexpiredTS,
                                                long now)
                                         throws IOException

Throws:

IOException