This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch ml/windowSet in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 756d8b83b092addb0ab0f43cdadada0af601c204 Merge: ac24e3599d 2ee98de984 Author: Minghui Liu <[email protected]> AuthorDate: Mon Oct 31 16:35:41 2022 +0800 Merge remote-tracking branch 'origin/master' into ml/windowSet # Conflicts: # thrift/src/main/thrift/client.thrift .dockerignore | 1 + .github/workflows/client-go.yml | 2 +- .github/workflows/client-python.yml | 2 +- .github/workflows/influxdb-protocol.yml | 2 +- .github/workflows/main-unix.yml | 2 +- .github/workflows/main-win.yml | 2 +- .github/workflows/standalone-it-for-mpp.yml | 160 +- .gitignore | 1 + .../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 21 +- .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 57 +- .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 29 +- .../java/org/apache/iotdb/cli/AbstractCli.java | 11 +- .../main/java/org/apache/iotdb/tool/ImportCsv.java | 4 +- .../org/apache/iotdb/cli/StartClientScriptIT.java | 3 + client-cpp/README.md | 41 +- client-go | 2 +- client-py/requirements.txt | 4 +- client-py/setup.py | 2 +- client-py/tests/test_template.py | 127 +- confignode/pom.xml | 5 + confignode/src/assembly/confignode.xml | 14 +- .../resources/conf/iotdb-confignode.properties | 357 +--- .../assembly/resources/conf/logback-confignode.xml | 140 ++ confignode/src/assembly/resources/conf/logback.xml | 140 -- .../assembly/resources/sbin/remove-confignode.bat | 2 +- .../assembly/resources/sbin/remove-confignode.sh | 2 +- .../assembly/resources/sbin/start-confignode.bat | 2 +- .../assembly/resources/sbin/start-confignode.sh | 2 +- .../assembly/resources/sbin/stop-confignode.bat | 10 +- .../src/assembly/resources/sbin/stop-confignode.sh | 6 +- .../confignode/client/DataNodeRequestType.java | 12 +- .../client/async/AsyncDataNodeClientPool.java | 72 +- .../client/async/handlers/AsyncClientHandler.java | 33 +- .../heartbeat/ConfigNodeHeartbeatHandler.java | 4 +- .../heartbeat/DataNodeHeartbeatHandler.java | 55 +- .../rpc/CountPathsUsingTemplateRPCHandler.java | 87 + .../async/handlers/rpc/DeleteSchemaRPCHandler.java | 84 + .../handlers/rpc/DeleteTimeSeriesRPCHandler.java | 84 - .../async/handlers/rpc/OperatePipeRPCHandler.java | 60 + .../iotdb/confignode/conf/ConfigNodeConfig.java | 59 +- .../iotdb/confignode/conf/ConfigNodeConstant.java | 4 +- .../confignode/conf/ConfigNodeDescriptor.java | 359 ++-- .../confignode/conf/ConfigNodeRemoveCheck.java | 2 +- .../confignode/conf/ConfigNodeStartupCheck.java | 2 +- .../confignode/conf/SystemPropertiesUtils.java | 24 +- .../consensus/request/ConfigPhysicalPlan.java | 233 ++- .../consensus/request/ConfigPhysicalPlanType.java | 214 +- .../consensus/request/auth/AuthorPlan.java | 41 +- .../request/read/CountStorageGroupPlan.java | 88 - .../request/read/GetDataNodeConfigurationPlan.java | 70 - .../request/read/GetDataPartitionPlan.java | 133 -- .../request/read/GetNodePathsPartitionPlan.java | 85 - .../request/read/GetOrCreateDataPartitionPlan.java | 52 - .../read/GetOrCreateSchemaPartitionPlan.java | 37 - .../consensus/request/read/GetRegionIdPlan.java | 112 - .../request/read/GetRegionInfoListPlan.java | 84 - .../request/read/GetSchemaPartitionPlan.java | 106 - .../request/read/GetSeriesSlotListPlan.java | 84 - .../request/read/GetStorageGroupPlan.java | 34 - .../request/read/GetTimeSlotListPlan.java | 109 - .../request/read/GetTransferringTriggersPlan.java | 42 - .../consensus/request/read/GetTriggerJarPlan.java | 68 - .../request/read/GetTriggerTablePlan.java | 62 - .../datanode/GetDataNodeConfigurationPlan.java | 70 + .../read/function/GetFunctionTablePlan.java | 42 + .../read/partition/GetDataPartitionPlan.java | 133 ++ .../read/partition/GetNodePathsPartitionPlan.java | 85 + .../partition/GetOrCreateDataPartitionPlan.java | 52 + .../partition/GetOrCreateSchemaPartitionPlan.java | 37 + .../read/partition/GetSchemaPartitionPlan.java | 106 + .../read/partition/GetSeriesSlotListPlan.java | 84 + .../read/partition/GetTimeSlotListPlan.java | 109 + .../request/read/region/GetRegionIdPlan.java | 112 + .../request/read/region/GetRegionInfoListPlan.java | 84 + .../read/storagegroup/CountStorageGroupPlan.java | 88 + .../read/storagegroup/GetStorageGroupPlan.java | 34 + .../read/template/CheckTemplateSettablePlan.java | 2 +- .../read/template/GetAllSchemaTemplatePlan.java | 2 +- .../read/template/GetAllTemplateSetInfoPlan.java | 2 +- .../read/template/GetPathsSetTemplatePlan.java | 2 +- .../read/template/GetSchemaTemplatePlan.java | 2 +- .../read/template/GetTemplateSetInfoPlan.java | 68 + .../read/trigger/GetTransferringTriggersPlan.java | 42 + .../request/read/trigger/GetTriggerJarPlan.java | 68 + .../read/trigger/GetTriggerLocationPlan.java | 62 + .../request/read/trigger/GetTriggerTablePlan.java | 62 + .../consensus/request/read/udf/GetUDFJarPlan.java | 68 + .../request/write/CreateFunctionPlan.java | 86 - .../request/write/DeleteProcedurePlan.java | 69 - .../consensus/request/write/DropFunctionPlan.java | 57 - .../request/write/RegisterDataNodePlan.java | 71 - .../request/write/RemoveDataNodePlan.java | 96 - .../request/write/UpdateProcedurePlan.java | 74 - .../request/write/UpdateRegionLocationPlan.java | 86 - .../write/confignode/ApplyConfigNodePlan.java | 2 +- .../write/confignode/RemoveConfigNodePlan.java | 2 +- .../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 | 42 + .../request/write/cq/UpdateCQLastExecTimePlan.java | 95 + .../write/datanode/RegisterDataNodePlan.java | 71 + .../request/write/datanode/RemoveDataNodePlan.java | 83 + .../request/write/datanode/UpdateDataNodePlan.java | 71 + .../request/write/function/CreateFunctionPlan.java | 76 + .../request/write/function/DropFunctionPlan.java | 57 + .../write/partition/CreateDataPartitionPlan.java | 2 +- .../write/partition/CreateSchemaPartitionPlan.java | 2 +- .../write/partition/UpdateRegionLocationPlan.java | 86 + .../write/procedure/DeleteProcedurePlan.java | 69 + .../write/procedure/UpdateProcedurePlan.java | 87 + .../write/region/CreateRegionGroupsPlan.java | 6 +- .../write/region/OfferRegionMaintainTasksPlan.java | 4 +- .../write/region/PollRegionMaintainTaskPlan.java | 2 +- .../AdjustMaxRegionGroupCountPlan.java | 2 +- .../write/storagegroup/DeleteStorageGroupPlan.java | 2 +- .../storagegroup/PreDeleteStorageGroupPlan.java | 2 +- .../storagegroup/SetDataReplicationFactorPlan.java | 2 +- .../SetSchemaReplicationFactorPlan.java | 2 +- .../write/storagegroup/SetStorageGroupPlan.java | 2 +- .../request/write/storagegroup/SetTTLPlan.java | 2 +- .../storagegroup/SetTimePartitionIntervalPlan.java | 2 +- .../request/write/sync/CreatePipeSinkPlan.java | 2 +- .../consensus/request/write/sync/DropPipePlan.java | 2 +- .../request/write/sync/DropPipeSinkPlan.java | 2 +- .../request/write/sync/GetPipeSinkPlan.java | 2 +- .../request/write/sync/PreCreatePipePlan.java | 2 +- .../request/write/sync/SetPipeStatusPlan.java | 2 +- .../consensus/request/write/sync/ShowPipePlan.java | 2 +- .../write/template/CreateSchemaTemplatePlan.java | 2 +- .../write/template/DropSchemaTemplatePlan.java | 57 + .../write/template/PreUnsetSchemaTemplatePlan.java | 67 + .../RollbackPreUnsetSchemaTemplatePlan.java | 67 + .../write/template/SetSchemaTemplatePlan.java | 2 +- .../write/template/UnsetSchemaTemplatePlan.java | 67 + .../write/trigger/AddTriggerInTablePlan.java | 2 +- .../write/trigger/DeleteTriggerInTablePlan.java | 2 +- .../write/trigger/UpdateTriggerLocationPlan.java | 2 +- .../trigger/UpdateTriggerStateInTablePlan.java | 2 +- .../trigger/UpdateTriggersOnTransferNodesPlan.java | 2 +- .../consensus/response/DataNodeRegisterResp.java | 17 +- .../consensus/response/FunctionTableResp.java | 70 + .../confignode/consensus/response/JarResp.java | 52 + .../confignode/consensus/response/ShowCQResp.java | 55 + .../consensus/response/TemplateSetInfoResp.java | 52 + .../consensus/response/TriggerJarResp.java | 52 - .../consensus/response/TriggerLocationResp.java | 49 + .../statemachine/PartitionRegionStateMachine.java | 99 +- .../confignode/manager/ClusterSchemaManager.java | 129 +- .../iotdb/confignode/manager/ConfigManager.java | 252 ++- .../iotdb/confignode/manager/ConsensusManager.java | 179 +- .../apache/iotdb/confignode/manager/IManager.java | 91 +- .../iotdb/confignode/manager/ProcedureManager.java | 165 +- .../iotdb/confignode/manager/SyncManager.java | 115 +- .../iotdb/confignode/manager/TriggerManager.java | 65 +- .../iotdb/confignode/manager/UDFManager.java | 151 +- .../iotdb/confignode/manager/cq/CQManager.java | 186 ++ .../confignode/manager/cq/CQScheduleTask.java | 276 +++ .../iotdb/confignode/manager/load/LoadManager.java | 188 +- .../manager/load/LoadManagerMetrics.java | 12 +- .../manager/load/balancer/RouteBalancer.java | 277 ++- .../manager/load/balancer/router/IRouter.java | 4 +- .../load/balancer/router/LazyGreedyRouter.java | 159 -- .../manager/load/balancer/router/LeaderRouter.java | 34 +- .../balancer/router/LoadScoreGreedyRouter.java | 30 +- .../load/balancer/router/RegionRouteMap.java | 166 ++ .../confignode/manager/node/BaseNodeCache.java | 80 - .../manager/node/ConfigNodeHeartbeatCache.java | 78 - .../manager/node/DataNodeHeartbeatCache.java | 80 - .../manager/node/NodeHeartbeatSample.java | 87 - .../iotdb/confignode/manager/node/NodeManager.java | 226 ++- .../manager/node/heartbeat/BaseNodeCache.java | 140 ++ .../node/heartbeat/ConfigNodeHeartbeatCache.java | 83 + .../node/heartbeat/DataNodeHeartbeatCache.java | 63 + .../node/heartbeat/NodeHeartbeatSample.java | 87 + .../manager/node/heartbeat/NodeStatistics.java | 139 ++ .../manager/partition/PartitionManager.java | 115 +- .../confignode/manager/partition/RegionCache.java | 91 - .../manager/partition/RegionGroupCache.java | 122 -- .../manager/partition/RegionHeartbeatSample.java | 68 - .../manager/partition/heartbeat/RegionCache.java | 73 + .../partition/heartbeat/RegionGroupCache.java | 157 ++ .../partition/heartbeat/RegionGroupStatistics.java | 135 ++ .../partition/heartbeat/RegionHeartbeatSample.java | 49 + .../partition/heartbeat/RegionStatistics.java | 86 + .../iotdb/confignode/persistence/NodeInfo.java | 532 ----- .../confignode/persistence/ProcedureInfo.java | 4 +- .../iotdb/confignode/persistence/TriggerInfo.java | 52 +- .../iotdb/confignode/persistence/UDFInfo.java | 227 ++- .../iotdb/confignode/persistence/cq/CQInfo.java | 501 +++++ .../persistence/executor/ConfigPlanExecutor.java | 134 +- .../persistence/metric/NodeInfoMetrics.java | 6 +- .../persistence/metric/PartitionInfoMetrics.java | 4 +- .../confignode/persistence/node/NodeInfo.java | 512 +++++ .../persistence/partition/PartitionInfo.java | 48 +- .../persistence/partition/RegionCreateTask.java | 135 -- .../persistence/partition/RegionDeleteTask.java | 98 - .../persistence/partition/RegionGroup.java | 3 + .../persistence/partition/RegionMaintainTask.java | 131 -- .../persistence/partition/RegionMaintainType.java | 24 - .../partition/StorageGroupPartitionTable.java | 21 +- .../partition/maintainer/RegionCreateTask.java | 135 ++ .../partition/maintainer/RegionDeleteTask.java | 98 + .../partition/maintainer/RegionMaintainTask.java | 131 ++ .../partition/maintainer/RegionMaintainType.java | 24 + .../persistence/schema/ClusterSchemaInfo.java | 136 +- .../persistence/schema/TemplateTable.java | 31 + .../persistence/sync/ClusterSyncInfo.java | 25 + .../iotdb/confignode/procedure/Procedure.java | 8 +- .../confignode/procedure/ProcedureExecutor.java | 2 +- .../procedure/env/ConfigNodeProcedureEnv.java | 87 +- .../procedure/env/DataNodeRemoveHandler.java | 34 +- .../procedure/impl/CreateTriggerProcedure.java | 295 --- .../procedure/impl/DropTriggerProcedure.java | 176 -- .../procedure/impl/cq/CreateCQProcedure.java | 263 +++ .../impl/node/AddConfigNodeProcedure.java | 4 +- .../impl/node/RemoveConfigNodeProcedure.java | 4 +- .../impl/node/RemoveDataNodeProcedure.java | 18 +- .../impl/schema/DataNodeRegionGroupUtil.java | 81 + .../procedure/impl/schema/DataNodeRegionTask.java | 195 ++ .../impl/schema/DeactivateTemplateProcedure.java | 488 +++++ .../impl/schema/DeleteStorageGroupProcedure.java | 211 ++ .../impl/schema/DeleteTimeSeriesProcedure.java | 549 +++++ .../impl/schema/UnsetTemplateProcedure.java | 426 ++++ .../statemachine/CreateRegionGroupsProcedure.java | 21 +- .../statemachine/DeleteStorageGroupProcedure.java | 210 -- .../statemachine/DeleteTimeSeriesProcedure.java | 658 ------ .../impl/statemachine/RegionMigrateProcedure.java | 4 +- .../impl/sync/AbstractOperatePipeProcedure.java | 3 + .../procedure/impl/sync/CreatePipeProcedure.java | 76 +- .../procedure/impl/sync/DropPipeProcedure.java | 44 +- .../OperatePipeProcedureRollbackProcessor.java | 122 ++ .../procedure/impl/sync/StartPipeProcedure.java | 103 +- .../procedure/impl/sync/StopPipeProcedure.java | 103 +- .../impl/trigger/CreateTriggerProcedure.java | 288 +++ .../impl/trigger/DropTriggerProcedure.java | 176 ++ .../confignode/procedure/scheduler/LockQueue.java | 10 +- .../procedure/state/CreateRegionGroupsState.java | 13 +- .../procedure/state/DeleteStorageGroupState.java | 27 - .../procedure/state/DeleteTimeSeriesState.java | 27 - .../procedure/state/RemoveDataNodeState.java | 1 + .../procedure/state/cq/CreateCQState.java | 25 + .../state/schema/DeactivateTemplateState.java | 27 + .../state/schema/DeleteStorageGroupState.java | 27 + .../state/schema/DeleteTimeSeriesState.java | 27 + .../procedure/state/schema/UnsetTemplateState.java | 27 + .../procedure/store/ConfigProcedureStore.java | 6 +- .../procedure/store/ProcedureFactory.java | 62 +- .../confignode/procedure/store/ProcedureType.java | 82 + .../iotdb/confignode/service/ConfigNode.java | 33 +- .../service/thrift/ConfigNodeRPCService.java | 6 +- .../thrift/ConfigNodeRPCServiceHandler.java | 2 +- .../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 4 +- .../thrift/ConfigNodeRPCServiceMetrics.java | 4 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 122 +- .../confignode/writelog/io/BatchLogReader.java | 76 + .../iotdb/confignode/writelog/io/ILogReader.java | 46 + .../writelog/io/SingleFileLogReader.java | 156 ++ .../request/ConfigPhysicalPlanSerDeTest.java | 244 ++- .../request/write/RemoveDataNodePlanTest.java | 173 -- .../iotdb/confignode/cq/CQScheduleTaskTest.java | 44 + .../load/balancer/router/LazyGreedyRouterTest.java | 166 -- .../load/balancer/router/LeaderRouterTest.java | 155 +- .../balancer/router/LoadScoreGreedyRouterTest.java | 40 +- .../load/balancer/router/RegionRouteMapTest.java | 82 + .../confignode/manager/node/NodeCacheTest.java | 67 + .../manager/partition/RegionGroupCacheTest.java | 109 +- .../iotdb/confignode/persistence/CQInfoTest.java | 102 + .../persistence/ClusterSchemaInfoTest.java | 2 +- .../iotdb/confignode/persistence/NodeInfoTest.java | 56 +- .../confignode/persistence/PartitionInfoTest.java | 25 +- .../confignode/persistence/TriggerInfoTest.java | 5 + .../iotdb/confignode/persistence/UDFInfoTest.java | 82 + .../persistence/node/NodeStatisticsTest.java | 49 + .../statistics/RegionGroupStatisticsTest.java | 58 + .../partition/statistics/RegionStatisticsTest.java | 49 + .../procedure/impl/CreateCQProcedureTest.java | 87 + .../impl/CreateRegionGroupsProcedureTest.java | 4 +- .../procedure/impl/CreateTriggerProcedureTest.java | 6 + .../impl/DeactivateTemplateProcedureTest.java | 88 + .../impl/DeleteStorageGroupProcedureTest.java | 2 +- .../impl/DeleteTimeSeriesProcedureTest.java | 6 +- .../procedure/impl/DropTriggerProcedureTest.java | 1 + .../procedure/impl/OperatePipeProcedureTest.java | 60 +- .../procedure/impl/UnsetTemplateProcedureTest.java | 75 + .../impl/node/AddConfigNodeProcedureTest.java | 50 + .../impl/node/RemoveConfigNodeProcedureTest.java | 50 + .../impl/node/RemoveDataNodeProcedureTest.java | 55 + .../statemachine/RegionMigrateProcedureTest.java | 65 + .../confignode1conf/iotdb-confignode.properties | 15 +- .../resources/confignode1conf/iotdb-metric.yml | 5 - .../confignode2conf/iotdb-confignode.properties | 15 +- .../resources/confignode2conf/iotdb-metric.yml | 5 - .../confignode3conf/iotdb-confignode.properties | 15 +- .../resources/confignode3conf/iotdb-metric.yml | 5 - .../org/apache/iotdb/consensus/IConsensus.java | 34 + .../org/apache/iotdb/consensus/common/Peer.java | 16 +- .../exception/ConsensusGroupAddPeerException.java | 34 - .../ConsensusGroupModifyPeerException.java | 34 + .../multileader/MultiLeaderConsensus.java | 37 +- .../multileader/MultiLeaderServerImpl.java | 204 +- .../multileader/MultiLeaderServerMetrics.java | 88 + .../multileader/client/DispatchLogHandler.java | 15 + .../multileader/logdispatcher/LogDispatcher.java | 26 +- .../logdispatcher/LogDispatcherThreadMetrics.java | 95 + .../logdispatcher/MultiLeaderMemoryManager.java | 10 +- .../MultiLeaderMemoryManagerMetrics.java | 52 + .../service/MultiLeaderRPCServiceProcessor.java | 63 +- .../iotdb/consensus/ratis/RatisConsensus.java | 65 +- .../consensus/standalone/StandAloneConsensus.java | 5 + .../iotdb/consensus/ratis/RatisConsensusTest.java | 14 + distribution/src/assembly/all.xml | 48 +- distribution/src/assembly/confignode.xml | 14 +- distribution/src/assembly/datanode.xml | 6 +- docker/src/main/DockerCompose/start-1c1d.sh | 22 + docker/src/main/Dockerfile-0.10.0 | 39 - docker/src/main/Dockerfile-0.11.0 | 39 - docker/src/main/Dockerfile-0.11.1 | 39 - docker/src/main/Dockerfile-0.11.2 | 41 - docker/src/main/Dockerfile-0.11.3 | 41 - docker/src/main/Dockerfile-0.12.0-cluster | 53 - docker/src/main/Dockerfile-0.12.0-node | 45 - docker/src/main/Dockerfile-0.12.1-cluster | 53 - docker/src/main/Dockerfile-0.12.1-node | 45 - docker/src/main/Dockerfile-0.12.2-cluster | 53 - docker/src/main/Dockerfile-0.12.2-grafana | 41 - docker/src/main/Dockerfile-0.12.2-node | 45 - docker/src/main/Dockerfile-0.12.6-cluster | 53 + docker/src/main/Dockerfile-0.12.6-grafana | 41 + docker/src/main/Dockerfile-0.12.6-node | 45 + docker/src/main/Dockerfile-0.13.0-cluster | 53 + .../src/main/Dockerfile-0.13.3-grafana-connector | 41 + docker/src/main/Dockerfile-0.13.3-node | 45 + .../src/main/Dockerfile-0.13.3-node-multi-platform | 45 + docker/src/main/Dockerfile-0.9.0 | 41 - docker/src/main/Dockerfile-1c1d | 56 + docker/src/main/Dockerfile-1c1d-influxdb | 57 + docs/Download/README.md | 176 +- docs/UserGuide/API/Interface-Comparison.md | 44 +- docs/UserGuide/API/Programming-Java-Native-API.md | 2 +- docs/UserGuide/Alert/Alerting.md | 122 +- docs/UserGuide/Alert/Triggers.md | 1174 +++-------- docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 56 +- docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 6 - docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 296 +-- docs/UserGuide/Operate-Metadata/Template.md | 38 +- 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/UserGuide/Query-Data/Select-Expression.md | 155 ++ docs/UserGuide/Reference/Keywords.md | 52 +- docs/UserGuide/Reference/Syntax-Conventions.md | 169 +- docs/UserGuide/UDF-Library/M4.md | 101 +- docs/zh/Download/README.md | 171 +- docs/zh/UserGuide/API/Interface-Comparison.md | 44 +- .../UserGuide/API/Programming-Java-Native-API.md | 2 +- docs/zh/UserGuide/Alert/Alerting.md | 110 +- docs/zh/UserGuide/Alert/Triggers.md | 1132 +++-------- .../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 53 +- docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 7 - docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 332 ++- docs/zh/UserGuide/Operate-Metadata/Template.md | 40 +- 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 +- docs/zh/UserGuide/Query-Data/Select-Expression.md | 156 ++ docs/zh/UserGuide/Reference/Keywords.md | 50 +- docs/zh/UserGuide/Reference/Syntax-Conventions.md | 172 +- docs/zh/UserGuide/UDF-Library/M4.md | 101 +- .../org/apache/iotdb/influxdb/InfluxDBExample.java | 2 +- .../server/CustomizedJsonPayloadFormatter.java | 2 +- .../iotdb/trigger/ClusterAlertingExample.java | 2 +- external-api/pom.xml | 8 + .../iotdb/external/api/IPropertiesLoader.java | 12 +- .../iotdb/external/api/ISeriesNumerLimiter.java | 48 - .../iotdb/external/api/ISeriesNumerMonitor.java | 46 + .../external/api/thrift/JudgableServerContext.java | 44 + .../external/api/thrift/ServerContextFactory.java | 27 + .../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 1 + .../util/TSFileConfigUtilCompletenessTest.java | 12 +- .../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 277 ++- .../Apache IoTDB DataNode Dashboard v0.14.0.json | 2141 +++++++++++++++++--- grafana-plugin/README.md | 363 +++- grafana-plugin/src/plugin.json | 4 +- .../influxdb/integration/IoTDBInfluxDBIT.java | 7 +- integration-test/checkstyle.xml | 2 +- integration-test/import-control.xml | 16 +- integration-test/src/assembly/mpp-test.xml | 18 +- .../java/org/apache/iotdb/it/env/AbstractEnv.java | 69 +- .../apache/iotdb/it/env/AbstractNodeWrapper.java | 34 +- .../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 44 +- .../org/apache/iotdb/it/env/DataNodeWrapper.java | 71 +- .../java/org/apache/iotdb/it/env/MppConfig.java | 44 + .../org/apache/iotdb/it/env/RemoteServerEnv.java | 23 +- .../BuiltinTimeSeriesGeneratingFunctionEnum.java | 3 +- .../org/apache/iotdb/itbase/env/BaseConfig.java | 60 + .../java/org/apache/iotdb/itbase/env/BaseEnv.java | 16 +- .../confignode/it/IoTDBClusterAuthorityIT.java | 452 +++++ .../iotdb/confignode/it/IoTDBClusterNodeIT.java | 308 +++ .../confignode/it/IoTDBClusterPartitionIT.java | 41 +- .../it/IoTDBClusterRegionLeaderBalancingIT.java | 152 ++ .../iotdb/confignode/it/IoTDBClusterRestartIT.java | 149 +- .../iotdb/confignode/it/IoTDBConfigNodeIT.java | 848 -------- .../confignode/it/IoTDBConfigNodeSnapshotIT.java | 180 +- .../it/IoTDBConfigNodeSwitchLeaderIT.java | 191 ++ .../iotdb/confignode/it/IoTDBStorageGroupIT.java | 8 +- .../confignode/it/utils/ConfigNodeTestUtils.java | 115 ++ .../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 5 + .../db/it/aggregation/IoTDBTagAggregationIT.java | 16 + .../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 1 - .../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 466 +++++ .../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 553 +++++ .../org/apache/iotdb/db/it/env/StandaloneEnv.java | 15 +- .../iotdb/db/it/env/StandaloneEnvConfig.java | 79 + .../apache/iotdb/db/it/mqtt/IoTDBMQTTSinkIT.java | 212 ++ .../db/it/schema/IoTDBDeactivateTemplateIT.java | 231 +++ .../schema/IoTDBDeleteTimeseriesSchemaFileIT.java | 49 + .../it/schema/IoTDBMetadataFetchSchemaFileIT.java | 53 + .../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 63 +- .../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 57 + .../iotdb/db/it/selectinto/IoTDBSelectInto3IT.java | 54 + .../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 523 +++++ .../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 126 +- .../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 2 +- .../apache/iotdb/db/it/sync/SyncTransportTest.java | 323 +++ .../db/it/trigger/IoTDBTriggerExecutionIT.java | 23 +- .../db/it/trigger/IoTDBTriggerManagementIT.java | 488 +++++ .../org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java | 283 +++ .../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 21 +- .../org/apache/iotdb/db/it/utils/TestUtils.java | 10 + .../iotdb/db/it/watermark/IoTDBWatermarkIT.java | 247 +++ .../iotdb/session/it/IoTDBConnectionInfoIT.java | 66 + .../iotdb/session/it/IoTDBSessionInsertNulIT.java | 360 ---- .../iotdb/session/it/IoTDBSessionInsertNullIT.java | 360 ++++ .../IoTDBSessionInsertWithTriggerExecutionIT.java | 23 +- .../session/it/IoTDBSessionSchemaTemplateIT.java | 223 ++ .../iotdb/session/it/IoTDBSessionSimpleIT.java | 186 +- .../iotdb/session/it/pool/SessionPoolIT.java | 550 +++++ .../src/test/resources/logback-test.xml | 2 +- .../src/test/resources/udf-example.jar | Bin 0 -> 10018 bytes .../apache/iotdb/integration/env/ClusterNode.java | 4 +- .../db/integration/IoTDBRewriteTsFileToolIT.java | 523 ++++- .../iotdb/db/integration/IoTDBTracingIT.java | 4 +- .../apache/iotdb/db/integration/IoTDBTtlIT.java | 4 +- .../apache/iotdb/session/pool/SessionPoolTest.java | 482 ----- .../apache/iotdb/session/template/TemplateUT.java | 400 ---- integration/src/test/resources/logback-test.xml | 2 +- jdbc/src/main/feature/feature.xml | 2 +- .../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 +- metrics/ReadMe.md | 9 +- metrics/dropwizard-metrics/pom.xml | 6 - .../dropwizard/DropwizardMetricManager.java | 2 +- .../resources/conf/iotdb-confignode-metric.yml | 51 + .../resources/conf/iotdb-datanode-metric.yml | 51 + .../main/assembly/resources/conf/iotdb-metric.yml | 56 - .../iotdb/metrics/AbstractMetricManager.java | 47 +- .../iotdb/metrics/AbstractMetricService.java | 19 +- .../iotdb/metrics/DoNothingMetricService.java | 6 - .../apache/iotdb/metrics/config/MetricConfig.java | 17 +- .../metrics/config/MetricConfigDescriptor.java | 32 +- .../iotdb/metrics/config/MetricConstant.java | 4 +- .../iotdb/metrics/impl/DoNothingMetricManager.java | 2 +- .../metricsets/jvm/JvmClassLoaderMetrics.java | 52 + .../metrics/metricsets/jvm/JvmCompileMetrics.java | 54 + .../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 346 ++++ .../metrics/metricsets/jvm/JvmMemoryMetrics.java | 133 ++ .../iotdb/metrics/metricsets/jvm/JvmMetrics.java | 52 + .../metrics/metricsets/jvm/JvmThreadMetrics.java | 102 + .../iotdb/metrics/metricsets/jvm/JvmUtils.java | 46 + .../metrics/metricsets/logback/LogbackMetrics.java | 104 + .../metricsets/logback/MetricsTurboFilter.java | 98 + .../metricsets/predefined/PredefinedMetric.java | 33 - .../predefined/jvm/JvmClassLoaderMetrics.java | 52 - .../predefined/jvm/JvmCompileMetrics.java | 54 - .../metricsets/predefined/jvm/JvmGcMetrics.java | 346 ---- .../predefined/jvm/JvmMemoryMetrics.java | 133 -- .../metricsets/predefined/jvm/JvmMetrics.java | 52 - .../predefined/jvm/JvmThreadMetrics.java | 102 - .../metricsets/predefined/jvm/JvmUtils.java | 46 - .../predefined/logback/LogbackMetrics.java | 104 - .../predefined/logback/MetricsTurboFilter.java | 98 - .../iotdb/metrics/utils/IoTDBMetricsUtils.java | 2 +- .../org/apache/iotdb/metrics/utils/MetricInfo.java | 2 +- .../iotdb/metrics/config/MetricConfigTest.java | 1 - .../interface/src/test/resources/iotdb-metric.yml | 8 - .../micrometer/MicrometerMetricManager.java | 2 +- node-commons/pom.xml | 21 + .../resources/conf/iotdb-common.properties | 1241 ++++++++++++ .../iotdb/commons/client/ClientPoolFactory.java | 24 +- .../async/AsyncDataNodeInternalServiceClient.java | 2 +- .../apache/iotdb/commons/cluster/NodeStatus.java | 2 +- .../iotdb/commons/cluster/RegionRoleType.java | 10 +- .../apache/iotdb/commons/cluster/RegionStatus.java | 5 + .../apache/iotdb/commons/conf/CommonConfig.java | 30 +- .../iotdb/commons/conf/CommonDescriptor.java | 23 +- .../apache/iotdb/commons/conf/IoTDBConstant.java | 30 +- .../java/org/apache/iotdb/commons/cq/CQState.java | 45 + .../org/apache/iotdb/commons/cq/TimeoutPolicy.java | 45 + .../exception/sync/PipeSinkBeingUsedException.java | 2 +- .../commons/executable/ExecutableManager.java | 63 +- .../org/apache/iotdb/commons/path/PartialPath.java | 4 + .../apache/iotdb/commons/service/ServiceType.java | 31 +- .../commons/service/metric/MetricService.java | 123 ++ .../commons/service/metric/MetricServiceMBean.java | 30 + .../iotdb/commons/service/metric/enums/Metric.java | 69 + .../commons/service/metric/enums/Operation.java | 39 + .../iotdb/commons/service/metric/enums/Tag.java | 32 + .../apache/iotdb/commons/sync/pipe/PipeInfo.java | 6 +- .../apache/iotdb/commons/sync/pipe/PipeStatus.java | 44 +- .../iotdb/commons/sync/pipe/TsFilePipeInfo.java | 8 +- .../iotdb/commons/trigger/TriggerInformation.java | 30 +- .../apache/iotdb/commons/trigger/TriggerTable.java | 7 + .../trigger/service/TriggerExecutableManager.java | 2 + .../apache/iotdb/commons/udf/UDFInformation.java | 173 ++ .../org/apache/iotdb/commons/udf/UDFTable.java | 138 ++ .../BuiltinTimeSeriesGeneratingFunction.java | 3 +- .../apache/iotdb/commons/udf/builtin/UDTFM4.java | 311 +++ .../iotdb/commons/udf/service/SnapshotUtils.java | 96 - .../commons/udf/service/UDFClassLoaderManager.java | 5 +- .../commons/udf/service/UDFExecutableManager.java | 67 +- .../iotdb/commons/udf/service/UDFLogWriter.java | 83 - .../commons/udf/service/UDFManagementService.java | 341 ++++ .../udf/service/UDFRegistrationInformation.java | 82 - .../udf/service/UDFRegistrationService.java | 513 ----- .../commons/utils/ThriftCommonsSerDeUtils.java | 19 + .../commons/utils/ThriftConfigNodeSerDeUtils.java | 19 - openapi/pom.xml | 26 - pom.xml | 3 +- .../java/org/apache/iotdb/RewriteTsFileTool.java | 620 ++++-- .../resources/conf/schema-rocksdb.properties | 8 +- .../schemaregion/rocksdb/RSchemaRegion.java | 29 +- .../schemaregion/rocksdb/mnode/REntityMNode.java | 20 + .../schemaregion/rocksdb/mnode/RMNode.java | 20 + .../rocksdb/mnode/RStorageGroupMNode.java | 2 +- schema-engine-tag/README.md | 190 ++ schema-engine-tag/pom.xml | 81 + .../assembly/resources/conf/schema-tag.properties | 33 + .../src/assembly/schema-engine-tag.xml | 44 + .../metadata/tagSchemaRegion/TagSchemaRegion.java | 992 +++++++++ .../tagSchemaRegion/config/TagSchemaConfig.java | 55 + .../config/TagSchemaDescriptor.java | 93 + .../idtable/IDTableWithDeviceIDListImpl.java | 138 ++ .../tagIndex/ITagInvertedIndex.java | 61 + .../tagIndex/Request/DeletionRequest.java | 55 + .../tagIndex/Request/InsertionRequest.java | 59 + .../tagIndex/Request/QueryRequest.java | 46 + .../tagSchemaRegion/tagIndex/TagInvertedIndex.java | 183 ++ .../tagIndex/deletion/MemChunkDeletion.java | 57 + .../tagIndex/deletion/MemChunkGroupDeletion.java | 68 + .../tagIndex/deletion/MemTableDeletion.java | 77 + .../tagIndex/deletion/MemTableGroupDeletion.java | 66 + .../tagIndex/insertion/MemChunkGroupInsertion.java | 65 + .../tagIndex/insertion/MemChunkInsertion.java | 58 + .../tagIndex/insertion/MemTableGroupInsertion.java | 74 + .../tagIndex/insertion/MemTableInsertion.java | 67 + .../tagIndex/memtable/MemChunk.java | 54 + .../tagIndex/memtable/MemChunkGroup.java | 56 + .../tagIndex/memtable/MemTable.java | 87 + .../tagIndex/memtable/MemTableGroup.java | 102 + .../tagIndex/query/MemChunkGroupQuery.java | 61 + .../tagIndex/query/MemChunkQuery.java | 67 + .../tagIndex/query/MemTableGroupQuery.java | 59 + .../tagIndex/query/MemTableQuery.java | 72 + .../tagIndex/response/QueryResponse.java | 71 + .../tagSchemaRegion/tagIndex/wal/WALEntry.java | 134 ++ .../tagSchemaRegion/tagIndex/wal/WALManager.java | 141 ++ .../utils/MeasurementPathUtils.java | 80 + .../utils/PathTagConverterUtils.java | 70 + .../utils/ShowTimeSeriesResultUtils.java | 73 + .../iotdb/lsm/annotation/DeletionProcessor.java | 36 + .../iotdb/lsm/annotation/InsertionProcessor.java | 36 + .../iotdb/lsm/annotation/QueryProcessor.java | 36 + .../applicationcontext/ApplicationContext.java | 61 + .../ApplicationContextGenerator.java | 119 ++ .../requestcontext/DeleteRequestContext.java | 34 + .../requestcontext/FlushRequestContext.java | 33 + .../requestcontext/InsertRequestContext.java | 34 + .../requestcontext/QueryRequestContext.java | 34 + .../lsm/context/requestcontext/RequestContext.java | 108 + .../org/apache/iotdb/lsm/engine/ILSMEngine.java | 73 + .../org/apache/iotdb/lsm/engine/IRecoverable.java | 34 + .../org/apache/iotdb/lsm/engine/LSMEngine.java | 176 ++ .../apache/iotdb/lsm/engine/LSMEngineBuilder.java | 290 +++ .../lsm/levelProcess/BasicLevelProcessor.java | 79 + .../lsm/levelProcess/DeleteLevelProcessor.java | 39 + .../lsm/levelProcess/FlushLevelProcessor.java | 38 + .../iotdb/lsm/levelProcess/ILevelProcessor.java | 41 + .../lsm/levelProcess/InsertLevelProcessor.java | 39 + .../lsm/levelProcess/LevelProcessorChain.java | 45 + .../lsm/levelProcess/QueryLevelProcessor.java | 39 + .../apache/iotdb/lsm/manager/BasicLSMManager.java | 55 + .../apache/iotdb/lsm/manager/DeletionManager.java | 48 + .../org/apache/iotdb/lsm/manager/ILSMManager.java | 58 + .../apache/iotdb/lsm/manager/InsertionManager.java | 48 + .../org/apache/iotdb/lsm/manager/QueryManager.java | 32 + .../apache/iotdb/lsm/manager/RecoverManager.java | 49 + .../org/apache/iotdb/lsm/manager/WALManager.java | 126 ++ .../apache/iotdb/lsm/request/IDeletionRequest.java | 30 + .../iotdb/lsm/request/IInsertionRequest.java | 30 + .../apache/iotdb/lsm/request/IQueryRequest.java | 35 + .../org/apache/iotdb/lsm/request/IRequest.java | 61 + .../org/apache/iotdb/lsm/request/RequestType.java | 27 + .../org/apache/iotdb/lsm/response/IResponse.java | 46 + .../iotdb/lsm/strategy/BFSAccessStrategy.java | 66 + .../apache/iotdb/lsm/strategy/IAccessStrategy.java | 36 + .../lsm/strategy/PostOrderAccessStrategy.java | 56 + .../iotdb/lsm/strategy/PreOrderAccessStrategy.java | 54 + .../iotdb/lsm/strategy/RBFSAccessStrategy.java | 85 + .../java/org/apache/iotdb/lsm/wal/IWALReader.java | 48 + .../java/org/apache/iotdb/lsm/wal/IWALRecord.java | 50 + .../java/org/apache/iotdb/lsm/wal/IWALWriter.java | 47 + .../java/org/apache/iotdb/lsm/wal/WALReader.java | 99 + .../java/org/apache/iotdb/lsm/wal/WALWriter.java | 111 + .../tagSchemaRegion/TagSchemaRegionTest.java | 231 +++ .../idtable/IDTableWithDeviceIDListImplTest.java | 212 ++ .../tagIndex/TagTagInvertedIndexTest.java | 184 ++ server/pom.xml | 10 - .../resources/conf/iotdb-datanode.properties | 1125 +--------- .../assembly/resources/conf/logback-datanode.xml | 302 +++ server/src/assembly/resources/conf/logback.xml | 302 --- .../assembly/resources/sbin/remove-datanode.bat | 2 +- .../src/assembly/resources/sbin/remove-datanode.sh | 2 +- .../src/assembly/resources/sbin/start-datanode.bat | 2 +- .../src/assembly/resources/sbin/start-datanode.sh | 2 +- .../assembly/resources/sbin/start-new-server.bat | 2 +- .../assembly/resources/sbin/start-new-server.sh | 2 +- .../src/assembly/resources/sbin/start-server.bat | 2 +- server/src/assembly/resources/sbin/start-server.sh | 2 +- .../src/assembly/resources/sbin/stop-datanode.bat | 10 +- .../src/assembly/resources/sbin/stop-datanode.sh | 6 +- server/src/assembly/server.xml | 14 +- .../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +- .../apache/iotdb/db/client/ConfigNodeClient.java | 484 ++++- .../iotdb/db/client/DataNodeInternalClient.java | 119 ++ .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 81 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 174 +- .../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 101 + .../iotdb/db/engine/TsFileMetricManager.java | 7 +- .../apache/iotdb/db/engine/cache/ChunkCache.java | 2 +- .../iotdb/db/engine/cache/ChunkCacheMetrics.java | 4 +- .../db/engine/cache/TimeSeriesMetadataCache.java | 2 +- .../cache/TimeSeriesMetadataCacheMetrics.java | 4 +- .../org/apache/iotdb/db/engine/cq/CQLogReader.java | 47 - .../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 74 - .../engine/cq/ContinuousQuerySchemaCheckTask.java | 99 - .../iotdb/db/engine/cq/ContinuousQueryService.java | 305 --- .../iotdb/db/engine/cq/ContinuousQueryTask.java | 200 -- .../engine/cq/ContinuousQueryTaskPoolManager.java | 107 - .../apache/iotdb/db/engine/flush/FlushManager.java | 2 +- .../iotdb/db/engine/flush/FlushManagerMetrics.java | 4 +- .../iotdb/db/engine/flush/MemTableFlushTask.java | 6 +- .../iotdb/db/engine/memtable/AbstractMemTable.java | 6 +- .../iotdb/db/engine/storagegroup/DataRegion.java | 6 +- .../db/engine/storagegroup/DataRegionMetrics.java | 4 +- .../db/engine/storagegroup/TsFileProcessor.java | 17 +- .../engine/storagegroup/TsFileProcessorInfo.java | 2 +- .../storagegroup/TsFileProcessorInfoMetrics.java | 6 +- .../iotdb/db/exception/IntoProcessException.java | 27 + .../SchemaFileLogCorruptedException.java | 34 + .../exception/query/PathNumOverLimitException.java | 2 +- .../exception/sql/PathNumOverLimitException.java | 2 +- .../iotdb/db/localconfignode/LocalConfigNode.java | 2 +- .../db/metadata/cache/DataNodeSchemaCache.java | 2 +- .../metadata/cache/DataNodeSchemaCacheMetrics.java | 4 +- .../db/metadata/idtable/entry/DiskSchemaEntry.java | 9 + .../idtable/entry/InsertMeasurementMNode.java | 20 + .../iotdb/db/metadata/mnode/EntityMNode.java | 38 + .../iotdb/db/metadata/mnode/IEntityMNode.java | 8 + .../org/apache/iotdb/db/metadata/mnode/IMNode.java | 8 + .../iotdb/db/metadata/mnode/InternalMNode.java | 41 +- .../iotdb/db/metadata/mnode/MeasurementMNode.java | 14 + .../iotdb/db/metadata/mtree/ConfigMTree.java | 77 +- .../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 66 + .../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 392 +++- .../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 262 ++- .../iotdb/db/metadata/mtree/store/IMTreeStore.java | 14 + .../db/metadata/mtree/store/MemMTreeStore.java | 2 +- .../mtree/store/disk/schemafile/ISchemaPage.java | 3 + .../mtree/store/disk/schemafile/InternalPage.java | 2 +- .../store/disk/schemafile/MockSchemaFile.java | 2 +- .../mtree/store/disk/schemafile/SchemaFile.java | 51 +- .../store/disk/schemafile/SchemaFileConfig.java | 28 +- .../mtree/store/disk/schemafile/SchemaPage.java | 14 +- .../mtree/store/disk/schemafile/SegmentedPage.java | 7 + .../disk/schemafile/log/SchemaFileLogReader.java | 112 + .../schemafile/log/SchemaFileLogSerializer.java | 34 + .../disk/schemafile/log/SchemaFileLogWriter.java | 68 + .../disk/schemafile/pagemgr/BTreePageManager.java | 7 +- .../disk/schemafile/pagemgr/IPageManager.java | 2 + .../store/disk/schemafile/pagemgr/PageManager.java | 146 +- .../db/metadata/mtree/traverser/Traverser.java | 19 +- .../traverser/collector/MeasurementCollector.java | 3 +- .../plan/schemaregion/SchemaRegionPlanType.java | 6 +- .../plan/schemaregion/SchemaRegionPlanVisitor.java | 17 + .../impl/ActivateTemplateInClusterPlanImpl.java | 8 +- .../impl/DeactivateTemplatePlanImpl.java | 41 + .../impl/PreDeactivateTemplatePlanImpl.java | 41 + .../RollbackPreDeactivateTemplatePlanImpl.java | 41 + .../impl/SchemaRegionPlanDeserializer.java | 43 + .../schemaregion/impl/SchemaRegionPlanFactory.java | 6 + .../impl/SchemaRegionPlanSerializer.java | 51 + .../impl/SchemaRegionPlanTxtSerializer.java | 35 + .../write/IActivateTemplateInClusterPlan.java | 4 +- .../write/IDeactivateTemplatePlan.java | 45 + .../write/IPreDeactivateTemplatePlan.java | 45 + .../write/IRollbackPreDeactivateTemplatePlan.java | 45 + .../db/metadata/rescon/SchemaResourceManager.java | 2 +- .../rescon/SchemaStatisticsManagerMetrics.java | 4 +- .../db/metadata/schemaregion/ISchemaRegion.java | 17 +- .../db/metadata/schemaregion/SchemaEngine.java | 46 +- .../schemaregion/SchemaRegionMemoryImpl.java | 172 +- .../schemaregion/SchemaRegionSchemaFileImpl.java | 164 +- .../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +- .../metadata/template/ClusterTemplateManager.java | 28 +- .../iotdb/db/metadata/template/Template.java | 5 +- .../metadata/template/TemplateInternalRPCUtil.java | 99 + .../metadata/visitor/SchemaExecutionVisitor.java | 38 + .../iotdb/db/mpp/common/MPPQueryContext.java | 19 +- .../org/apache/iotdb/db/mpp/common/QueryId.java | 2 + .../apache/iotdb/db/mpp/common/SessionInfo.java | 19 + .../db/mpp/common/header/ColumnHeaderConstant.java | 13 + .../db/mpp/common/header/DatasetHeaderFactory.java | 4 + .../db/mpp/execution/exchange/ISourceHandle.java | 10 + .../mpp/execution/exchange/LocalSourceHandle.java | 21 + .../execution/exchange/MPPDataExchangeService.java | 2 +- .../exchange/MPPDataExchangeServiceMetrics.java | 4 +- .../MPPDataExchangeServiceThriftHandler.java | 2 +- ...MppDataExchangeServiceThriftHandlerMetrics.java | 6 +- .../db/mpp/execution/exchange/SourceHandle.java | 22 +- .../execution/executor/RegionWriteExecutor.java | 31 + .../fragment/FragmentInstanceContext.java | 29 +- .../fragment/FragmentInstanceManager.java | 6 +- .../db/mpp/execution/operator/OperatorContext.java | 5 + .../operator/process/AbstractIntoOperator.java | 384 ++++ .../operator/process/DeviceViewIntoOperator.java | 140 ++ .../execution/operator/process/IntoOperator.java | 104 + .../process/RawDataAggregationOperator.java | 2 +- .../process/SingleInputAggregationOperator.java | 2 - .../process/SlidingWindowAggregationOperator.java | 2 +- .../operator/process/TransformOperator.java | 6 +- .../schema/PathsUsingTemplateScanOperator.java | 21 +- .../schema/TimeSeriesSchemaScanOperator.java | 9 +- .../execution/schedule/AbstractDriverThread.java | 60 +- .../db/mpp/execution/schedule/DriverScheduler.java | 38 +- .../mpp/execution/schedule/DriverTaskThread.java | 5 +- .../schedule/DriverTaskTimeoutSentinelThread.java | 5 +- .../db/mpp/execution/schedule/ThreadProducer.java | 32 + .../org/apache/iotdb/db/mpp/plan/Coordinator.java | 15 +- .../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 12 + .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 65 +- .../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 22 +- .../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 6 +- .../db/mpp/plan/analyze/ExpressionAnalyzer.java | 26 + .../iotdb/db/mpp/plan/constant/StatementType.java | 2 + .../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 | 65 +- .../config/executor/ClusterConfigTaskExecutor.java | 474 ++++- .../config/executor/IConfigTaskExecutor.java | 28 +- .../executor/StandaloneConfigTaskExecutor.java | 110 +- .../config/metadata/CreateContinuousQueryTask.java | 49 + .../config/metadata/CreateFunctionTask.java | 15 +- .../config/metadata/DropContinuousQueryTask.java | 42 + .../execution/config/metadata/ShowClusterTask.java | 4 +- .../config/metadata/ShowContinuousQueriesTask.java | 75 + .../config/metadata/ShowFunctionsTask.java | 160 +- .../template/DeactivateSchemaTemplateTask.java | 45 + .../metadata/template/DropSchemaTemplateTask.java | 42 + .../metadata/template/UnsetSchemaTemplateTask.java | 45 + .../execution/config/sys/sync/ShowPipeTask.java | 3 +- .../plan/execution/memory/MemorySourceHandle.java | 22 + .../memory/StatementMemorySourceVisitor.java | 9 +- .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 262 ++- .../db/mpp/plan/parser/StatementGenerator.java | 18 +- .../db/mpp/plan/planner/LogicalPlanBuilder.java | 47 +- .../db/mpp/plan/planner/LogicalPlanVisitor.java | 11 +- .../db/mpp/plan/planner/OperatorTreeGenerator.java | 125 +- .../planner/distribution/ExchangeNodeAdder.java | 6 +- .../SimpleFragmentParallelPlanner.java | 1 + .../plan/planner/distribution/SourceRewriter.java | 99 +- .../distribution/WriteFragmentParallelPlanner.java | 3 +- .../db/mpp/plan/planner/plan/FragmentInstance.java | 22 +- .../plan/planner/plan/node/PlanGraphPrinter.java | 53 + .../mpp/plan/planner/plan/node/PlanNodeType.java | 22 +- .../db/mpp/plan/planner/plan/node/PlanVisitor.java | 25 + .../metedata/read/AbstractSchemaMergeNode.java | 5 + .../node/metedata/read/CountSchemaMergeNode.java | 5 + .../plan/node/metedata/read/DevicesCountNode.java | 6 + .../metedata/read/LevelTimeSeriesCountNode.java | 7 + .../read/NodeManagementMemoryMergeNode.java | 5 + .../node/metedata/read/NodePathsConvertNode.java | 5 + .../node/metedata/read/NodePathsCountNode.java | 5 + .../metedata/read/NodePathsSchemaScanNode.java | 7 + .../metedata/read/PathsUsingTemplateScanNode.java | 43 +- .../node/metedata/read/SchemaFetchScanNode.java | 2 +- .../node/metedata/read/SchemaQueryMergeNode.java | 2 +- .../metedata/read/SchemaQueryOrderByHeatNode.java | 4 +- .../node/metedata/read/SchemaQueryScanNode.java | 12 +- .../node/metedata/read/TimeSeriesCountNode.java | 7 + .../metedata/write/DeactivateTemplateNode.java | 128 ++ .../metedata/write/PreDeactivateTemplateNode.java | 128 ++ .../write/RollbackPreDeactivateTemplateNode.java | 130 ++ .../planner/plan/node/process/AggregationNode.java | 23 +- .../planner/plan/node/process/DeviceMergeNode.java | 32 +- .../plan/node/process/DeviceViewIntoNode.java | 117 ++ .../planner/plan/node/process/DeviceViewNode.java | 19 +- .../planner/plan/node/process/ExchangeNode.java | 41 +- .../plan/planner/plan/node/process/FillNode.java | 46 +- .../plan/node/process/GroupByLevelNode.java | 29 +- .../planner/plan/node/process/GroupByTagNode.java | 17 +- .../plan/planner/plan/node/process/IntoNode.java | 114 ++ .../plan/planner/plan/node/process/LimitNode.java | 37 +- .../planner/plan/node/process/MultiChildNode.java | 66 - .../plan/node/process/MultiChildProcessNode.java | 81 + .../plan/planner/plan/node/process/OffsetNode.java | 36 +- .../planner/plan/node/process/ProjectNode.java | 40 +- .../plan/node/process/SingleChildProcessNode.java | 92 + .../node/process/SlidingWindowAggregationNode.java | 36 +- .../plan/planner/plan/node/process/SortNode.java | 29 +- .../planner/plan/node/process/TimeJoinNode.java | 17 +- .../planner/plan/node/process/TransformNode.java | 29 +- .../node/process/last/LastQueryCollectNode.java | 4 +- .../plan/node/process/last/LastQueryMergeNode.java | 4 +- .../plan/node/process/last/LastQueryNode.java | 4 +- .../parameter/DeviceViewIntoPathDescriptor.java | 11 +- .../planner/plan/parameter/IntoPathDescriptor.java | 10 +- .../plan/scheduler/load/LoadTsFileScheduler.java | 6 +- .../db/mpp/plan/statement/StatementVisitor.java | 36 + .../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 | 20 +- .../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 + .../plan/statement/crud/LoadTsFileStatement.java | 4 + .../db/mpp/plan/statement/crud/QueryStatement.java | 116 +- .../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 | 28 +- .../statement/metadata/CreateTriggerStatement.java | 19 +- .../metadata/DropContinuousQueryStatement.java | 60 + .../metadata/ShowContinuousQueriesStatement.java | 52 + .../template/DeactivateTemplateStatement.java | 80 + .../template/DropSchemaTemplateStatement.java | 55 + .../template/ShowPathsUsingTemplateStatement.java | 22 +- .../template/UnsetSchemaTemplateStatement.java | 74 + .../mpp/transformation/dag/udf/UDTFExecutor.java | 4 +- .../dag/udf/UDTFInformationInferrer.java | 4 +- .../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 18 +- .../influxdb/handler/AbstractQueryHandler.java | 90 +- .../protocol/influxdb/handler/NewQueryHandler.java | 114 +- .../db/protocol/influxdb/handler/QueryHandler.java | 521 ----- .../influxdb/handler/QueryHandlerFactory.java | 45 + .../protocol/influxdb/handler/TagQueryHandler.java | 140 ++ .../influxdb/meta/AbstractInfluxDBMetaManager.java | 46 +- .../influxdb/meta/IInfluxDBMetaManager.java | 66 + .../influxdb/meta/InfluxDBMetaManager.java | 150 -- .../influxdb/meta/InfluxDBMetaManagerFactory.java | 45 + .../influxdb/meta/NewInfluxDBMetaManager.java | 61 +- .../influxdb/meta/TagInfluxDBMetaManager.java | 191 ++ .../protocol/influxdb/util/QueryResultUtils.java | 102 +- .../iotdb/db/protocol/mpprest/MPPRestService.java | 162 -- .../protocol/mpprest/filter/ApiOriginFilter.java | 45 - .../mpprest/filter/AuthorizationFilter.java | 138 -- .../mpprest/filter/BasicSecurityContext.java | 56 - .../iotdb/db/protocol/mpprest/filter/User.java | 38 - .../db/protocol/mpprest/filter/UserCache.java | 56 - .../mpprest/handler/AuthorizationHandler.java | 47 - .../protocol/mpprest/handler/ExceptionHandler.java | 86 - .../mpprest/handler/QueryDataSetHandler.java | 279 --- .../mpprest/handler/RequestValidationHandler.java | 53 - .../handler/StatementConstructionHandler.java | 165 -- .../mpprest/impl/GrafanaApiServiceImpl.java | 268 --- .../protocol/mpprest/impl/PingApiServiceImpl.java | 51 - .../protocol/mpprest/impl/RestApiServiceImpl.java | 203 -- .../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 41 +- .../db/protocol/mqtt/PayloadFormatManager.java | 5 +- .../iotdb/db/protocol/mqtt/PublishHandler.java | 149 -- .../apache/iotdb/db/protocol/rest/RestService.java | 1 + .../rest/handler/AuthorizationHandler.java | 10 +- .../db/protocol/rest/handler/ExceptionHandler.java | 13 +- .../handler/PhysicalPlanConstructionHandler.java | 163 -- .../handler/PhysicalPlanValidationHandler.java | 81 - .../protocol/rest/handler/QueryDataSetHandler.java | 331 ++- .../rest/handler/StatementConstructionHandler.java | 165 ++ .../protocol/rest/impl/GrafanaApiServiceImpl.java | 183 +- .../db/protocol/rest/impl/RestApiServiceImpl.java | 152 +- .../main/java/org/apache/iotdb/db/qp/Planner.java | 19 - .../apache/iotdb/db/qp/executor/PlanExecutor.java | 90 +- .../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 2 +- .../sys/ActivateTemplateInClusterPlan.java | 8 +- .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 59 +- .../apache/iotdb/db/qp/utils/DateTimeUtils.java | 4 +- .../iotdb/db/query/context/QueryContext.java | 14 +- .../db/query/control/QueryResourceManager.java | 11 +- .../iotdb/db/query/control/QueryTimeManager.java | 46 +- .../iotdb/db/query/control/SessionManager.java | 412 ++-- .../db/query/control/SessionManagerMBean.java | 30 + .../db/query/control/SessionTimeoutManager.java | 119 -- .../query/control/clientsession/ClientSession.java | 115 ++ .../control/clientsession/IClientSession.java | 137 ++ .../clientsession/InternalClientSession.java | 97 + .../control/clientsession/MqttClientSession.java | 82 + .../apache/iotdb/db/query/dataset/UDTFDataSet.java | 6 +- .../apache/iotdb/db/query/executor/fill/IFill.java | 2 +- .../db/query/pool/RawQueryReadTaskPoolManager.java | 2 +- .../pool/RawQueryReadTaskPoolManagerMetrics.java | 4 +- .../java/org/apache/iotdb/db/service/DataNode.java | 198 +- .../db/service/DataNodeInternalRPCService.java | 4 +- .../service/DataNodeInternalRPCServiceMetrics.java | 4 +- .../db/service/DataNodeServerCommandLine.java | 10 +- .../java/org/apache/iotdb/db/service/IoTDB.java | 29 +- .../org/apache/iotdb/db/service/MQTTService.java | 3 +- .../java/org/apache/iotdb/db/service/NewIoTDB.java | 22 +- .../org/apache/iotdb/db/service/RPCService.java | 2 +- .../apache/iotdb/db/service/RPCServiceMetrics.java | 4 +- .../db/service/ResourcesInformationHolder.java | 12 + .../iotdb/db/service/basic/ServiceProvider.java | 1 - .../db/service/metrics/DataNodeMetricsHelper.java | 39 + .../iotdb/db/service/metrics/FileMetrics.java | 200 ++ .../iotdb/db/service/metrics/MetricService.java | 156 -- .../db/service/metrics/MetricServiceMBean.java | 30 - .../iotdb/db/service/metrics/ProcessMetrics.java | 189 ++ .../iotdb/db/service/metrics/SystemMetrics.java | 260 +++ .../iotdb/db/service/metrics/enums/Metric.java | 70 - .../iotdb/db/service/metrics/enums/Operation.java | 39 - .../apache/iotdb/db/service/metrics/enums/Tag.java | 31 - .../db/service/metrics/predefined/FileMetrics.java | 200 -- .../service/metrics/predefined/ProcessMetrics.java | 189 -- .../service/metrics/predefined/SystemMetrics.java | 256 --- .../metrics/recorder/CacheMetricsRecorder.java | 6 +- .../recorder/CompactionMetricsRecorder.java | 6 +- .../db/service/thrift/ProcessorWithMetrics.java | 6 +- .../thrift/handler/BaseServerContextHandler.java | 79 + .../handler/InfluxDBServiceThriftHandler.java | 11 +- .../handler/InternalServiceThriftHandler.java | 2 +- .../InternalServiceThriftHandlerMetrics.java | 4 +- .../thrift/handler/RPCServiceThriftHandler.java | 21 +- .../handler/RPCServiceThriftHandlerMetrics.java | 4 +- .../service/thrift/impl/ClientRPCServiceImpl.java | 830 ++++---- .../impl/DataNodeInternalRPCServiceImpl.java | 393 +++- .../service/thrift/impl/InfluxDBServiceImpl.java | 184 -- .../thrift/impl/NewInfluxDBServiceImpl.java | 75 +- .../db/service/thrift/impl/TSServiceImpl.java | 416 ++-- .../java/org/apache/iotdb/db/sync/SyncService.java | 142 +- .../db/sync/common/ClusterSyncInfoFetcher.java | 14 +- .../sync/pipedata/queue/BufferedPipeDataQueue.java | 70 +- .../db/sync/receiver/load/DeletionLoader.java | 52 +- .../iotdb/db/sync/receiver/load/ILoader.java | 20 + .../iotdb/db/sync/receiver/load/TsFileLoader.java | 58 +- .../db/sync/transport/server/ReceiverManager.java | 2 +- .../iotdb/db/trigger/executor/TriggerExecutor.java | 14 +- .../db/trigger/executor/TriggerFireVisitor.java | 42 +- .../trigger/service/TriggerInformationUpdater.java | 104 + .../trigger/service/TriggerManagementService.java | 39 +- .../java/org/apache/iotdb/db/utils/FilesUtils.java | 43 + .../org/apache/iotdb/db/utils/JarLoaderUtil.java | 150 -- .../apache/iotdb/db/utils/QueryDataSetUtils.java | 27 + .../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 12 +- .../java/org/apache/iotdb/db/wal/WALManager.java | 24 +- .../iotdb/db/wal/allocation/ElasticStrategy.java | 103 + .../db/wal/allocation/RoundRobinStrategy.java | 4 +- .../java/org/apache/iotdb/db/wal/node/WALNode.java | 79 +- .../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 6 +- .../engine/compaction/CompactionSchedulerTest.java | 3 + .../inner/InnerCompactionMoreDataTest.java | 3 + .../engine/modification/DeletionFileNodeTest.java | 433 ---- .../db/engine/modification/DeletionQueryTest.java | 362 ---- .../idtable/IDTableResourceControlTest.java | 167 -- .../db/metadata/idtable/IDTableRestartTest.java | 205 -- .../db/metadata/idtable/InsertWithIDTableTest.java | 759 ------- .../QueryAlignedTimeseriesWithIDTableTest.java | 373 ---- .../db/metadata/idtable/QueryWithIDTableTest.java | 375 ---- .../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 2 +- .../mtree/schemafile/SchemaFileLogTest.java | 156 ++ .../metadata/mtree/schemafile/SchemaFileTest.java | 25 +- .../plan/SchemaRegionPlanCompatibilityTest.java | 22 +- .../schemaRegion/SchemaRegionBasicTest.java | 315 +++ .../schemaRegion/SchemaRegionSnapshotTest.java | 168 ++ .../db/metadata/schemaRegion/SchemaRegionTest.java | 168 -- .../multimode/SchemaRegionFullMemoryTest.java | 43 + .../multimode/SchemaRegionMemoryTest.java | 46 + .../multimode/SchemaRegionNonMemoryTest.java | 43 + .../multimode/SchemaRegionPartialMemoryTest.java | 43 + .../multimode/SchemaRegionSchemaFileTest.java | 46 + .../apache/iotdb/db/metric/MetricServiceTest.java | 19 + .../mpp/execution/operator/OperatorMemoryTest.java | 6 +- .../DriverTaskTimeoutSentinelThreadTest.java | 23 +- .../db/mpp/plan/StandaloneCoordinatorTest.java | 17 +- .../iotdb/db/mpp/plan/analyze/AnalyzeFailTest.java | 87 +- .../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 8 +- .../mpp/plan/plan/FragmentInstanceSerdeTest.java | 10 +- .../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 40 + .../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 11 +- .../plan/plan/node/process/IntoNodeSerdeTest.java | 83 + .../plan/scheduler/StandaloneSchedulerTest.java | 18 +- .../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 132 -- .../db/protocol/rest/GrafanaApiServiceTest.java | 3 + .../db/protocol/rest/IoTDBRestServiceTest.java | 3 + .../iotdb/db/qp/physical/InsertRowPlanTest.java | 395 ---- .../db/qp/physical/InsertTabletMultiPlanTest.java | 300 --- .../iotdb/db/qp/physical/InsertTabletPlanTest.java | 449 ---- .../iotdb/db/qp/physical/PhysicalPlanTest.java | 29 +- .../dataset/EngineDataSetWithValueFilterTest.java | 159 -- .../query/dataset/UDTFAlignByTimeDataSetTest.java | 2 + .../query/dataset/groupby/GroupByDataSetTest.java | 226 --- .../dataset/groupby/GroupByFillDataSetTest.java | 194 -- .../dataset/groupby/GroupByLevelDataSetTest.java | 161 -- .../valuefilter/RawQueryWithValueFilterTest.java | 147 -- .../apache/iotdb/db/sink/LocalIoTDBSinkTest.java | 218 -- .../org/apache/iotdb/db/sink/MQTTSinkTest.java | 210 -- .../sync/pipedata/BufferedPipeDataQueueTest.java | 98 + .../iotdb/db/sync/pipedata/PipeDataTest.java | 21 +- .../iotdb/db/sync/transport/SyncTransportTest.java | 357 ---- .../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 246 --- .../iotdb/db/tools/SchemaFileSketchTest.java | 2 +- .../apache/iotdb/db/utils/EnvironmentUtils.java | 17 +- .../iotdb/db/utils/TsFileRewriteToolTest.java | 47 +- .../org/apache/iotdb/db/wal/WALManagerTest.java | 14 +- .../db/wal/allocation/ElasticStrategyTest.java | 130 ++ .../db/wal/allocation/FirstCreateStrategyTest.java | 3 - .../db/wal/allocation/RoundRobinStrategyTest.java | 3 - .../datanode1conf/iotdb-datanode.properties | 28 +- .../test/resources/datanode1conf/iotdb-metric.yml | 7 +- .../datanode2conf/iotdb-datanode.properties | 28 +- .../test/resources/datanode2conf/iotdb-metric.yml | 7 +- .../datanode3conf/iotdb-datanode.properties | 28 +- .../test/resources/datanode3conf/iotdb-metric.yml | 7 +- .../src/test/resources/iotdb-datanode.properties | 10 +- server/src/test/resources/logback-test.xml | 2 +- service-rpc/pom.xml | 8 + .../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 345 ++-- .../apache/iotdb/rpc/TElasticFramedTransport.java | 4 + .../java/org/apache/iotdb/rpc/TSStatusCode.java | 19 +- .../rpc/TimeoutChangeableTFastFramedTransport.java | 8 +- .../TimeoutChangeableTSnappyFramedTransport.java | 8 +- .../java/org/apache/iotdb/session/ISession.java | 9 +- .../java/org/apache/iotdb/session/Session.java | 272 ++- .../org/apache/iotdb/session/SessionConfig.java | 2 +- .../apache/iotdb/session/SessionConnection.java | 43 +- .../org/apache/iotdb/session/SessionDataSet.java | 29 +- .../org/apache/iotdb/session/pool/SessionPool.java | 361 +++- .../apache/iotdb/session/SessionCacheLeaderUT.java | 4 +- site/src/main/.vuepress/config.js | 4 +- .../apache/iotdb/spark/db/EnvironmentUtils.java | 6 +- .../org/apache/iotdb/spark/db/IoTDBTest.scala | 2 + .../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 1 + .../java/org/apache/iotdb/db/sql/ClusterIT.java | 2 +- .../src/test/resources/iotdb-datanode.properties | 2 +- .../src/main/thrift/confignode.thrift | 172 +- .../src/main/thrift/mutlileader.thrift | 21 + thrift/src/main/thrift/client.thrift | 39 +- thrift/src/main/thrift/datanode.thrift | 96 +- .../iotdb/tsfile/common/conf/TSFileConfig.java | 14 +- .../iotdb/tsfile/common/conf/TSFileDescriptor.java | 4 +- .../org/apache/iotdb/tsfile/read/common/Path.java | 72 +- .../java/org/apache/iotdb/tsfile/utils/BitMap.java | 6 + .../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +- .../iotdb/tsfile/utils/ReadWriteIOUtils.java | 28 + .../apache/iotdb/tsfile/utils/BytesUtilsTest.java | 47 + .../udf/api/exception/UDFManagementException.java | 32 + .../api/exception/UDFRegistrationException.java | 32 - .../zeppelin/iotdb/IoTDBInterpreterTest.java | 3 + 1078 files changed, 58316 insertions(+), 33964 deletions(-) diff --cc thrift/src/main/thrift/client.thrift index 49dc875de5,61744021c8..51b0d24c29 --- a/thrift/src/main/thrift/client.thrift +++ b/thrift/src/main/thrift/client.thrift @@@ -547,5 -559,5 +580,7 @@@ service IClientRPCService common.TSStatus sendFile(1:TSyncTransportMetaInfo metaInfo, 2:binary buff); + TSConnectionInfoResp fetchAllConnectionsInfo(); ++ + TFetchWindowSetResp fetchWindowSet(1:TFetchWindowSetReq req) }
