This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch feat/pipe-logical-backup-sink
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7311c1454f2 Fix logical backup builtin plugin import
add 6355496a6f8 feat: add logical backup dump and restore workflow
No new revisions were added by this update.
Summary of changes:
.../treemodel/manual/IoTDBPipeLogicalBackupIT.java | 298 ++++++
iotdb-client/cli/LOGICAL_BACKUP.md | 138 +++
.../en/org/apache/iotdb/cli/i18n/CliMessages.java | 40 +
.../zh/org/apache/iotdb/cli/i18n/CliMessages.java | 40 +
.../iotdb/tool/pipe/LogicalBackupDumpOptions.java | 275 +++++
.../iotdb/tool/pipe/PipeLogicalBackupTool.java | 1059 +++++++++++++++-----
.../iotdb/tool/pipe/PipeLogicalBackupToolTest.java | 258 ++++-
.../runtime/heartbeat/PipeHeartbeatParser.java | 67 +-
.../protocol/logicalbackup/LogicalBackupSink.java | 97 +-
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 32 +
.../task/subtask/sink/PipeSinkSubtaskManager.java | 32 +-
.../protocol/logicalbackup/LogicalBackupSink.java | 227 ++---
.../source/dataregion/IoTDBDataRegionSource.java | 11 +
.../realtime/PipeRealtimeDataRegionSource.java | 25 +
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 21 +
.../logicalbackup/LogicalBackupSinkTest.java | 105 ++
.../realtime/PipeRealtimeDataRegionSourceTest.java | 20 +
.../iotdb/commons/i18n/LogicalBackupMessages.java | 10 +
.../iotdb/commons/i18n/LogicalBackupMessages.java | 10 +
.../logicalbackup/LogicalBackupArchiveReader.java | 147 ++-
.../sink/logicalbackup/LogicalBackupCatalog.java | 277 +++++
.../sink/logicalbackup/LogicalBackupManifest.java | 4 +
.../sink/logicalbackup/LogicalBackupSettings.java | 199 ++++
.../sink/logicalbackup/LogicalBackupWriter.java | 21 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 51 +-
.../LogicalBackupArchiveReaderTest.java | 105 +-
.../logicalbackup/LogicalBackupSettingsTest.java | 99 ++
.../logicalbackup/LogicalBackupWriterTest.java | 11 +-
.../pipe/source/IoTDBNonDataRegionSourceTest.java | 60 +-
29 files changed, 3260 insertions(+), 479 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/manual/IoTDBPipeLogicalBackupIT.java
create mode 100644 iotdb-client/cli/LOGICAL_BACKUP.md
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/pipe/LogicalBackupDumpOptions.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/logicalbackup/LogicalBackupCatalog.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/logicalbackup/LogicalBackupSettings.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/sink/logicalbackup/LogicalBackupSettingsTest.java
