|
24 | 24 | import com.alipay.oceanbase.rpc.protocol.payload.ObPayload; |
25 | 25 | import com.alipay.oceanbase.rpc.protocol.payload.ResultCodes; |
26 | 26 | import com.alipay.oceanbase.rpc.protocol.payload.impl.ObRowKey; |
| 27 | +import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.ObTableEntityType; |
27 | 28 | import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.aggregation.ObTableAggregationType; |
28 | 29 | import com.alipay.oceanbase.rpc.protocol.payload.impl.execute.query.*; |
29 | 30 | import com.alipay.oceanbase.rpc.stream.ObTableClientQueryAsyncStreamResult; |
@@ -192,14 +193,6 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract |
192 | 193 | } |
193 | 194 | } |
194 | 195 |
|
195 | | - // set correct table group name for hbase |
196 | | - if (tableQuery.isHbaseQuery() |
197 | | - && obTableClient.getTableGroupInverted().containsKey(tableName) |
198 | | - && tableName.equalsIgnoreCase(obTableClient.getTableGroupCache().get( |
199 | | - obTableClient.getTableGroupInverted().get(tableName)))) { |
200 | | - tableName = obTableClient.getTableGroupInverted().get(tableName); |
201 | | - } |
202 | | - |
203 | 196 | // init query stream result |
204 | 197 | AbstractQueryStreamResult streamResult = callable.execute(); |
205 | 198 |
|
@@ -267,7 +260,9 @@ public Map<Long, ObPair<Long, ObTableParam>> initPartitions(ObTableQuery tableQu |
267 | 260 | end[i] = endKey.getObj(i).isMinObj() || endKey.getObj(i).isMaxObj() ? |
268 | 261 | endKey.getObj(i) : endKey.getObj(i).getValue(); |
269 | 262 | } |
270 | | - |
| 263 | + if (this.entityType == ObTableEntityType.HKV && obTableClient.isTableGroupName(tableName)) { |
| 264 | + indexTableName = obTableClient.tryGetTableNameFromTableGroupCache(tableName, false); |
| 265 | + } |
271 | 266 | ObBorderFlag borderFlag = range.getBorderFlag(); |
272 | 267 | List<ObPair<Long, ObTableParam>> pairs = this.obTableClient.getTables(indexTableName, |
273 | 268 | tableQuery, start, borderFlag.isInclusiveStart(), end, borderFlag.isInclusiveEnd(), |
|
0 commit comments