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/10/28 12:36:15 UTC
[iotdb] branch config updated (c1333be21f -> e08ef0563b)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch config
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c1333be21f fix
add 576331b99b [IOTDB-4619] Support CQ in Cluster Mode (#7749)
add e08ef0563b fix
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 34 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +-
.../confignode/client/DataNodeRequestType.java | 4 +-
.../client/async/AsyncDataNodeClientPool.java | 7 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 21 +
.../confignode/conf/ConfigNodeDescriptor.java | 32 +-
.../consensus/request/ConfigPhysicalPlan.java | 20 +
.../consensus/request/ConfigPhysicalPlanType.java | 5 +
.../cq/ActiveCQPlan.java} | 50 +-
.../consensus/request/write/cq/AddCQPlan.java | 98 +++
.../DropCQPlan.java} | 64 +-
.../cq/ShowCQPlan.java} | 14 +-
.../cq/UpdateCQLastExecTimePlan.java} | 65 +-
.../consensus/response/DataNodeRegisterResp.java | 8 +
...{GetSeriesSlotListResp.java => ShowCQResp.java} | 46 +-
.../statemachine/PartitionRegionStateMachine.java | 13 +
.../iotdb/confignode/manager/ConfigManager.java | 44 +-
.../apache/iotdb/confignode/manager/IManager.java | 17 +
.../iotdb/confignode/manager/ProcedureManager.java | 10 +
.../iotdb/confignode/manager/TriggerManager.java | 13 +-
.../iotdb/confignode/manager/cq/CQManager.java | 186 ++++++
.../confignode/manager/cq/CQScheduleTask.java | 276 +++++++++
.../iotdb/confignode/manager/node/NodeManager.java | 39 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 1 -
.../iotdb/confignode/persistence/cq/CQInfo.java | 501 +++++++++++++++
.../persistence/executor/ConfigPlanExecutor.java | 22 +-
.../iotdb/confignode/procedure/Procedure.java | 2 +-
.../procedure/impl/cq/CreateCQProcedure.java | 263 ++++++++
.../procedure/state/cq/CreateCQState.java | 10 +-
.../procedure/store/ProcedureFactory.java | 9 +
.../iotdb/confignode/service/ConfigNode.java | 4 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 18 +
.../request/ConfigPhysicalPlanSerDeTest.java | 72 +++
.../iotdb/confignode/cq/CQScheduleTaskTest.java | 26 +-
.../iotdb/confignode/persistence/CQInfoTest.java | 102 +++
docs/UserGuide/Process-Data/Continuous-Query.md | 678 ++++++++++++++------
docs/zh/UserGuide/Process-Data/Continuous-Query.md | 681 +++++++++++++++------
integration-test/import-control.xml | 1 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 13 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 83 ++-
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 466 ++++++++++++++
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 553 +++++++++++++++++
.../resources/conf/iotdb-common.properties | 13 +-
.../java/org/apache/iotdb/commons/cq/CQState.java | 39 +-
.../org/apache/iotdb/commons/cq/TimeoutPolicy.java | 39 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 19 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 51 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 +
.../iotdb/db/mpp/common/MPPQueryContext.java | 19 +-
.../org/apache/iotdb/db/mpp/common/QueryId.java | 2 +
.../db/mpp/common/header/ColumnHeaderConstant.java | 11 +
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 12 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 22 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 26 +
.../mpp/plan/execution/config/ConfigExecution.java | 5 +-
.../plan/execution/config/ConfigTaskVisitor.java | 41 +-
.../config/executor/ClusterConfigTaskExecutor.java | 85 +++
.../config/executor/IConfigTaskExecutor.java | 8 +
.../executor/StandaloneConfigTaskExecutor.java | 46 ++
...ionTask.java => CreateContinuousQueryTask.java} | 19 +-
...etTTLTask.java => DropContinuousQueryTask.java} | 14 +-
...TTLTask.java => ShowContinuousQueriesTask.java} | 43 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 120 +++-
.../db/mpp/plan/statement/StatementVisitor.java | 18 +
.../plan/statement/component/FillComponent.java | 12 +
.../plan/statement/component/FromComponent.java | 12 +
.../statement/component/GroupByLevelComponent.java | 17 +
.../statement/component/GroupByTimeComponent.java | 35 ++
.../plan/statement/component/HavingCondition.java | 4 +
.../plan/statement/component/IntoComponent.java | 12 +
.../db/mpp/plan/statement/component/IntoItem.java | 15 +
.../plan/statement/component/OrderByComponent.java | 12 +
.../plan/statement/component/SelectComponent.java | 21 +-
.../db/mpp/plan/statement/component/SortItem.java | 4 +
.../plan/statement/component/WhereCondition.java | 4 +
.../db/mpp/plan/statement/crud/QueryStatement.java | 97 ++-
.../mpp/plan/statement/literal/BooleanLiteral.java | 5 +
.../mpp/plan/statement/literal/DoubleLiteral.java | 5 +
.../db/mpp/plan/statement/literal/LongLiteral.java | 5 +
.../db/mpp/plan/statement/literal/NullLiteral.java | 5 +
.../mpp/plan/statement/literal/StringLiteral.java | 5 +
.../metadata/CreateContinuousQueryStatement.java | 215 +++++++
...ment.java => DropContinuousQueryStatement.java} | 24 +-
...nt.java => ShowContinuousQueriesStatement.java} | 16 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 59 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 1 +
.../impl/DataNodeInternalRPCServiceImpl.java | 145 ++++-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 9 +-
.../src/main/thrift/confignode.thrift | 63 +-
thrift/src/main/thrift/datanode.thrift | 18 +
93 files changed, 5342 insertions(+), 748 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/template/GetSchemaTemplatePlan.java => write/cq/ActiveCQPlan.java} (58%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/AddCQPlan.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{template/CreateSchemaTemplatePlan.java => cq/DropCQPlan.java} (54%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/GetFunctionTablePlan.java => write/cq/ShowCQPlan.java} (76%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/GetSeriesSlotListPlan.java => write/cq/UpdateCQLastExecTimePlan.java} (50%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{GetSeriesSlotListResp.java => ShowCQResp.java} (53%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQScheduleTask.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/cq/CQInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java
copy node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java => confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/cq/CreateCQState.java (87%)
copy testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster2IT.java => confignode/src/test/java/org/apache/iotdb/confignode/cq/CQScheduleTaskTest.java (57%)
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/persistence/CQInfoTest.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java
copy udf-api/src/main/java/org/apache/iotdb/udf/api/type/Type.java => node-commons/src/main/java/org/apache/iotdb/commons/cq/CQState.java (68%)
copy udf-api/src/main/java/org/apache/iotdb/udf/api/type/Type.java => node-commons/src/main/java/org/apache/iotdb/commons/cq/TimeoutPolicy.java (66%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{CreateFunctionTask.java => CreateContinuousQueryTask.java} (66%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{SetTTLTask.java => DropContinuousQueryTask.java} (77%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{ShowTTLTask.java => ShowContinuousQueriesTask.java} (64%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CreateContinuousQueryStatement.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{DropFunctionStatement.java => DropContinuousQueryStatement.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{ShowTriggersStatement.java => ShowContinuousQueriesStatement.java} (85%)