|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.hbase.regionserver.ScanQueryMatcher
public class ScanQueryMatcher
A query matcher that is specifically designed for the scan case.
Nested Class Summary | |
---|---|
static class |
ScanQueryMatcher.MatchCode
match(org.apache.hadoop.hbase.KeyValue) return codes. |
Field Summary | |
---|---|
protected ColumnTracker |
columns
Keeps track of columns and versions |
protected DeleteTracker |
deletes
Keeps track of deletes |
protected Filter |
filter
|
protected long |
oldestStamp
Oldest allowed version stamp for TTL enforcement |
protected boolean |
retainDeletesInOutput
|
protected byte[] |
row
Row the query is on |
protected KeyValue |
startKey
Key to seek to in memstore and StoreFiles |
protected TimeRange |
tr
|
Constructor Summary | |
---|---|
ScanQueryMatcher(Scan scan,
byte[] family,
NavigableSet<byte[]> columns,
long ttl,
KeyValue.KeyComparator rowComparator,
int maxVersions)
|
|
ScanQueryMatcher(Scan scan,
byte[] family,
NavigableSet<byte[]> columns,
long ttl,
KeyValue.KeyComparator rowComparator,
int maxVersions,
boolean retainDeletesInOutput)
Constructs a ScanQueryMatcher for a Scan. |
Method Summary | |
---|---|
KeyValue |
getKeyForNextColumn(KeyValue kv)
|
KeyValue |
getKeyForNextRow(KeyValue kv)
|
KeyValue |
getNextKeyHint(KeyValue kv)
|
ScanQueryMatcher.MatchCode |
getNextRowOrNextColumn(byte[] bytes,
int offset,
int qualLength)
|
KeyValue |
getStartKey()
|
protected boolean |
isDelete(byte type)
|
protected boolean |
isExpired(long timestamp)
|
ScanQueryMatcher.MatchCode |
match(KeyValue kv)
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) |
boolean |
moreRowsMayExistAfter(KeyValue kv)
|
void |
reset()
|
void |
setRow(byte[] row)
Set current row |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected TimeRange tr
protected Filter filter
protected DeleteTracker deletes
protected boolean retainDeletesInOutput
protected ColumnTracker columns
protected KeyValue startKey
protected long oldestStamp
protected byte[] row
Constructor Detail |
---|
public ScanQueryMatcher(Scan scan, byte[] family, NavigableSet<byte[]> columns, long ttl, KeyValue.KeyComparator rowComparator, int maxVersions, boolean retainDeletesInOutput)
scan
- family
- columns
- ttl
- rowComparator
- public ScanQueryMatcher(Scan scan, byte[] family, NavigableSet<byte[]> columns, long ttl, KeyValue.KeyComparator rowComparator, int maxVersions)
Method Detail |
---|
public ScanQueryMatcher.MatchCode match(KeyValue kv)
kv
- KeyValue to check
public ScanQueryMatcher.MatchCode getNextRowOrNextColumn(byte[] bytes, int offset, int qualLength)
public boolean moreRowsMayExistAfter(KeyValue kv)
public void setRow(byte[] row)
row
- public void reset()
protected boolean isDelete(byte type)
protected boolean isExpired(long timestamp)
public KeyValue getStartKey()
public KeyValue getNextKeyHint(KeyValue kv)
public KeyValue getKeyForNextColumn(KeyValue kv)
public KeyValue getKeyForNextRow(KeyValue kv)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |