[iotdb] branch master updated (e7b130e373 -> 43d7f28413)

[ne...@apache.org]

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

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


    from e7b130e373 [IOTDB-4216] Fix execute create aligned timeseries but a non-aligned timeseries created (#7101)
     add 43d7f28413 [IOTDB-4130] Implement sync module in the sender in the ASTVisitor to IConfigTaskExecutor section and development of SHOW PIPESINKTYPE  (#7088)

No new revisions were added by this update.

Summary of changes:
 .../db/mpp/common/header/ColumnHeaderConstant.java |  4 ++
 .../db/mpp/common/header/DatasetHeaderFactory.java |  4 ++
 .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java  | 11 +++
 .../plan/execution/config/ConfigTaskVisitor.java   | 51 ++++++++++++++
 .../config/executor/ClusterConfigTaskExecutor.java | 80 ++++++++++++++++++++++
 .../config/executor/IConfigTaskExecutor.java       | 16 +++++
 .../executor/StandaloneConfigTaskExecutor.java     | 80 ++++++++++++++++++++++
 .../sync/CreatePipeSinkTask.java}                  | 14 ++--
 .../{MergeTask.java => sync/CreatePipeTask.java}   | 14 ++--
 .../sync/DropPipeSinkTask.java}                    | 14 ++--
 .../sys/{MergeTask.java => sync/DropPipeTask.java} | 14 ++--
 .../sync/ShowPipeSinkTask.java}                    | 14 ++--
 .../sys/{MergeTask.java => sync/ShowPipeTask.java} | 14 ++--
 .../{MergeTask.java => sync/StartPipeTask.java}    | 14 ++--
 .../sys/{MergeTask.java => sync/StopPipeTask.java} | 14 ++--
 .../memory/StatementMemorySourceVisitor.java       | 19 +++++
 .../iotdb/db/mpp/plan/parser/ASTVisitor.java       | 18 ++---
 .../db/mpp/plan/statement/StatementVisitor.java    | 48 ++++++++++---
 .../sys/{ => sync}/CreatePipeSinkStatement.java    |  8 ++-
 .../sys/{ => sync}/CreatePipeStatement.java        |  8 ++-
 .../sys/{ => sync}/DropPipeSinkStatement.java      |  8 ++-
 .../sys/{ => sync}/DropPipeStatement.java          |  8 ++-
 .../sys/{ => sync}/ShowPipeSinkStatement.java      |  2 +-
 .../sys/{ => sync}/ShowPipeSinkTypeStatement.java  | 11 +--
 .../sys/{ => sync}/ShowPipeStatement.java          |  4 +-
 .../sys/{ => sync}/StartPipeStatement.java         |  8 ++-
 .../sys/{ => sync}/StopPipeStatement.java          |  8 ++-
 27 files changed, 417 insertions(+), 91 deletions(-)
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{metadata/DropFunctionTask.java => sys/sync/CreatePipeSinkTask.java} (73%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/{MergeTask.java => sync/CreatePipeTask.java} (75%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{metadata/DropFunctionTask.java => sys/sync/DropPipeSinkTask.java} (75%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/{MergeTask.java => sync/DropPipeTask.java} (76%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{metadata/DropFunctionTask.java => sys/sync/ShowPipeSinkTask.java} (75%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/{MergeTask.java => sync/ShowPipeTask.java} (76%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/{MergeTask.java => sync/StartPipeTask.java} (75%)
 copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/{MergeTask.java => sync/StopPipeTask.java} (76%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ => sync}/CreatePipeSinkStatement.java (89%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ => sync}/CreatePipeStatement.java (89%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ => sync}/DropPipeSinkStatement.java (86%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ => sync}/DropPipeStatement.java (86%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ => sync}/ShowPipeSinkStatement.java (96%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ => sync}/ShowPipeSinkTypeStatement.java (76%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ => sync}/ShowPipeStatement.java (94%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ => sync}/StartPipeStatement.java (86%)
 rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/{ => sync}/StopPipeStatement.java (86%)