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

[minor](fe) simplfy some code in HMSExternalTable (#32344) (#38675)

Browse Source 
bp #32344

Co-authored-by: DuRipeng <453243496@qq.com>
This commit is contained in:
Mingyu Chen
2024-08-02 11:27:10 +08:00
committed by GitHub
parent 1d982ada45
commit 4f2ca43917
1 changed files with 3 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalTable.java
View File

@ -543,8 +543,7 @@ public class HMSExternalTable extends ExternalTable implements MTMVRelatedTableI
public boolean hasColumnStatistics(String colName) {
Map<String, String> parameters = remoteTable.getParameters();
return parameters.keySet().stream()
.filter(k -> k.startsWith(SPARK_COL_STATS + colName + ".")).findAny().isPresent();
return parameters.keySet().stream().anyMatch(k -> k.startsWith(SPARK_COL_STATS + colName + "."));
}
public boolean fillColumnStatistics(String colName, Map<StatsType, String> statsTypes, Map<String, String> stats) {
@ -556,12 +555,8 @@ public class HMSExternalTable extends ExternalTable implements MTMVRelatedTableI
Map<String, String> parameters = remoteTable.getParameters();
for (StatsType type : statsTypes.keySet()) {
String key = SPARK_COL_STATS + colName + MAP_SPARK_STATS_TO_DORIS.getOrDefault(type, "-");
if (parameters.containsKey(key)) {
stats.put(statsTypes.get(type), parameters.get(key));
} else {
// should not happen, spark would have all type (except histogram)
stats.put(statsTypes.get(type), "NULL");
}
// 'NULL' should not happen, spark would have all type (except histogram)
stats.put(statsTypes.get(type), parameters.getOrDefault(key, "NULL"));
}
return true;
}