(iotdb) branch pipe-meta-sync updated (d5b20ab5218 -> 25db924dab4)

[ta...@apache.org]

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

tanxinyu pushed a change to branch pipe-meta-sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from d5b20ab5218 Pipe Schema: fixed NPE problem (#11801)
     add 25db924dab4 Pipe Schema: schema events (#11763)

No new revisions were added by this update.

Summary of changes:
 .../pipe/event/PipeConfigRegionSnapshotEvent.java  |  44 ++++++
 .../pipe/event/PipeWriteConfigPlanEvent.java       |  50 +++++++
 .../PipeConfigNodeSnapshotResourceManager.java     |  27 ++--
 .../db/pipe/agent/runtime/PipeRuntimeAgent.java    |   9 ++
 ...IoTDBThriftSyncPipeTransferBatchReqBuilder.java |   2 +-
 .../builder/PipeTransferBatchReqBuilder.java       |   2 +-
 .../protocol/airgap/IoTDBAirGapConnector.java      |   2 +-
 .../thrift/async/IoTDBThriftAsyncConnector.java    |   2 +-
 .../PipeTransferTabletBatchEventHandler.java       |   2 +-
 .../PipeTransferTabletInsertionEventHandler.java   |   2 +-
 .../thrift/sync/IoTDBThriftSyncConnector.java      |   2 +-
 .../protocol/websocket/WebSocketConnector.java     |   2 +-
 .../websocket/WebSocketConnectorServer.java        |   2 +-
 .../protocol/writeback/WriteBackConnector.java     |   2 +-
 .../event/common/heartbeat/PipeHeartbeatEvent.java |  10 +-
 .../db/pipe/event/common/row/PipeRowCollector.java |   2 +-
 .../schema/PipeSchemaRegionSnapshotEvent.java      |  44 ++++++
 .../common/schema/PipeWriteSchemaPlanEvent.java    |  50 +++++++
 .../tablet/PipeInsertNodeTabletInsertionEvent.java |   2 +-
 .../common/tablet/PipeRawTabletInsertionEvent.java |   2 +-
 .../tablet/TabletInsertionDataContainer.java       |   2 +-
 .../common/tsfile/PipeTsFileInsertionEvent.java    |   2 +-
 .../tsfile/TsFileInsertionDataContainer.java       |   2 +-
 .../db/pipe/event/realtime/PipeRealtimeEvent.java  |   2 +-
 .../realtime/PipeRealtimeDataRegionExtractor.java  |   2 +-
 .../realtime/assigner/DisruptorQueue.java          |   2 +-
 .../realtime/assigner/PipeDataRegionAssigner.java  |   2 +-
 .../iotdb/db/pipe/metric/PipeDataNodeMetrics.java  |   1 +
 .../PipeDataNodeSnapshotResourceManager.java}      |  45 +++---
 .../pipe/task/connection/PipeEventCollector.java   |   4 +-
 .../db/pipe/task/subtask/PipeDataNodeSubtask.java  |   8 +-
 .../subtask/connector/PipeConnectorSubtask.java    |   8 +-
 .../connector/PipeConnectorSubtaskManager.java     |   2 +-
 .../PipeDataNodeSnapshotResourceManagerTest.java   | 117 +++++++++++++++
 .../iotdb/commons}/pipe/event/EnrichedEvent.java   |  19 ++-
 .../commons/pipe/event/PipeSnapshotEvent.java      |  92 ++++++++++++
 .../commons/pipe/event/PipeWritePlanEvent.java     |  79 ++++++++++
 .../pipe/metric/PipeEventCommitMetrics.java        |  11 +-
 .../progress/committer/PipeEventCommitManager.java |  11 +-
 .../progress/committer/PipeEventCommitter.java     |   4 +-
 .../pipe/resource/PipeSnapshotResourceManager.java | 159 +++++++++++++++++++++
 41 files changed, 740 insertions(+), 94 deletions(-)
 create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/event/PipeConfigRegionSnapshotEvent.java
 create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/event/PipeWriteConfigPlanEvent.java
 copy iotdb-client/session/src/main/java/org/apache/iotdb/session/DummyNodesSupplier.java => iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/snapshot/PipeConfigNodeSnapshotResourceManager.java (51%)
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/schema/PipeSchemaRegionSnapshotEvent.java
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/schema/PipeWriteSchemaPlanEvent.java
 copy iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/transition/DFAWildcardTransition.java => datanode/src/main/java/org/apache/iotdb/db/pipe/resource/snapshot/PipeDataNodeSnapshotResourceManager.java} (50%)
 create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/resource/PipeDataNodeSnapshotResourceManagerTest.java
 rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db => node-commons/src/main/java/org/apache/iotdb/commons}/pipe/event/EnrichedEvent.java (93%)
 create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/event/PipeSnapshotEvent.java
 create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/event/PipeWritePlanEvent.java
 rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db => node-commons/src/main/java/org/apache/iotdb/commons}/pipe/metric/PipeEventCommitMetrics.java (94%)
 rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db => node-commons/src/main/java/org/apache/iotdb/commons}/pipe/progress/committer/PipeEventCommitManager.java (90%)
 rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db => node-commons/src/main/java/org/apache/iotdb/commons}/pipe/progress/committer/PipeEventCommitter.java (96%)
 create mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/PipeSnapshotResourceManager.java