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

HBASE-1190 TableInputFormatBase with row filters scan too far 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/hbase/trunk@742146 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Andrew Kyle Purtell 2009-02-08 19:32:54 +00:00
parent 3156618b75
commit 0e83a2224c
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGES.txt
View File

@ -19,6 +19,8 @@ Release 0.20.0 - Unreleased
(K M via Jean-Daniel Cryans) (K M via Jean-Daniel Cryans)
HBASE-1175 HBA administrative tools do not work when specifying region HBASE-1175 HBA administrative tools do not work when specifying region
name (Jonathan Gray via Andrew Purtell) name (Jonathan Gray via Andrew Purtell)
HBASE-1190 TableInputFormatBase with row filters scan too far (Dave
Latham via Andrew Purtell)
IMPROVEMENTS IMPROVEMENTS
HBASE-1089 Add count of regions on filesystem to master UI; add percentage HBASE-1089 Add count of regions on filesystem to master UI; add percentage

3
src/java/org/apache/hadoop/hbase/mapred/TableInputFormatBase.java
View File

@ -32,6 +32,7 @@ import org.apache.hadoop.hbase.client.Scanner;
import org.apache.hadoop.hbase.filter.RowFilterInterface; import org.apache.hadoop.hbase.filter.RowFilterInterface;
import org.apache.hadoop.hbase.filter.RowFilterSet; import org.apache.hadoop.hbase.filter.RowFilterSet;
import org.apache.hadoop.hbase.filter.StopRowFilter; import org.apache.hadoop.hbase.filter.StopRowFilter;
import org.apache.hadoop.hbase.filter.WhileMatchRowFilter;
import org.apache.hadoop.hbase.io.ImmutableBytesWritable; import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
import org.apache.hadoop.hbase.io.RowResult; import org.apache.hadoop.hbase.io.RowResult;
import org.apache.hadoop.hbase.util.Writables; import org.apache.hadoop.hbase.util.Writables;
@ -102,7 +103,7 @@ implements InputFormat<ImmutableBytesWritable, RowResult> {
if (trrRowFilter != null) { if (trrRowFilter != null) {
final Set<RowFilterInterface> rowFiltersSet = final Set<RowFilterInterface> rowFiltersSet =
new HashSet<RowFilterInterface>(); new HashSet<RowFilterInterface>();
rowFiltersSet.add(new StopRowFilter(endRow)); rowFiltersSet.add(new WhileMatchRowFilter(new StopRowFilter(endRow)));
rowFiltersSet.add(trrRowFilter); rowFiltersSet.add(trrRowFilter);
this.scanner = this.htable.getScanner(trrInputColumns, startRow, this.scanner = this.htable.getScanner(trrInputColumns, startRow,
new RowFilterSet(RowFilterSet.Operator.MUST_PASS_ALL, new RowFilterSet(RowFilterSet.Operator.MUST_PASS_ALL,