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 614a0d8433a Optimize max_tsblock_line_num parameter and memory usage
of TopKOperator when align by device with limit value. (#11995)
add 63933967f6a Pipe: support alter pipe functionality (#11963)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/pipe/it/IoTDBPipeAlterIT.java | 154 ++++++++++++++++
.../api/customizer/parameter/PipeParameters.java | 28 +++
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 22 ++-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
...{CreatePipePlanV2.java => AlterPipePlanV2.java} | 10 +-
.../iotdb/confignode/manager/ConfigManager.java | 9 +
.../apache/iotdb/confignode/manager/IManager.java | 9 +
.../iotdb/confignode/manager/ProcedureManager.java | 19 ++
.../pipe/coordinator/task/PipeTaskCoordinator.java | 10 ++
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../persistence/pipe/PipePluginInfo.java | 22 +--
.../confignode/persistence/pipe/PipeTaskInfo.java | 77 +++++++-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 21 ++-
.../procedure/impl/pipe/PipeTaskOperation.java | 1 +
...eProcedureV2.java => AlterPipeProcedureV2.java} | 195 +++++++++++++--------
.../impl/pipe/task/CreatePipeProcedureV2.java | 25 ++-
.../impl/pipe/task/StopPipeProcedureV2.java | 3 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 1 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../request/ConfigPhysicalPlanSerDeTest.java | 29 ++-
.../iotdb/confignode/persistence/PipeInfoTest.java | 2 +-
...reV2Test.java => AlterPipeProcedureV2Test.java} | 17 +-
.../pipe/agent/plugin/PipePluginDataNodeAgent.java | 13 ++
.../pipe/extractor/IoTDBDataRegionExtractor.java | 13 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 54 +++++-
.../config/executor/IConfigTaskExecutor.java | 3 +
.../pipe/{DropPipeTask.java => AlterPipeTask.java} | 12 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 68 +++++--
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 +
...ePipeStatement.java => AlterPipeStatement.java} | 17 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 11 ++
.../commons/pipe/agent/task/PipeTaskAgent.java | 7 +-
.../src/main/thrift/confignode.thrift | 11 +-
40 files changed, 733 insertions(+), 176 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeAlterIT.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/task/{CreatePipePlanV2.java
=> AlterPipePlanV2.java} (87%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/{CreatePipeProcedureV2.java
=> AlterPipeProcedureV2.java} (52%)
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/{CreatePipeProcedureV2Test.java
=> AlterPipeProcedureV2Test.java} (81%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/pipe/{DropPipeTask.java
=> AlterPipeTask.java} (82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/{CreatePipeStatement.java
=> AlterPipeStatement.java} (84%)
