Package 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

@Private
public class StripeCompactionScanQueryMatcher
extends DropDeletesCompactionScanQueryMatcher

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	StripeCompactionScanQueryMatcher.DropDeletesInOutput

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

ScanQueryMatcher.MatchCode

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	dropDeletesFromRow
private StripeCompactionScanQueryMatcher.DropDeletesInOutput	dropDeletesInOutput
private final byte[]	dropDeletesToRow

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	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	Description
private boolean	entered()
private boolean	left()
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)
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

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 Details

dropDeletesFromRow

private final byte[] dropDeletesFromRow

dropDeletesToRow

private final byte[] dropDeletesToRow

dropDeletesInOutput

private StripeCompactionScanQueryMatcher.DropDeletesInOutput dropDeletesInOutput

Constructor Details

StripeCompactionScanQueryMatcher

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

Method Details

match

public ScanQueryMatcher.MatchCode match(ExtendedCell 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.

entered

private boolean entered()

left

private boolean left()

reset

protected void reset()

Overrides:

reset in class CompactionScanQueryMatcher