yujunjun/openspg
1
0
Fork 0
mirror of https://github.com/OpenSPG/openspg.git synced 2025-09-18 04:58:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
baifuyu 2023-12-21 20:53:53 +08:00
parent c58a5c3c29
commit 093e78415e
9 changed files with 25 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/OperatorFactory.java → builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/OperatorFactory.java
View File

@ -1,4 +1,4 @@
package com.antgroup.openspg.builder.core.strategy.operator;
package com.antgroup.openspg.builder.core.physical.operator;
import com.antgroup.openspg.builder.core.runtime.BuilderContext;
import com.antgroup.openspg.builder.model.exception.BuilderException;

2
builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/PythonOperatorFactory.java → builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/PythonOperatorFactory.java
View File

@ -1,4 +1,4 @@
package com.antgroup.openspg.builder.core.strategy.operator;
package com.antgroup.openspg.builder.core.physical.operator;
import com.antgroup.openspg.builder.core.runtime.BuilderContext;
import com.antgroup.openspg.builder.model.pipeline.config.OperatorConfig;

6
builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/PythonRecordConvertor.java → builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/PythonRecordConvertor.java
View File

@ -1,8 +1,8 @@
package com.antgroup.openspg.builder.core.strategy.operator;
package com.antgroup.openspg.builder.core.physical.operator;
import com.antgroup.openspg.builder.core.physical.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.core.runtime.BuilderCatalog;
import com.antgroup.openspg.builder.core.strategy.linking.RecordLinking;
import com.antgroup.openspg.builder.core.strategy.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.model.record.BaseAdvancedRecord;
import com.antgroup.openspg.cloudext.interfaces.graphstore.adapter.util.VertexRecordConvertor;
import com.antgroup.openspg.common.util.StringUtils;
@ -13,7 +13,7 @@ import java.util.Map;
public class PythonRecordConvertor {
public static BaseAdvancedRecord toAdvancedRecord(
PythonRecord pythonRecord, RecordLinking recordLinking, BuilderCatalog catalog) {
PythonRecord pythonRecord, RecordLinking recordLinking, BuilderCatalog catalog) {
String recordId = pythonRecord.getId();
if (StringUtils.isBlank(recordId)) {
return null;

2
builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/protocol/InvokeResultWrapper.java → builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/protocol/InvokeResultWrapper.java
View File

@ -11,7 +11,7 @@
* or implied.
*/
package com.antgroup.openspg.builder.core.strategy.operator.protocol;
package com.antgroup.openspg.builder.core.physical.operator.protocol;
import java.util.List;
import lombok.Getter;

2
builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/protocol/PythonRecord.java → builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/protocol/PythonRecord.java
View File

@ -11,7 +11,7 @@
* or implied.
*/
package com.antgroup.openspg.builder.core.strategy.operator.protocol;
package com.antgroup.openspg.builder.core.physical.operator.protocol;
import java.util.Map;
import lombok.Getter;

8
builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/process/UserDefinedExtractProcessor.java
View File

@ -1,10 +1,10 @@
package com.antgroup.openspg.builder.core.physical.process;
import com.antgroup.openspg.builder.core.runtime.BuilderContext;
import com.antgroup.openspg.builder.core.strategy.operator.OperatorFactory;
import com.antgroup.openspg.builder.core.strategy.operator.PythonOperatorFactory;
import com.antgroup.openspg.builder.core.strategy.operator.protocol.InvokeResultWrapper;
import com.antgroup.openspg.builder.core.strategy.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.core.physical.operator.OperatorFactory;
import com.antgroup.openspg.builder.core.physical.operator.PythonOperatorFactory;
import com.antgroup.openspg.builder.core.physical.operator.protocol.InvokeResultWrapper;
import com.antgroup.openspg.builder.core.physical.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.model.exception.BuilderException;
import com.antgroup.openspg.builder.model.pipeline.config.UserDefinedExtractNodeConfig;
import com.antgroup.openspg.builder.model.record.BaseRecord;

10
builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/fusing/impl/OperatorFusing.java
View File

@ -4,11 +4,11 @@ import com.antgroup.openspg.builder.core.runtime.BuilderContext;
import com.antgroup.openspg.builder.core.strategy.fusing.EntityFusing;
import com.antgroup.openspg.builder.core.strategy.linking.RecordLinking;
import com.antgroup.openspg.builder.core.strategy.linking.RecordLinkingImpl;
import com.antgroup.openspg.builder.core.strategy.operator.OperatorFactory;
import com.antgroup.openspg.builder.core.strategy.operator.PythonOperatorFactory;
import com.antgroup.openspg.builder.core.strategy.operator.PythonRecordConvertor;
import com.antgroup.openspg.builder.core.strategy.operator.protocol.InvokeResultWrapper;
import com.antgroup.openspg.builder.core.strategy.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.core.physical.operator.OperatorFactory;
import com.antgroup.openspg.builder.core.physical.operator.PythonOperatorFactory;
import com.antgroup.openspg.builder.core.physical.operator.PythonRecordConvertor;
import com.antgroup.openspg.builder.core.physical.operator.protocol.InvokeResultWrapper;
import com.antgroup.openspg.builder.core.physical.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.model.exception.BuilderException;
import com.antgroup.openspg.builder.model.exception.FusingException;
import com.antgroup.openspg.builder.model.pipeline.config.fusing.OperatorFusingConfig;

8
builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/linking/impl/OperatorLinking.java
View File

@ -2,10 +2,10 @@ package com.antgroup.openspg.builder.core.strategy.linking.impl;
import com.antgroup.openspg.builder.core.runtime.BuilderContext;
import com.antgroup.openspg.builder.core.strategy.linking.PropertyLinking;
import com.antgroup.openspg.builder.core.strategy.operator.OperatorFactory;
import com.antgroup.openspg.builder.core.strategy.operator.PythonOperatorFactory;
import com.antgroup.openspg.builder.core.strategy.operator.protocol.InvokeResultWrapper;
import com.antgroup.openspg.builder.core.strategy.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.core.physical.operator.OperatorFactory;
import com.antgroup.openspg.builder.core.physical.operator.PythonOperatorFactory;
import com.antgroup.openspg.builder.core.physical.operator.protocol.InvokeResultWrapper;
import com.antgroup.openspg.builder.core.physical.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.model.exception.BuilderException;
import com.antgroup.openspg.builder.model.exception.LinkingException;
import com.antgroup.openspg.builder.model.pipeline.config.linking.OperatorLinkingConfig;

10
builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/predicting/impl/OperatorPredicting.java
View File

@ -3,11 +3,11 @@ package com.antgroup.openspg.builder.core.strategy.predicting.impl;
import com.antgroup.openspg.builder.core.runtime.BuilderContext;
import com.antgroup.openspg.builder.core.strategy.linking.RecordLinking;
import com.antgroup.openspg.builder.core.strategy.linking.RecordLinkingImpl;
import com.antgroup.openspg.builder.core.strategy.operator.OperatorFactory;
import com.antgroup.openspg.builder.core.strategy.operator.PythonOperatorFactory;
import com.antgroup.openspg.builder.core.strategy.operator.PythonRecordConvertor;
import com.antgroup.openspg.builder.core.strategy.operator.protocol.InvokeResultWrapper;
import com.antgroup.openspg.builder.core.strategy.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.core.physical.operator.OperatorFactory;
import com.antgroup.openspg.builder.core.physical.operator.PythonOperatorFactory;
import com.antgroup.openspg.builder.core.physical.operator.PythonRecordConvertor;
import com.antgroup.openspg.builder.core.physical.operator.protocol.InvokeResultWrapper;
import com.antgroup.openspg.builder.core.physical.operator.protocol.PythonRecord;
import com.antgroup.openspg.builder.core.strategy.predicting.PropertyPredicting;
import com.antgroup.openspg.builder.model.exception.BuilderException;
import com.antgroup.openspg.builder.model.exception.FusingException;