yujunjun/openspg
1
0
Fork 0
mirror of https://github.com/OpenSPG/openspg.git synced 2025-12-25 22:24:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
baifuyu 2023-12-21 19:23:13 +08:00
parent ba34d44949
commit 6c32d2c9fe
8 changed files with 36 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
builder/core/src/main/java/com/antgroup/openspg/builder/core/operator/fusing/SubGraphFusingImpl.java
View File

@ -8,10 +8,12 @@ import com.antgroup.openspg.builder.model.pipeline.config.fusing.BaseFusingConfi
import com.antgroup.openspg.builder.model.record.BaseAdvancedRecord;
import com.antgroup.openspg.builder.model.record.BaseSPGRecord;
import com.antgroup.openspg.builder.model.record.property.BasePropertyRecord;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.*;
import com.antgroup.openspg.core.schema.model.constraint.Constraint;
import com.antgroup.openspg.core.schema.model.constraint.ConstraintTypeEnum;
import com.antgroup.openspg.core.schema.model.type.SPGTypeRef;
import org.apache.commons.collections4.CollectionUtils;
public class SubGraphFusingImpl implements SubGraphFusing {
@ -62,7 +64,7 @@ public class SubGraphFusingImpl implements SubGraphFusing {
}
private List<BaseSPGRecord> toSPGRecords(BasePropertyRecord propertyRecord) {
return null;
List<String> rawValues = propertyRecord.getRawValues();
}
private void modifyPropertyRecord(

2
builder/model/src/main/java/com/antgroup/openspg/builder/model/pipeline/config/BaseMappingNodeConfig.java
View File

@ -23,7 +23,7 @@ public abstract class BaseMappingNodeConfig extends BaseNodeConfig {
public static class MappingConfig {
private final String source;
private final String target;
private final BaseOperatorConfig operatorConfig;
private final BaseStrategyConfig operatorConfig;
}
@Getter

15
builder/model/src/main/java/com/antgroup/openspg/builder/model/pipeline/config/BaseOperatorConfig.java
View File

@ -1,15 +0,0 @@
package com.antgroup.openspg.builder.model.pipeline.config;
import com.antgroup.openspg.builder.model.pipeline.enums.OperatorTypeEnum;
import com.antgroup.openspg.server.common.model.base.BaseValObj;
import lombok.Getter;
@Getter
public abstract class BaseOperatorConfig extends BaseValObj {
private final OperatorTypeEnum operatorType;
public BaseOperatorConfig(OperatorTypeEnum operatorType) {
this.operatorType = operatorType;
}
}

15
builder/model/src/main/java/com/antgroup/openspg/builder/model/pipeline/config/BaseStrategyConfig.java Normal file
View File

@ -0,0 +1,15 @@
package com.antgroup.openspg.builder.model.pipeline.config;
import com.antgroup.openspg.builder.model.pipeline.enums.StrategyTypeEnum;
import com.antgroup.openspg.server.common.model.base.BaseValObj;
import lombok.Getter;
@Getter
public abstract class BaseStrategyConfig extends BaseValObj {
private final StrategyTypeEnum strategyType;
public BaseStrategyConfig(StrategyTypeEnum strategyType) {
this.strategyType = strategyType;
}
}

8
builder/model/src/main/java/com/antgroup/openspg/builder/model/pipeline/config/fusing/BaseFusingConfig.java
View File

@ -1,17 +1,17 @@
package com.antgroup.openspg.builder.model.pipeline.config.fusing;
import com.antgroup.openspg.builder.model.pipeline.config.BaseOperatorConfig;
import com.antgroup.openspg.builder.model.pipeline.config.BaseStrategyConfig;
import com.antgroup.openspg.builder.model.pipeline.enums.FusingTypeEnum;
import com.antgroup.openspg.builder.model.pipeline.enums.OperatorTypeEnum;
import com.antgroup.openspg.builder.model.pipeline.enums.StrategyTypeEnum;
import lombok.Getter;
@Getter
public abstract class BaseFusingConfig extends BaseOperatorConfig {
public abstract class BaseFusingConfig extends BaseStrategyConfig {
private final FusingTypeEnum fusingType;
public BaseFusingConfig(FusingTypeEnum fusingType) {
super(OperatorTypeEnum.FUSING);
super(StrategyTypeEnum.FUSING);
this.fusingType = fusingType;
}
}

8
builder/model/src/main/java/com/antgroup/openspg/builder/model/pipeline/config/linking/BaseLinkingConfig.java
View File

@ -1,17 +1,17 @@
package com.antgroup.openspg.builder.model.pipeline.config.linking;
import com.antgroup.openspg.builder.model.pipeline.config.BaseOperatorConfig;
import com.antgroup.openspg.builder.model.pipeline.config.BaseStrategyConfig;
import com.antgroup.openspg.builder.model.pipeline.enums.LinkingTypeEnum;
import com.antgroup.openspg.builder.model.pipeline.enums.OperatorTypeEnum;
import com.antgroup.openspg.builder.model.pipeline.enums.StrategyTypeEnum;
import lombok.Getter;
@Getter
public abstract class BaseLinkingConfig extends BaseOperatorConfig {
public abstract class BaseLinkingConfig extends BaseStrategyConfig {
private final LinkingTypeEnum linkingType;
public BaseLinkingConfig(LinkingTypeEnum linkingType) {
super(OperatorTypeEnum.LINKING);
super(StrategyTypeEnum.LINKING);
this.linkingType = linkingType;
}
}

8
builder/model/src/main/java/com/antgroup/openspg/builder/model/pipeline/config/predicating/BasePredictingConfig.java
View File

@ -1,17 +1,17 @@
package com.antgroup.openspg.builder.model.pipeline.config.predicating;
import com.antgroup.openspg.builder.model.pipeline.config.BaseOperatorConfig;
import com.antgroup.openspg.builder.model.pipeline.enums.OperatorTypeEnum;
import com.antgroup.openspg.builder.model.pipeline.config.BaseStrategyConfig;
import com.antgroup.openspg.builder.model.pipeline.enums.StrategyTypeEnum;
import com.antgroup.openspg.builder.model.pipeline.enums.PredictingTypeEnum;
import lombok.Getter;
@Getter
public abstract class BasePredictingConfig extends BaseOperatorConfig {
public abstract class BasePredictingConfig extends BaseStrategyConfig {
private final PredictingTypeEnum predictingType;
public BasePredictingConfig(PredictingTypeEnum predictingType) {
super(OperatorTypeEnum.PREDICTING);
super(StrategyTypeEnum.PREDICTING);
this.predictingType = predictingType;
}
}

2
builder/model/src/main/java/com/antgroup/openspg/builder/model/pipeline/enums/OperatorTypeEnum.java → builder/model/src/main/java/com/antgroup/openspg/builder/model/pipeline/enums/StrategyTypeEnum.java
View File

@ -1,6 +1,6 @@
package com.antgroup.openspg.builder.model.pipeline.enums;
public enum OperatorTypeEnum {
public enum StrategyTypeEnum {
LINKING,
FUSING,
PREDICTING,