You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by er...@apache.org on 2022/08/26 01:57:45 UTC
[iotdb] branch master updated (8a7645c7c6 -> 968d8fe0fb)
This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8a7645c7c6 [IOTDB-4185] Prevent RatisConsensus Start Race (#7115)
add 968d8fe0fb [IOTDB-3465] ext-pipe support DeletionPipeData. (#6947)
No new revisions were added by this update.
Summary of changes:
example/ext-pipe-plugin-example/pom.xml | 6 +-
.../iotdb/extpipe/ExtPipeSinkWriterImpl.java | 56 +++----
...ipe.external.api.IExternalPipeSinkWriterFactory | 1 +
.../pipe/external/api/IExternalPipeSinkWriter.java | 94 +++++++-----
.../org/apache/iotdb/commons/path/PartialPath.java | 66 +++++---
.../apache/iotdb/commons/path/PartialPathTest.java | 142 ++++++++++++++++-
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 2 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 2 +-
.../iotdb/db/sync/datasource/AbstractOpBlock.java | 27 ++--
.../iotdb/db/sync/datasource/DeletionOpBlock.java | 106 +++++++++++++
.../iotdb/db/sync/datasource/PipeOpManager.java | 166 +++++++++++++++++---
.../iotdb/db/sync/datasource/PipeOpSgManager.java | 37 ++++-
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 16 +-
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 170 +++++++++++++++------
.../db/sync/externalpipe/ExtPipePluginManager.java | 166 +++++++++++++-------
.../externalpipe/operation/DeleteOperation.java | 78 ++++++++++
.../externalpipe/operation/InsertOperation.java | 12 +-
.../db/sync/externalpipe/operation/Operation.java | 37 ++++-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 20 ++-
.../db/sync/sender/manager/TsFileSyncManager.java | 4 +-
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 4 +-
.../db/sync/datasource/DeletionOpBlockTest.java | 62 ++++++++
.../db/sync/datasource/PipeOpManagerTest.java | 70 ++++++++-
25 files changed, 1067 insertions(+), 281 deletions(-)
create mode 100644 example/ext-pipe-plugin-example/src/main/resources/META-INF/services/org.apache.iotdb.pipe.external.api.IExternalPipeSinkWriterFactory
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/datasource/DeletionOpBlock.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/externalpipe/operation/DeleteOperation.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/datasource/DeletionOpBlockTest.java