[iotdb] branch master updated (eb7095ecf8 -> e1cda9bd04)

[ro...@apache.org]

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

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


    from eb7095ecf8 [grafana-plugin] Preparing grafana-plugin launching in Grafana Marketplace: serveral bug fixes & code optimization (#9293)
     add e1cda9bd04 [IOTDB-5650] Pipe Plugin Coordinator: From SQL to ConfigNode (#9254)

No new revisions were added by this update.

Summary of changes:
 confignode/pom.xml                                 |   5 +
 .../confignode/client/DataNodeRequestType.java     |   4 +
 .../consensus/request/ConfigPhysicalPlanType.java  |   8 +-
 .../plugin/GetPipePluginJarPlan.java}              |  20 +-
 .../plugin/GetPipePluginTablePlan.java}            |   8 +-
 .../plugin/CreatePipePluginPlan.java}              |  26 ++-
 .../pipe/plugin/DropPipePluginPlan.java}           |  25 ++-
 .../plugin/PipePluginTableResp.java}               |  33 ++--
 .../iotdb/confignode/manager/ConfigManager.java    |  34 +++-
 .../apache/iotdb/confignode/manager/IManager.java  |   3 +
 .../iotdb/confignode/manager/pipe/PipeManager.java |  23 ++-
 .../manager/pipe/PipePluginCoordinator.java        | 209 ++++++++++++++++++++
 .../persistence/executor/ConfigPlanExecutor.java   |  20 +-
 .../confignode/persistence/pipe/PipeInfo.java      |  25 ++-
 .../persistence/pipe/PipePluginInfo.java           | 214 +++++++++++++++++++++
 node-commons/pom.xml                               |   5 +
 .../meta/ConfigNodePipePluginMetaKeeper.java       | 108 +++++++++++
 .../plugin/meta/DataNodePipePluginMetaKeeper.java  |  53 +++++
 .../commons/pipe/plugin/meta/PipePluginMeta.java   |  86 ++++-----
 .../pipe/plugin/meta/PipePluginMetaKeeper.java     |  52 +++++
 .../service/PipePluginExecutableManager.java       |  46 ++++-
 .../org/apache/iotdb/pipe/api/PipeConnector.java   |   2 +-
 .../java/org/apache/iotdb/pipe/api/PipePlugin.java |   4 +-
 .../org/apache/iotdb/pipe/api/PipeProcessor.java   |   2 +-
 .../api/exception/PipeManagementException.java     |   8 +-
 .../db/mpp/common/header/ColumnHeaderConstant.java |   6 +-
 .../config/executor/ClusterConfigTaskExecutor.java |   3 +-
 .../config/metadata/ShowPipePluginsTask.java       |   4 +-
 .../iotdb/db/pipe/agent/PipePluginAgent.java       | 191 ++++++++++++++++++
 .../impl/DataNodeInternalRPCServiceImpl.java       |  27 +++
 .../java/org/apache/iotdb/rpc/TSStatusCode.java    |   4 +-
 .../src/main/thrift/confignode.thrift              |   8 +-
 thrift/src/main/thrift/datanode.thrift             |  24 +++
 33 files changed, 1136 insertions(+), 154 deletions(-)
 copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{udf/GetUDFJarPlan.java => pipe/plugin/GetPipePluginJarPlan.java} (80%)
 copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{function/GetFunctionTablePlan.java => pipe/plugin/GetPipePluginTablePlan.java} (85%)
 copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{function/CreateFunctionPlan.java => pipe/plugin/CreatePipePluginPlan.java} (73%)
 copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/template/GetPathsSetTemplatePlan.java => write/pipe/plugin/DropPipePluginPlan.java} (71%)
 copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{udf/JarResp.java => pipe/plugin/PipePluginTableResp.java} (53%)
 copy node-commons/src/main/java/org/apache/iotdb/commons/concurrent/IoTDBDefaultThreadExceptionHandler.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/PipeManager.java (58%)
 create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/PipePluginCoordinator.java
 copy node-commons/src/main/java/org/apache/iotdb/commons/auth/user/LocalFileUserManager.java => confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeInfo.java (59%)
 create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipePluginInfo.java
 create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/meta/ConfigNodePipePluginMetaKeeper.java
 create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/meta/DataNodePipePluginMetaKeeper.java
 create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/meta/PipePluginMetaKeeper.java
 copy metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingMetric.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipePlugin.java (90%)
 copy udf-api/src/main/java/org/apache/iotdb/udf/api/exception/UDFManagementException.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeManagementException.java (79%)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/pipe/agent/PipePluginAgent.java