Skip to content

Commit d0d37ab

Browse files
committed
adapt fulltext query
1 parent 19051f1 commit d0d37ab

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientQueryImpl.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -170,6 +170,10 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
170170
// fill a whole range if no range is added explicitly.
171171
if (tableQuery.getKeyRanges().isEmpty()) {
172172
tableQuery.addKeyRange(ObNewRange.getWholeRange());
173+
} else if (tableQuery.isFTSQuery()) {
174+
// Currently, fulltext query only support scan all partitions
175+
tableQuery.getKeyRanges().clear();
176+
tableQuery.addKeyRange(ObNewRange.getWholeRange());
173177
}
174178

175179
// init partitionObTables

0 commit comments

Comments
 (0)