This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-meta-sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from dbcb21a5d5a Revert "Pipe Meta: Changed the default sync inclusion to
data.insert (#12083)"
add 4793e02a459 rename
No new revisions were added by this update.
Summary of changes:
.../dataregion/DataExecutionVisitor.java | 5 +-
.../schemaregion/SchemaExecutionVisitor.java | 22 +++----
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 4 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 5 +-
.../schemaregion/PipeSchemaNodeFilter.java | 4 +-
.../schemaregion/SchemaNodeListeningQueue.java | 12 ++--
.../impl/DataNodeInternalRPCServiceImpl.java | 10 ++--
.../execution/executor/RegionWriteExecutor.java | 50 ++++++++--------
.../plan/planner/LogicalPlanVisitor.java | 4 +-
.../plan/planner/plan/node/PlanNodeType.java | 21 +++----
.../plan/planner/plan/node/PlanVisitor.java | 16 +++---
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 2 +-
.../plan/node/pipe/PipeEnrichedInsertNode.java | 8 +--
...Node.java => PipeEnrichedNonWritePlanNode.java} | 60 +++++++++----------
...emaNode.java => PipeEnrichedWritePlanNode.java} | 67 +++++++++++-----------
...ueNode.java => PipeOperateSchemaQueueNode.java} | 24 ++++----
.../db/trigger/executor/TriggerFireVisitor.java | 2 +-
.../extractor/SchemaNodeListeningQueueTest.java | 9 ++-
.../node/pipe/PipeEnrichedInsertNodeSerdeTest.java | 3 +-
... => PipeEnrichedNonWritePlanNodeSerdeTest.java} | 12 ++--
...ava => PipeEnrichedWritePlanNodeSerdeTest.java} | 12 ++--
21 files changed, 177 insertions(+), 175 deletions(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/{PipeEnrichedConfigSchemaNode.java
=> PipeEnrichedNonWritePlanNode.java} (72%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/{PipeEnrichedWriteSchemaNode.java
=> PipeEnrichedWritePlanNode.java} (73%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/{OperateSchemaQueueNode.java
=> PipeOperateSchemaQueueNode.java} (77%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/pipe/{PipeEnrichedConfigSchemaNodeSerdeTest.java
=> PipeEnrichedNonWritePlanNodeSerdeTest.java} (86%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/pipe/{PipeEnrichedWriteSchemaNodeSerdeTest.java
=> PipeEnrichedWritePlanNodeSerdeTest.java} (85%)