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

(improvement)(Headless) Support parsing description information and aggregation methods in the map phase. (#969)

Browse Source
This commit is contained in:
lexluo09
2024-05-09 14:07:27 +08:00
committed by GitHub
parent b122053e98
commit 9de188ae7e
2 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
headless/api/src/main/java/com/tencent/supersonic/headless/api/pojo/SchemaElement.java
View File

@@ -32,6 +32,7 @@ public class SchemaElement implements Serializable {
private String dataFormatType; private String dataFormatType;
private double order; private double order;
private int isTag; private int isTag;
private String description;
@Override @Override
public boolean equals(Object o) { public boolean equals(Object o) {

6
headless/server/src/main/java/com/tencent/supersonic/headless/server/utils/DataSetSchemaBuilder.java
View File

@@ -76,7 +76,9 @@ public class DataSetSchemaBuilder {
.type(SchemaElementType.TAG) .type(SchemaElementType.TAG)
.useCnt(metric.getUseCnt()) .useCnt(metric.getUseCnt())
.alias(alias) .alias(alias)
.defaultAgg(metric.getDefaultAgg())
.isTag(metric.getIsTag()) .isTag(metric.getIsTag())
.description(metric.getDescription())
.build(); .build();
tags.add(tagToAdd); tags.add(tagToAdd);
} }
@@ -110,6 +112,7 @@ public class DataSetSchemaBuilder {
.alias(alias) .alias(alias)
.schemaValueMaps(schemaValueMaps) .schemaValueMaps(schemaValueMaps)
.isTag(dim.getIsTag()) .isTag(dim.getIsTag())
.description(dim.getDescription())
.build(); .build();
tags.add(tagToAdd); tags.add(tagToAdd);
} }
@@ -159,6 +162,7 @@ public class DataSetSchemaBuilder {
.alias(alias) .alias(alias)
.schemaValueMaps(schemaValueMaps) .schemaValueMaps(schemaValueMaps)
.isTag(dim.getIsTag()) .isTag(dim.getIsTag())
.description(dim.getDescription())
.build(); .build();
dimensions.add(dimToAdd); dimensions.add(dimToAdd);
} }
@@ -191,6 +195,7 @@ public class DataSetSchemaBuilder {
.useCnt(dim.getUseCnt()) .useCnt(dim.getUseCnt())
.alias(new ArrayList<>(Arrays.asList(dimValueAlias.toArray(new String[0])))) .alias(new ArrayList<>(Arrays.asList(dimValueAlias.toArray(new String[0]))))
.isTag(dim.getIsTag()) .isTag(dim.getIsTag())
.description(dim.getDescription())
.build(); .build();
dimensionValues.add(dimValueToAdd); dimensionValues.add(dimValueToAdd);
} }
@@ -217,6 +222,7 @@ public class DataSetSchemaBuilder {
.defaultAgg(metric.getDefaultAgg()) .defaultAgg(metric.getDefaultAgg())
.dataFormatType(metric.getDataFormatType()) .dataFormatType(metric.getDataFormatType())
.isTag(metric.getIsTag()) .isTag(metric.getIsTag())
.description(metric.getDescription())
.build(); .build();
metrics.add(metricToAdd); metrics.add(metricToAdd);