topdog/supersonic
1
0
Fork 0
mirror of https://github.com/tencentmusic/supersonic.git synced 2025-12-11 12:07:42 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

(improvement)(Headless) fix field parse error (#669)

Browse Source
This commit is contained in:
jipeli
2024-01-19 23:06:11 +08:00
committed by GitHub
parent 566321895e
commit add74b9589
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
headless/server/src/main/java/com/tencent/supersonic/headless/server/manager/SemanticSchemaManager.java
View File

@@ -131,19 +131,13 @@ public class SemanticSchemaManager {
datasource.setTimePartType(TimePartType.of(d.getModelSourceTypeEnum().name())); datasource.setTimePartType(TimePartType.of(d.getModelSourceTypeEnum().name()));
} }
if (Objects.nonNull(d.getFields()) && !CollectionUtils.isEmpty(d.getFields())) { if (Objects.nonNull(d.getFields()) && !CollectionUtils.isEmpty(d.getFields())) {
Set<String> dimensions = datasource.getDimensions().stream().map(dd -> dd.getBizName())
.collect(Collectors.toSet());
Set<String> measures = datasource.getMeasures().stream().map(mm -> mm.getName()) Set<String> measures = datasource.getMeasures().stream().map(mm -> mm.getName())
.collect(Collectors.toSet()); .collect(Collectors.toSet());
Set<String> identifiers = datasource.getIdentifiers().stream().map(ii -> ii.getName())
.collect(Collectors.toSet());
for (Field f : d.getFields()) { for (Field f : d.getFields()) {
if (dimensions.contains(f.getFieldName()) || measures.contains(f.getFieldName()) if (!measures.contains(f.getFieldName())) {
|| identifiers.contains(f.getFieldName())) { datasource.getMeasures()
continue; .add(Measure.builder().expr(f.getFieldName()).name(f.getFieldName()).agg("").build());
} }
datasource.getMeasures()
.add(Measure.builder().expr(f.getFieldName()).name(f.getFieldName()).agg("").build());
} }
} }
return datasource; return datasource;