org.apache.hadoop.hbase.regionserver.querymatcher

Class StripeCompactionScanQueryMatcher

java.lang.Object

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

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

org.apache.hadoop.hbase.regionserver.querymatcher.DropDeletesCompactionScanQueryMatcher

org.apache.hadoop.hbase.regionserver.querymatcher.StripeCompactionScanQueryMatcher

All Implemented Interfaces:

ShipperListener

@InterfaceAudience.Private
public class StripeCompactionScanQueryMatcher
extends DropDeletesCompactionScanQueryMatcher

Query matcher for stripe compaction if range drop deletes is used.

Nested Class Summary

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

ScanQueryMatcher.MatchCode

Field Summary

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

earliestPutTs, timeToPurgeDeletes

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

deletes, keepDeletedCells, maxReadPointToTrackVersions

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

columns, currentRow, now, oldestUnexpiredTS, rowComparator, startKey

Constructor Summary

Constructors

Constructor and Description
StripeCompactionScanQueryMatcher(ScanInfo scanInfo, DeleteTracker deletes, ColumnTracker columns, long readPointToUse, long earliestPutTs, long oldestUnexpiredTS, long now, byte[] dropDeletesFromRow, byte[] dropDeletesToRow)

Method Summary

Modifier and Type	Method and Description
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.DropDeletesCompactionScanQueryMatcher

tryDropDelete

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

beforeShipped, create, getFilter, getNextKeyHint, hasNullColumnInQuery, isUserScan, moreRowsMayExistAfter, trackDelete

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

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

Constructor Detail

StripeCompactionScanQueryMatcher

public StripeCompactionScanQueryMatcher(ScanInfo scanInfo,
                                        DeleteTracker deletes,
                                        ColumnTracker columns,
                                        long readPointToUse,
                                        long earliestPutTs,
                                        long oldestUnexpiredTS,
                                        long now,
                                        byte[] dropDeletesFromRow,
                                        byte[] dropDeletesToRow)

Method Detail

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

Overrides:

reset in class CompactionScanQueryMatcher