mirror of
https://github.com/tencentmusic/supersonic.git
synced 2025-12-12 12:37:55 +00:00
[improvement][headless]Add ANY agg operator and remove table name from bizName of field. (#2028)
This commit is contained in:
@@ -1,6 +1,8 @@
|
|||||||
package com.tencent.supersonic.common.pojo.enums;
|
package com.tencent.supersonic.common.pojo.enums;
|
||||||
|
|
||||||
public enum AggOperatorEnum {
|
public enum AggOperatorEnum {
|
||||||
|
ANY("ANY"),
|
||||||
|
|
||||||
MAX("MAX"),
|
MAX("MAX"),
|
||||||
|
|
||||||
MIN("MIN"),
|
MIN("MIN"),
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ public class ColumnSchema {
|
|||||||
|
|
||||||
private FieldType filedType;
|
private FieldType filedType;
|
||||||
|
|
||||||
private AggOperatorEnum agg = AggOperatorEnum.SUM;
|
private AggOperatorEnum agg = AggOperatorEnum.ANY;
|
||||||
|
|
||||||
private String name;
|
private String name;
|
||||||
|
|
||||||
|
|||||||
@@ -163,13 +163,11 @@ public class ModelConverter {
|
|||||||
getIdentifyType(fieldType).name(), columnSchema.getColumnName(), 1);
|
getIdentifyType(fieldType).name(), columnSchema.getColumnName(), 1);
|
||||||
modelDetail.getIdentifiers().add(identify);
|
modelDetail.getIdentifiers().add(identify);
|
||||||
} else if (FieldType.measure.equals(fieldType)) {
|
} else if (FieldType.measure.equals(fieldType)) {
|
||||||
Measure measure = new Measure(columnSchema.getName(),
|
Measure measure = new Measure(columnSchema.getName(), columnSchema.getColumnName(),
|
||||||
modelReq.getBizName() + "_" + columnSchema.getColumnName(),
|
|
||||||
columnSchema.getColumnName(), columnSchema.getAgg().getOperator(), 1);
|
columnSchema.getColumnName(), columnSchema.getAgg().getOperator(), 1);
|
||||||
modelDetail.getMeasures().add(measure);
|
modelDetail.getMeasures().add(measure);
|
||||||
} else {
|
} else {
|
||||||
Dimension dim = new Dimension(columnSchema.getName(),
|
Dimension dim = new Dimension(columnSchema.getName(), columnSchema.getColumnName(),
|
||||||
modelReq.getBizName() + "_" + columnSchema.getColumnName(),
|
|
||||||
columnSchema.getColumnName(),
|
columnSchema.getColumnName(),
|
||||||
DimensionType.valueOf(columnSchema.getFiledType().name()), 1);
|
DimensionType.valueOf(columnSchema.getFiledType().name()), 1);
|
||||||
modelDetail.getDimensions().add(dim);
|
modelDetail.getDimensions().add(dim);
|
||||||
|
|||||||
Reference in New Issue
Block a user