This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch IOTDB-4741
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c4536e4ce9 [IOTDB-4741] [IOTDB-4767] Support fetching all connection
info in Session & SessionPool
add 62c707132d [IOTDB-4747][IOTDB-4776] Modify default write path of iotdb
metric reporter (#7757)
add 6d1dff2421 [IOTDB-4779] Fix remove metrics in Metric Module (#7762)
add 2536fda09b [IOTDB-4718] Update user guide of SELECT INTO statement
(#7771)
add 7980a76f2e [IOTDB-4773] new session cause memory-leak (#7752)
add 3648dbea7a [IOTDB-4774]Register/recover UDF when registering/restart a
datanode (ConfigNode Process) (#7751)
add 576331b99b [IOTDB-4619] Support CQ in Cluster Mode (#7749)
add ebe53d1bd8 [IOTDB-4787] Make Using clause in CREATE FUNCTION optional
(#7777)
add fb60f603fa [IOTDB-4790] Make error message of ASTVisitor more specific
(#7781)
add 4800c36e01 [IOTDB-3562] Support Unset Template in cluster (#7735)
add c2ba3ae3d5 Add wait logic to ensure no data lost when remove a Peer
from MultiLeader consensus group (#7759)
add ad570418ad [IOTDB-4341] Refactor LoadBalancing framework and maintain
RegionRouteMap in RouteBalancer (#7766)
add 32f1674e11 [IOTDB-4737] Modify user doc of UDF && Trigger (#7782)
add 07210c64c8 [IOTDB-4788] Make Using clause in CREATE TRIGGER optional
(#7780)
add 9d9ef04b5a [IOTDB-3976] Support Drop Schema Template in cluster (#7769)
add 69582de2b5 [IOTDB-4787] Make Using clause in CREATE FUNCTION optional
(ConfigNode) (#7785)
add 8cdfa446d7 [IOTDB-4743] OperatePipeProcedure support rollback (#7750)
add af1a000c91 [IOTDB-4782] Fix systemMetrics in confignode (#7768)
add 2ca857db14 [IOTDB-3936]Add an interface in IClientRPCService to
directly return bytebuffer instead of TSQueryDataSet
add a78b9c2ee5 [IOTDB-4750] Refactor the configuration file structure
(#7779)
add 561a4aaf64 [IOTDB-4788] Make Using clause in CREATE TRIGGER optional
(ConfigNode) (#7788)
new f7d02745ff resolve conflicts
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 46 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 9 +-
confignode/src/assembly/confignode.xml | 4 +
.../resources/conf/iotdb-confignode.properties | 301 +----
.../confignode/client/DataNodeRequestType.java | 8 +-
.../client/async/AsyncDataNodeClientPool.java | 26 +
.../client/async/handlers/AsyncClientHandler.java | 24 +-
.../heartbeat/DataNodeHeartbeatHandler.java | 24 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 87 ++
.../async/handlers/rpc/OperatePipeRPCHandler.java | 60 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 21 +
.../confignode/conf/ConfigNodeDescriptor.java | 349 +++---
.../consensus/request/ConfigPhysicalPlan.java | 40 +
.../consensus/request/ConfigPhysicalPlanType.java | 12 +-
.../consensus/request/read/GetUDFJarPlan.java | 68 ++
.../consensus/request/write/cq/ActiveCQPlan.java | 85 ++
.../consensus/request/write/cq/AddCQPlan.java | 98 ++
.../consensus/request/write/cq/DropCQPlan.java | 93 ++
.../consensus/request/write/cq/ShowCQPlan.java | 30 +-
.../request/write/cq/UpdateCQLastExecTimePlan.java | 95 ++
.../write/statistics/UpdateLoadStatisticsPlan.java | 81 +-
.../write/template/DropSchemaTemplatePlan.java | 49 +-
.../write/template/PreUnsetSchemaTemplatePlan.java | 67 ++
.../RollbackPreUnsetSchemaTemplatePlan.java | 67 ++
.../write/template/UnsetSchemaTemplatePlan.java | 67 ++
.../consensus/response/DataNodeRegisterResp.java | 14 +
.../response/{TriggerJarResp.java => JarResp.java} | 10 +-
.../{TriggerJarResp.java => ShowCQResp.java} | 39 +-
.../statemachine/PartitionRegionStateMachine.java | 25 +-
.../confignode/manager/ClusterSchemaManager.java | 118 +-
.../iotdb/confignode/manager/ConfigManager.java | 95 +-
.../apache/iotdb/confignode/manager/IManager.java | 32 +-
.../iotdb/confignode/manager/ProcedureManager.java | 55 +
.../iotdb/confignode/manager/SyncManager.java | 87 +-
.../iotdb/confignode/manager/TriggerManager.java | 37 +-
.../iotdb/confignode/manager/UDFManager.java | 37 +-
.../iotdb/confignode/manager/cq/CQManager.java | 186 ++++
.../confignode/manager/cq/CQScheduleTask.java | 276 +++++
.../iotdb/confignode/manager/load/LoadManager.java | 55 +-
.../manager/load/LoadManagerMetrics.java | 8 +-
.../manager/load/balancer/RouteBalancer.java | 260 ++++-
.../manager/load/balancer/router/IRouter.java | 4 +-
.../load/balancer/router/LazyGreedyRouter.java | 159 ---
.../manager/load/balancer/router/LeaderRouter.java | 25 +-
.../balancer/router/LoadScoreGreedyRouter.java | 21 +-
.../load/balancer/router/RegionRouteMap.java | 172 +++
.../confignode/manager/node/BaseNodeCache.java | 20 +-
.../manager/node/ConfigNodeHeartbeatCache.java | 18 +-
.../manager/node/DataNodeHeartbeatCache.java | 16 +-
.../iotdb/confignode/manager/node/NodeManager.java | 185 ++--
.../manager/partition/PartitionManager.java | 117 +-
.../confignode/manager/partition/RegionCache.java | 2 +-
.../manager/partition/RegionGroupCache.java | 67 +-
.../manager/partition/RegionHeartbeatSample.java | 11 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 26 +-
.../iotdb/confignode/persistence/UDFInfo.java | 34 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 501 +++++++++
.../persistence/executor/ConfigPlanExecutor.java | 44 +-
.../confignode/persistence/node/NodeInfo.java | 22 +-
.../persistence/node/NodeStatistics.java | 24 +-
.../persistence/partition/PartitionInfo.java | 109 +-
.../partition/StorageGroupPartitionTable.java | 17 +
.../statistics/RegionGroupStatistics.java | 36 +-
.../partition/statistics/RegionStatistics.java | 48 +-
.../persistence/schema/ClusterSchemaInfo.java | 74 +-
.../persistence/schema/TemplateTable.java | 15 +
.../iotdb/confignode/procedure/Procedure.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 73 +-
.../procedure/impl/CreateTriggerProcedure.java | 11 +-
.../procedure/impl/cq/CreateCQProcedure.java | 263 +++++
.../impl/node/RemoveDataNodeProcedure.java | 2 +-
.../procedure/impl/schema/DataNodeRegionTask.java | 4 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 2 +-
.../impl/schema/UnsetTemplateProcedure.java | 426 +++++++
.../statemachine/CreateRegionGroupsProcedure.java | 11 +-
.../procedure/impl/sync/CreatePipeProcedure.java | 67 +-
.../procedure/impl/sync/DropPipeProcedure.java | 39 +-
.../OperatePipeProcedureRollbackProcessor.java | 122 ++
.../procedure/impl/sync/StartPipeProcedure.java | 97 +-
.../procedure/impl/sync/StopPipeProcedure.java | 97 +-
.../procedure/state/CreateRegionGroupsState.java | 13 +-
.../procedure/state/cq/CreateCQState.java | 15 +-
.../procedure/state/schema/UnsetTemplateState.java | 17 +-
.../procedure/store/ProcedureFactory.java | 18 +-
.../iotdb/confignode/service/ConfigNode.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 42 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 166 ++-
.../iotdb/confignode/cq/CQScheduleTaskTest.java | 32 +-
.../load/balancer/router/LazyGreedyRouterTest.java | 166 ---
.../load/balancer/router/LeaderRouterTest.java | 147 +--
.../balancer/router/LoadScoreGreedyRouterTest.java | 32 +-
.../load/balancer/router/RegionRouteMapTest.java | 82 ++
.../confignode/manager/node/NodeCacheTest.java | 54 +
.../manager/partition/RegionGroupCacheTest.java | 53 +-
.../iotdb/confignode/persistence/CQInfoTest.java | 102 ++
.../confignode/persistence/PartitionInfoTest.java | 29 +-
.../confignode/persistence/TriggerInfoTest.java | 2 +
.../statistics/RegionGroupStatisticsTest.java | 4 +-
.../partition/statistics/RegionStatisticsTest.java | 2 +-
.../procedure/impl/CreateTriggerProcedureTest.java | 2 +
.../procedure/impl/OperatePipeProcedureTest.java | 52 +
.../procedure/impl/UnsetTemplateProcedureTest.java | 75 ++
.../confignode1conf/iotdb-confignode.properties | 1 +
.../confignode2conf/iotdb-confignode.properties | 1 +
.../confignode3conf/iotdb-confignode.properties | 1 +
...java => ConsensusGroupModifyPeerException.java} | 8 +-
.../multileader/MultiLeaderConsensus.java | 22 +-
.../multileader/MultiLeaderServerImpl.java | 118 +-
.../service/MultiLeaderRPCServiceProcessor.java | 34 +-
distribution/src/assembly/all.xml | 4 +
distribution/src/assembly/confignode.xml | 4 +
distribution/src/assembly/datanode.xml | 4 +
docker/src/main/Dockerfile-1c1d-influxdb | 2 +-
docs/UserGuide/Alert/Alerting.md | 2 +-
docs/UserGuide/Alert/Triggers.md | 16 +-
docs/UserGuide/Process-Data/Continuous-Query.md | 678 ++++++++----
docs/UserGuide/Process-Data/Select-Into.md | 425 ++++---
.../Process-Data/UDF-User-Defined-Function.md | 9 +-
docs/zh/UserGuide/Alert/Alerting.md | 2 +-
docs/zh/UserGuide/Alert/Triggers.md | 16 +-
docs/zh/UserGuide/Process-Data/Continuous-Query.md | 681 ++++++++----
docs/zh/UserGuide/Process-Data/Select-Into.md | 425 ++++---
.../Process-Data/UDF-User-Defined-Function.md | 8 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
integration-test/import-control.xml | 1 +
integration-test/src/assembly/mpp-test.xml | 18 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 5 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 14 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 12 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 9 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 13 +-
...figNodeIT.java => IoTDBClusterAuthorizeIT.java} | 344 +-----
.../iotdb/confignode/it/IoTDBClusterNodeIT.java | 308 ++++++
.../confignode/it/IoTDBClusterPartitionIT.java | 1 +
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 152 +++
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 88 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 76 +-
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 3 +-
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 466 ++++++++
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 553 ++++++++++
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 63 +-
.../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 100 +-
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 21 +-
.../db/it/trigger/IoTDBTriggerManagementIT.java | 49 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 21 +-
.../apache/iotdb/integration/env/ClusterNode.java | 2 +-
.../iotdb/db/integration/IoTDBTracingIT.java | 4 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 843 ++++++++------
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 1163 +++++++++++++++++++-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 26 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 4 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 77 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 34 +-
.../dropwizard/DropwizardMetricManager.java | 2 +-
.../resources/conf/iotdb-confignode-metric.yml | 2 +-
.../resources/conf/iotdb-datanode-metric.yml | 2 +-
.../iotdb/metrics/AbstractMetricManager.java | 47 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 2 +-
.../iotdb/metrics/impl/DoNothingMetricManager.java | 2 +-
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 2 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 2 +-
.../micrometer/MicrometerMetricManager.java | 2 +-
.../resources/conf/iotdb-common.properties | 993 +++++++++--------
.../iotdb/commons/cluster/RegionRoleType.java | 10 +-
.../apache/iotdb/commons/cluster/RegionStatus.java | 5 +
.../apache/iotdb/commons/conf/CommonConfig.java | 2 +
.../java/org/apache/iotdb/commons/cq/CQState.java | 27 +-
.../org/apache/iotdb/commons/cq/TimeoutPolicy.java | 27 +-
.../exception/sync/PipeSinkBeingUsedException.java | 2 +-
.../commons/executable/ExecutableManager.java | 51 +-
.../apache/iotdb/commons/sync/pipe/PipeInfo.java | 6 +-
.../apache/iotdb/commons/sync/pipe/PipeStatus.java | 44 +-
.../iotdb/commons/trigger/TriggerInformation.java | 27 +-
.../trigger/service/TriggerExecutableManager.java | 2 +
.../apache/iotdb/commons/udf/UDFInformation.java | 37 +-
.../org/apache/iotdb/commons/udf/UDFTable.java | 3 +-
.../commons/udf/service/UDFClassLoaderManager.java | 5 +-
.../commons/udf/service/UDFExecutableManager.java | 36 +-
.../commons/udf/service/UDFManagementService.java | 8 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 19 +
.../resources/conf/schema-rocksdb.properties | 8 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 6 +
.../schemaregion/rocksdb/mnode/RMNode.java | 20 +
.../assembly/resources/conf/schema-tag.properties | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 6 +
.../resources/conf/iotdb-datanode.properties | 1065 +-----------------
server/src/assembly/server.xml | 4 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 103 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 15 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 58 +-
.../exception/query/PathNumOverLimitException.java | 2 +-
.../exception/sql/PathNumOverLimitException.java | 2 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 2 +-
.../idtable/entry/InsertMeasurementMNode.java | 20 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 8 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 37 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 14 +
.../iotdb/db/metadata/mtree/ConfigMTree.java | 36 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 23 +
.../db/metadata/schemaregion/ISchemaRegion.java | 2 +
.../schemaregion/SchemaRegionMemoryImpl.java | 10 +
.../schemaregion/SchemaRegionSchemaFileImpl.java | 6 +
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +-
.../metadata/template/ClusterTemplateManager.java | 28 +-
.../metadata/template/TemplateInternalRPCUtil.java | 99 ++
.../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 +
.../db/mpp/execution/exchange/ISourceHandle.java | 10 +
.../mpp/execution/exchange/LocalSourceHandle.java | 21 +
.../db/mpp/execution/exchange/SourceHandle.java | 22 +-
.../execution/executor/RegionWriteExecutor.java | 31 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 12 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 22 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 26 +
.../db/mpp/plan/execution/IQueryExecution.java | 3 +
.../db/mpp/plan/execution/QueryExecution.java | 33 +-
.../mpp/plan/execution/config/ConfigExecution.java | 23 +-
.../plan/execution/config/ConfigTaskVisitor.java | 57 +-
.../config/executor/ClusterConfigTaskExecutor.java | 368 +++++--
.../config/executor/IConfigTaskExecutor.java | 16 +
.../executor/StandaloneConfigTaskExecutor.java | 70 ++
.../config/metadata/CreateContinuousQueryTask.java | 49 +
.../config/metadata/DropContinuousQueryTask.java | 42 +
.../config/metadata/ShowContinuousQueriesTask.java | 75 ++
.../metadata/template/DropSchemaTemplateTask.java} | 39 +-
.../metadata/template/UnsetSchemaTemplateTask.java | 45 +
.../plan/execution/memory/MemorySourceHandle.java | 22 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 222 +++-
.../db/mpp/plan/statement/StatementVisitor.java | 30 +
.../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 ++++
.../metadata/CreateFunctionStatement.java | 19 +-
.../statement/metadata/CreateTriggerStatement.java | 19 +-
...ment.java => DropContinuousQueryStatement.java} | 46 +-
...nt.java => ShowContinuousQueriesStatement.java} | 48 +-
.../DropSchemaTemplateStatement.java} | 51 +-
.../UnsetSchemaTemplateStatement.java} | 44 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 59 +-
.../iotdb/db/query/control/SessionManager.java | 1 -
.../java/org/apache/iotdb/db/service/DataNode.java | 61 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 2 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 22 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 450 ++++----
.../impl/DataNodeInternalRPCServiceImpl.java | 208 +++-
.../db/service/thrift/impl/TSServiceImpl.java | 32 +
.../java/org/apache/iotdb/db/sync/SyncService.java | 84 +-
.../db/sync/transport/server/ReceiverManager.java | 2 +-
.../trigger/service/TriggerManagementService.java | 4 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 27 +
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 8 +-
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 6 +-
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 2 +-
.../apache/iotdb/db/metric/MetricServiceTest.java | 19 +
.../db/mpp/plan/StandaloneCoordinatorTest.java | 3 +-
service-rpc/pom.xml | 8 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 345 +++---
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 10 +-
.../apache/iotdb/session/SessionConnection.java | 22 +-
.../org/apache/iotdb/session/SessionDataSet.java | 29 +-
.../src/main/thrift/confignode.thrift | 121 +-
.../src/main/thrift/mutlileader.thrift | 11 +
thrift/src/main/thrift/client.thrift | 20 +-
thrift/src/main/thrift/datanode.thrift | 43 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 28 +
284 files changed, 14729 insertions(+), 6027 deletions(-)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/CountPathsUsingTemplateRPCHandler.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/OperatePipeRPCHandler.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetUDFJarPlan.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/ActiveCQPlan.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/AddCQPlan.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/DropCQPlan.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/FromComponent.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/ShowCQPlan.java
(56%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/UpdateCQLastExecTimePlan.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/literal/NullLiteral.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/DropSchemaTemplatePlan.java
(51%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/PreUnsetSchemaTemplatePlan.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/RollbackPreUnsetSchemaTemplatePlan.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/template/UnsetSchemaTemplatePlan.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{TriggerJarResp.java
=> JarResp.java} (80%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{TriggerJarResp.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
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LazyGreedyRouter.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMap.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
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/UnsetTemplateProcedure.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/OperatePipeProcedureRollbackProcessor.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/PipeStatus.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/cq/CreateCQState.java
(79%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/PipeStatus.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/UnsetTemplateState.java
(79%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/FromComponent.java
=>
confignode/src/test/java/org/apache/iotdb/confignode/cq/CQScheduleTaskTest.java
(55%)
delete mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/LazyGreedyRouterTest.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMapTest.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/manager/node/NodeCacheTest.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/persistence/CQInfoTest.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/UnsetTemplateProcedureTest.java
copy
consensus/src/main/java/org/apache/iotdb/consensus/exception/{ConsensusGroupAddPeerException.java
=> ConsensusGroupModifyPeerException.java} (77%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/{IoTDBConfigNodeIT.java
=> IoTDBClusterAuthorizeIT.java} (50%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterNodeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterRegionLeaderBalancingIT.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 server/src/assembly/resources/conf/iotdb-datanode.properties =>
node-commons/src/assembly/resources/conf/iotdb-common.properties (79%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupAddPeerException.java
=> node-commons/src/main/java/org/apache/iotdb/commons/cq/CQState.java (64%)
rename
consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupAddPeerException.java
=> node-commons/src/main/java/org/apache/iotdb/commons/cq/TimeoutPolicy.java
(63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateInternalRPCUtil.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/CreateContinuousQueryTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/DropContinuousQueryTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowContinuousQueriesTask.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/{IQueryExecution.java
=> config/metadata/template/DropSchemaTemplateTask.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/template/UnsetSchemaTemplateTask.java
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/{CreateFunctionStatement.java
=> DropContinuousQueryStatement.java} (65%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CreateFunctionStatement.java
=> ShowContinuousQueriesStatement.java} (59%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CreateFunctionStatement.java
=> template/DropSchemaTemplateStatement.java} (52%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CreateFunctionStatement.java
=> template/UnsetSchemaTemplateStatement.java} (62%)
