You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/10/31 08:49:28 UTC
[iotdb] 01/02: Merge remote-tracking branch 'origin/master' into ml/windowSet
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 <li...@foxmail.com>
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)
}