Skip to content

Commit 53ee83f

Browse files
authored
Merge pull request #199 from shenyunlong/fix_reverse_scan
[Fix] reverse scan with include stop row does not work
2 parents 62de7c1 + 22cec21 commit 53ee83f

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/main/java/com/alipay/oceanbase/hbase/OHTable.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1931,11 +1931,11 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, final Scan scan) {
19311931
filter.setOffsetPerRowPerCf(scan.getRowOffsetPerColumnFamily());
19321932
}
19331933
if (scan.isReversed()) {
1934-
obTableQuery = buildObTableQuery(filter, scan.getStopRow(), false, scan.getStartRow(),
1935-
true, true, ts);
1934+
obTableQuery = buildObTableQuery(filter, scan.getStopRow(), scan.includeStopRow(), scan.getStartRow(),
1935+
scan.includeStartRow(), true, ts);
19361936
} else {
1937-
obTableQuery = buildObTableQuery(filter, scan.getStartRow(), true, scan.getStopRow(),
1938-
false, false, ts);
1937+
obTableQuery = buildObTableQuery(filter, scan.getStartRow(), scan.includeStartRow(), scan.getStopRow(),
1938+
scan.includeStopRow(), false, ts);
19391939
}
19401940
obTableQuery.setBatchSize(scan.getBatch());
19411941
obTableQuery.setLimit(scan.getLimit());

0 commit comments

Comments
 (0)