diff --git a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/OperatorFactory.java b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/OperatorFactory.java
similarity index 87%
rename from builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/OperatorFactory.java
rename to builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/OperatorFactory.java
index 78a282ba..1202b705 100644
--- a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/OperatorFactory.java
+++ b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/OperatorFactory.java
@@ -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;
diff --git a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/PythonOperatorFactory.java b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/PythonOperatorFactory.java
similarity index 98%
rename from builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/PythonOperatorFactory.java
rename to builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/PythonOperatorFactory.java
index 0b1b352c..bab7bb46 100644
--- a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/PythonOperatorFactory.java
+++ b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/PythonOperatorFactory.java
@@ -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;
diff --git a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/PythonRecordConvertor.java b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/PythonRecordConvertor.java
similarity index 87%
rename from builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/PythonRecordConvertor.java
rename to builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/PythonRecordConvertor.java
index 75d6b9ed..da733f7e 100644
--- a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/PythonRecordConvertor.java
+++ b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/PythonRecordConvertor.java
@@ -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;
diff --git a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/protocol/InvokeResultWrapper.java b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/protocol/InvokeResultWrapper.java
similarity index 92%
rename from builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/protocol/InvokeResultWrapper.java
rename to builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/protocol/InvokeResultWrapper.java
index 8d8ce382..f621673b 100644
--- a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/protocol/InvokeResultWrapper.java
+++ b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/protocol/InvokeResultWrapper.java
@@ -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;
diff --git a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/protocol/PythonRecord.java b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/protocol/PythonRecord.java
similarity index 92%
rename from builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/protocol/PythonRecord.java
rename to builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/protocol/PythonRecord.java
index 4688f96f..3422598d 100644
--- a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/operator/protocol/PythonRecord.java
+++ b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/operator/protocol/PythonRecord.java
@@ -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;
diff --git a/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/process/UserDefinedExtractProcessor.java b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/process/UserDefinedExtractProcessor.java
index 5c821faf..70772e2a 100644
--- a/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/process/UserDefinedExtractProcessor.java
+++ b/builder/core/src/main/java/com/antgroup/openspg/builder/core/physical/process/UserDefinedExtractProcessor.java
@@ -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;
diff --git a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/fusing/impl/OperatorFusing.java b/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/fusing/impl/OperatorFusing.java
index 424893bd..0814ea38 100644
--- a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/fusing/impl/OperatorFusing.java
+++ b/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/fusing/impl/OperatorFusing.java
@@ -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;
diff --git a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/linking/impl/OperatorLinking.java b/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/linking/impl/OperatorLinking.java
index 91c1fe76..d84153de 100644
--- a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/linking/impl/OperatorLinking.java
+++ b/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/linking/impl/OperatorLinking.java
@@ -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;
diff --git a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/predicting/impl/OperatorPredicting.java b/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/predicting/impl/OperatorPredicting.java
index a44fdbc5..92aec9a5 100644
--- a/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/predicting/impl/OperatorPredicting.java
+++ b/builder/core/src/main/java/com/antgroup/openspg/builder/core/strategy/predicting/impl/OperatorPredicting.java
@@ -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;