(iotdb) branch master updated: Pipe: Allowed the transfer of logical view alter statement in schema snapshot (#12488)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 4cb0a3965b4 Pipe: Allowed the transfer of logical view alter statement 
in schema snapshot (#12488)
4cb0a3965b4 is described below

commit 4cb0a3965b448ae70e974c7cca29f581911ca628
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Wed May 8 18:16:56 2024 +0800

    Pipe: Allowed the transfer of logical view alter statement in schema 
snapshot (#12488)
---
 .../pipe/event/common/schema/PipeSchemaRegionSnapshotEvent.java   | 2 +-
 .../pipe/extractor/schemaregion/IoTDBSchemaRegionExtractor.java   | 8 +++++++-
 2 files changed, 8 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/schema/PipeSchemaRegionSnapshotEvent.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/schema/PipeSchemaRegionSnapshotEvent.java
index 1b51c7f5568..d647285bdc6 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/schema/PipeSchemaRegionSnapshotEvent.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/schema/PipeSchemaRegionSnapshotEvent.java
@@ -68,7 +68,7 @@ public class PipeSchemaRegionSnapshotEvent extends 
PipeSnapshotEvent {
         PlanNodeType.CREATE_LOGICAL_VIEW.getNodeType(), 
StatementType.CREATE_LOGICAL_VIEW);
     // For logical view
     PLAN_NODE_2_STATEMENT_TYPE_MAP.put(
-        PlanNodeType.ALTER_TIME_SERIES.getNodeType(), 
StatementType.ALTER_TIME_SERIES);
+        PlanNodeType.ALTER_LOGICAL_VIEW.getNodeType(), 
StatementType.ALTER_LOGICAL_VIEW);
   }
 
   public PipeSchemaRegionSnapshotEvent() {
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/schemaregion/IoTDBSchemaRegionExtractor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/schemaregion/IoTDBSchemaRegionExtractor.java
index 914ba7f432b..47b8739147a 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/schemaregion/IoTDBSchemaRegionExtractor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/schemaregion/IoTDBSchemaRegionExtractor.java
@@ -31,8 +31,10 @@ import 
org.apache.iotdb.db.consensus.SchemaRegionConsensusImpl;
 import org.apache.iotdb.db.pipe.agent.PipeAgent;
 import 
org.apache.iotdb.db.pipe.event.common.schema.PipeSchemaRegionSnapshotEvent;
 import 
org.apache.iotdb.db.pipe.event.common.schema.PipeSchemaRegionWritePlanEvent;
+import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNode;
 import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNodeId;
 import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanNodeType;
+import 
org.apache.iotdb.db.queryengine.plan.planner.plan.node.metedata.write.AlterTimeSeriesNode;
 import 
org.apache.iotdb.db.queryengine.plan.planner.plan.node.pipe.PipeOperateSchemaQueueNode;
 import 
org.apache.iotdb.pipe.api.customizer.configuration.PipeExtractorRuntimeConfiguration;
 import org.apache.iotdb.pipe.api.customizer.parameter.PipeParameters;
@@ -119,8 +121,12 @@ public class IoTDBSchemaRegionExtractor extends 
IoTDBNonDataRegionExtractor {
 
   @Override
   protected boolean isTypeListened(final Event event) {
+    final PlanNode planNode = ((PipeSchemaRegionWritePlanEvent) 
event).getPlanNode();
     return listenedTypeSet.contains(
-        ((PipeSchemaRegionWritePlanEvent) event).getPlanNode().getType());
+        (planNode.getType() == PlanNodeType.ALTER_TIME_SERIES
+                && ((AlterTimeSeriesNode) planNode).isAlterView())
+            ? PlanNodeType.ALTER_LOGICAL_VIEW
+            : planNode.getType());
   }
 
   @Override