database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](iceberg) iceberg hms support hive1 (#30985)

Browse Source
This commit is contained in:
wangtao
2024-02-18 15:27:32 +08:00
committed by yiguolei
parent 6e4f76de54
commit a7037df9a1
1 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
fe/fe-core/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
View File

@ -1819,12 +1819,19 @@ public class HiveMetaStoreClient implements IMetaStoreClient, AutoCloseable {
@Override
public List<Table> getTableObjectsByName(String catName, String dbName,
List<String> tableNames) throws TException {
GetTablesRequest req = new GetTablesRequest(dbName);
req.setCatName(catName);
req.setTblNames(tableNames);
req.setCapabilities(version);
List<Table> tabs = client.get_table_objects_by_name_req(req).getTables();
return deepCopyTables(filterHook.filterTables(tabs));
List<Table> tabs = new ArrayList<>();
if (hiveVersion == HiveVersion.V1_0 || hiveVersion == HiveVersion.V2_0) {
for (String tableName: tableNames) {
tabs.add(client.get_table(dbName, tableName));
}
} else {
GetTablesRequest req = new GetTablesRequest(dbName);
req.setCatName(catName);
req.setTblNames(tableNames);
req.setCapabilities(version);
tabs = client.get_table_objects_by_name_req(req).getTables();
}
return deepCopyTables(filterHook.filterTables(tabs));
}
@Override