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

opt fillTagInfo (#817)

Browse Source
This commit is contained in:
daikon
2024-03-13 21:59:33 +08:00
committed by GitHub
parent 9dcf8c23f2
commit 4267aa2547
2 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
headless/server/src/main/java/com/tencent/supersonic/headless/server/service/impl/DimensionServiceImpl.java
View File

@@ -301,7 +301,8 @@ public class DimensionServiceImpl implements DimensionService {
TagFilter tagFilter = new TagFilter();
tagFilter.setTagDefineType(TagDefineType.DIMENSION);
Map<String, TagResp> keyAndTagMap = tagMetaService.getTags(tagFilter).stream()
.collect(Collectors.toMap(tag -> tag.getModelId() + "_" + tag.getBizName(), tag -> tag));
.collect(Collectors.toMap(tag -> tag.getModelId() + "_" + tag.getBizName(), tag -> tag,
(newTag, oldTag) -> newTag));
if (Objects.nonNull(keyAndTagMap)) {
dimensionResps.stream().forEach(dim -> {
String key = dim.getModelId() + "_" + dim.getBizName();

14
headless/server/src/main/java/com/tencent/supersonic/headless/server/service/impl/TagMetaServiceImpl.java
View File

@@ -252,7 +252,7 @@ public class TagMetaServiceImpl implements TagMetaService {
metrics = metrics.stream().filter(metric -> tagLoadReq.getItemIds().contains(metric.getId()))
.collect(Collectors.toList());
}
metrics.stream().forEach(metric -> {
metrics.parallelStream().forEach(metric -> {
TagReq tagReq = new TagReq();
BeanUtils.copyProperties(metric, tagReq);
tagReq.setId(null);
@@ -261,9 +261,12 @@ public class TagMetaServiceImpl implements TagMetaService {
TagDefineParams tagDefineParams = new TagDefineParams();
tagDefineParams.setExpr(metric.getBizName());
tagDefineParams.setDependencies(new ArrayList<>(Arrays.asList(metric.getId())));
// tagReq.setSensitiveLevel(metric.getSensitiveLevel());
tagReq.setTagDefineParams(tagDefineParams);
create(tagReq, user);
try {
create(tagReq, user);
} catch (Exception e) {
log.info("loadMetricTagBatch, e:{}", e.getMessage());
}
});
return metrics.size();
}
@@ -273,7 +276,7 @@ public class TagMetaServiceImpl implements TagMetaService {
dimensions = dimensions.stream().filter(dim -> tagLoadReq.getItemIds().contains(dim.getId()))
.collect(Collectors.toList());
}
dimensions.stream().forEach(dim -> {
dimensions.parallelStream().forEach(dim -> {
TagReq tagReq = new TagReq();
BeanUtils.copyProperties(dim, tagReq);
tagReq.setId(null);
@@ -282,12 +285,11 @@ public class TagMetaServiceImpl implements TagMetaService {
TagDefineParams tagDefineParams = new TagDefineParams();
tagDefineParams.setExpr(dim.getBizName());
tagDefineParams.setDependencies(new ArrayList<>(Arrays.asList(dim.getId())));
// tagReq.setSensitiveLevel(dim.getSensitiveLevel());
tagReq.setTagDefineParams(tagDefineParams);
try {
create(tagReq, user);
} catch (Exception e) {
log.info("loadDimTagBatch, e:{}", e);
log.info("loadDimTagBatch, e:{}", e.getMessage());
}
});