Skip to content

Commit d77526a

Browse files
maochongxinstuBirdFly
authored andcommitted
add K Q T to scan range column
(cherry picked from commit 687a2cb)
1 parent 39d2388 commit d77526a

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1916,6 +1916,7 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, byte[] start,
19161916
obTableQuery.setIndexName("PRIMARY");
19171917
obTableQuery.sethTableFilter(filter);
19181918
obTableQuery.addKeyRange(obNewRange);
1919+
obTableQuery.setScanRangeColumns("K", "Q", "T");
19191920
return obTableQuery;
19201921
}
19211922

@@ -1941,6 +1942,7 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, final Scan scan) {
19411942
: configuration.getLong(HConstants.HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE_KEY,
19421943
HConstants.DEFAULT_HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE));
19431944
obTableQuery.setObKVParams(buildOBKVParams(scan));
1945+
obTableQuery.setScanRangeColumns("K", "Q", "T");
19441946
return obTableQuery;
19451947
}
19461948

@@ -1957,6 +1959,7 @@ private ObTableQuery buildObTableQuery(final Get get, Collection<byte[]> columnQ
19571959
get.getTimeRange());
19581960
}
19591961
obTableQuery.setObKVParams(buildOBKVParams(get));
1962+
obTableQuery.setScanRangeColumns("K", "Q", "T");
19601963
return obTableQuery;
19611964
}
19621965

0 commit comments

Comments
 (0)