Skip to content

Commit 687a2cb

Browse files
committed
add K Q T to scan range column
1 parent 8936673 commit 687a2cb

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
@@ -1927,6 +1927,7 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, byte[] start,
19271927
obTableQuery.setIndexName("PRIMARY");
19281928
obTableQuery.sethTableFilter(filter);
19291929
obTableQuery.addKeyRange(obNewRange);
1930+
obTableQuery.setScanRangeColumns("K", "Q", "T");
19301931
return obTableQuery;
19311932
}
19321933

@@ -1953,6 +1954,7 @@ private ObTableQuery buildObTableQuery(ObHTableFilter filter, final Scan scan) {
19531954
: configuration.getLong(HConstants.HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE_KEY,
19541955
HConstants.DEFAULT_HBASE_CLIENT_SCANNER_MAX_RESULT_SIZE));
19551956
obTableQuery.setObKVParams(buildOBKVParams(scan));
1957+
obTableQuery.setScanRangeColumns("K", "Q", "T");
19561958
return obTableQuery;
19571959
}
19581960

@@ -1978,6 +1980,7 @@ private ObTableQuery buildObTableQuery(final Get get, Collection<byte[]> columnQ
19781980
get.getTimeRange());
19791981
}
19801982
obTableQuery.setObKVParams(buildOBKVParams(get));
1983+
obTableQuery.setScanRangeColumns("K", "Q", "T");
19811984
return obTableQuery;
19821985
}
19831986

0 commit comments

Comments
 (0)