You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/08/26 03:15:59 UTC
[iotdb] branch master updated (968d8fe0fb -> 530d6f780f)

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

haonan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from 968d8fe0fb [IOTDB-3465] ext-pipe support DeletionPipeData. (#6947)
     add 530d6f780f [IOTDB-4228] PipeSink execution process in new standalone (#7123)

No new revisions were added by this update.

Summary of changes:
 .../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java   | 99 ++++++++++++++++++++++
 .../apache/iotdb/commons/conf/IoTDBConstant.java   |  1 +
 .../iotdb/db/localconfignode/LocalConfigNode.java  | 34 ++++++++
 .../db/mpp/common/header/ColumnHeaderConstant.java | 14 ++-
 .../db/mpp/common/header/DatasetHeaderFactory.java |  4 +
 .../plan/execution/config/ConfigTaskVisitor.java   |  8 ++
 .../config/executor/ClusterConfigTaskExecutor.java | 12 ++-
 .../config/executor/IConfigTaskExecutor.java       | 13 +--
 .../executor/StandaloneConfigTaskExecutor.java     | 50 ++++++-----
 .../config/sys/sync/CreatePipeSinkTask.java        |  4 +-
 .../config/sys/sync/DropPipeSinkTask.java          |  4 +-
 .../execution/config/sys/sync/DropPipeTask.java    |  2 +-
 .../config/sys/sync/ShowPipeSinkTask.java          | 35 +++++++-
 .../iotdb/db/mpp/plan/parser/ASTVisitor.java       |  2 +
 .../sys/sync/CreatePipeSinkStatement.java          | 38 +++++++++
 .../java/org/apache/iotdb/db/sync/SyncService.java | 10 +++
 .../iotdb/db/sync/common/ISyncInfoFetcher.java     |  5 +-
 .../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 11 +++
 .../org/apache/iotdb/db/sync/common/SyncInfo.java  | 17 ++++
 .../db/sync/common/persistence/SyncLogReader.java  | 13 +--
 .../db/sync/common/persistence/SyncLogWriter.java  | 11 +++
 .../db/sync/sender/pipe/ExternalPipeSink.java      | 20 +++++
 .../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java   | 23 +++++
 .../apache/iotdb/db/sync/sender/pipe/PipeSink.java |  5 +-
 .../apache/iotdb/db/utils/sync/SyncPipeUtil.java   | 18 ++++
 25 files changed, 411 insertions(+), 42 deletions(-)
 create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java