Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-595 RowFilterInterface.rowProcessed() is called *before* fhe final 

filtering decision is made


git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@650202 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2008-04-21 16:46:31 +00:00
parent 66e545adf0
commit e411d3c61f
3 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGES.txt
View File

@ -12,6 +12,8 @@ Hbase Change Log
HBASE-532 Odd interaction between HRegion.get, HRegion.deleteAll and compactions
HBASE-10 HRegionServer hangs upon exit due to DFSClient Exception
HBASE-598 Loggging, no .log file; all goes into .out
HBASE-595 RowFilterInterface.rowProcessed() is called *before* fhe final
filtering decision is made (Clint Morgan via Stack)
IMPROVEMENTS
HBASE-559 MR example job to count table rows

11
src/java/org/apache/hadoop/hbase/regionserver/HRegion.java
View File

@ -1804,9 +1804,14 @@ public class HRegion implements HConstants {
}
filtered = filter == null ? false : filter.filterNotNull(results);
if (filtered && moreToFollow) {
results.clear();
if (moreToFollow) {
if (filter != null) {
filter.rowProcessed(filtered, key.getRow());
}
if (filtered) {
results.clear();
}
}
} while(filtered && moreToFollow);

3
src/java/org/apache/hadoop/hbase/regionserver/HStoreScanner.java
View File

@ -219,9 +219,6 @@ class HStoreScanner implements InternalScanner {
moreToFollow = chosenTimestamp >= 0;
if (dataFilter != null) {
if (moreToFollow) {
dataFilter.rowProcessed(filtered, chosenRow);
}
if (dataFilter.filterAllRemaining()) {
moreToFollow = false;
}