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
