You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/11/28 08:34:48 UTC
[iotdb] branch QueryMetrics updated (40717cc921 -> 6da84a5b0b)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch QueryMetrics
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 40717cc921 Merge remote-tracking branch 'origin/master' into QueryMetrics
add b88f23361a Fix go ci (#8039)
add 8755c3fbea Remove useless code of schema template for old standalone (#8058)
add 0cf7e521e9 [IOTDB-4841] Upgrade user guide (query part) (#7879)
add 3b8f005d67 update go client (#8066)
add de1d96aa36 Fix a document typo about status code 503 (#8067)
add 76e1bc032d Fix wal ut error when serializing and deserializing (#8069)
add a424df0191 Delete useless class SchemaRegion defined in MPP (#8072)
add 1350323cf7 Remove all trigger code for old standalone from schema module (#8071)
add 5b8c18ab04 Update distribution package structure (#8070)
add c7c239c4ba Fix segment size estimation (#8003)
add 1bb7b0ac5e Remove code of last cache for old standalone (#8075)
add b42f87f6a7 Rename schema describer scripts and related docs (#8074)
add bc97eee3a9 Fix the bug that the AggregationNode is always Final (#8073)
add 6193de436c Fix potential NPE exception (#8079)
add 37c310fc8a [IOTDB-5011] Fix session connection failure when start datanode using iotdb reporter (#8080)
add 92c98dddb8 Remove useless code in schema module (#8084)
add 66a23130b7 [IOTDB-4999] Configure maximum of connection for config node internal service (#8086)
add 93b936ed71 [IOTDB-5014] Fix ratis param (#8083)
add 6c70719095 [IOTDB-5007] Changed the logic of register unclean datanode (#8077)
add 531577765b [IOTDB-4993] Rename the storage group of permissions to database (#8054)
add 92d2d2a379 [doc] Adjust the data file section of the Quick Start chapter and rearrange the file classification (#7978)
add 55bc50e53e [IOTDB-4968] Auto register sg error in sync receiver and OOM (#8034)
add fe48dff712 Add dn_sync_dir in iotdb-datanode.properties (#8094)
add 74077572fe [IOTDB-5022] Deleted the redundant Xlog:gc in datanode-env.bat (#8098)
add 44e0419dbc add relase note 0.12.5, 0.13.3 (#8099)
add 32e2f982c2 Support Create timeseries with deadband field (#8093)
add 08414361dc Remove unused scripts (#8092)
add 843741691b [IOTDB-5024] Fix same tag keys in metrics #8101
add 0740d7face [IOTDB-5008] Fix SHUTDOWN errors in ratis create peer (#8076) (#8088)
add 67d9cc487e fix CSV-Tool doc
add b9e50cbb84 Add schema template lifecycle description and strengthen sql constraints (#8100)
add 63182c1ee3 [IOTDB-5002] Move metric related config into properties file and modify distribution structure (#8096)
add b8076e09fc Split syntax convetion doc into multiple files for better display (#8104)
add 8546175048 add data load export tool document (#8107)
add ea1500ed72 [IOTDB-5018] Fix NPE when using uppercase function name in GROUP BY LEVEL (#8108)
add beb1ac2438 [IOTDB-4926] Add error message when the key of parameter attributes is not quoted (#8089)
add d871670848 remove node tool of 0.13 cluster (#8109)
add f748e5cfed [IOTDB-5023] Improve Schema Count operation to return long (#8105)
add 29b7f48f05 [IOTDB-4983] Greedy leader balancing policy (#8057)
add 819ca649c0 Fix some format error about database in docs (#8111)
add f3f267b2a9 [IOTDB-5012] Update Deployment and User doc for cluster V1.0 (#8091)
add c530774ae6 Better schema file printer, not limited by length anymore (#8087)
add 85c488e708 Set namespace to generated go files (#8112)
add 1c01608849 [IOTDB-4881] Add feature StorageGroup fast activation (#7944)
add 03c826930a [IOTDB-5027] The RegionRouteMap doesn't update after the leader Node is Unknown (#8106)
add 91a279a8a6 [IOTDB-4972] Fix NPE when validate schema without auto create schema (#8115)
add 6eca1ec092 Unify Column Header in RestApi (#8114)
add d0b1515d6b remove stale vis tool (#8116)
add 633cf37b1c [IOTDB-4947] Add Internal Reporter in metric module (#8081)
add bdd7e1b9ca Grafana plugin request and return parameter adjustment (#8117)
add de2617c172 [IOTDB-4855] [MultiLeader] Strength the memory control (#8025)
add a59e4a1bbe Remove old SQL parser code (#8113)
add 555f1d5bc1 Delete time-consuming check in TypeProvider (#8118)
add cd839a4337 optimize the distribution plan for aggregation with align by device (#8119)
add 5c3f4e12fd [IOTDB-5032] ConfigNode and DataNode Manual and User doc for cluster V1.0 (#8121)
add a92b895eea [IOTDB-4830] Fixed some bugs when removing an unknown node (#8068)
add 24de040d1f Fix tsfile split tool doc and move Status-Codes to Reference (#8124)
add 3b2bd8198d Fix typo in user guide (#8127)
add d9227e79fb [IOTDB-5033] Fix deadlock in memory pool (#8123)
add a04c7023c7 Catch Throwable in DataNodeInternalService to avoid ambiguous TException (#8126)
add ce92432c8c Remove start-new-server scripts (#8128)
add 4da2f1bf4f [IOTDB-4556] Optimize log of failing to flush sync index (#8090)
add 3103c12a00 [IOTDB-5006]Add a load-tsfile script (#8120)
add ac3b408da8 [IOTDB-5010] DataRegion StateMachine support for Ratis Snapshot (#8110)
add fbca630b0a Add dispatch node endpoint msg to error log (#8132)
add 94414ad041 remove duplicate code in the PlanNodeIterator (#8122)
add 76542ea665 [IOTDB-5031] Make snapshot taking in shutdown hook parallel (#8134)
add f30463ff30 [IOTDB-5019] Fix releasing wal files after flushing memtable (#8131)
add 3775e9277e fix the issue that client get 305 when explain non-existing series (#8145)
add b762675f22 Make memory portion take effect after change the default ratio (#8137)
add 443c30293f Fix abstract map bug when remove failing measurement (#8139)
add dd250fc49b Remove redundant PartialPath init in TsFileProcessor (#8153)
add df7eb81932 [IOTDB-4556] change the log level from warn to info in IndexController (#8149)
add 24cd97d101 [IOTDB-5040] Common Config Manual for cluster V1.0 (#8142)
add 444bfade77 update trigger jar
add 9f12b58c0b [IOTDB-5028] Using `show timeseries` to query the schema in import-csv (#8130)
add 91aa0341ae [IOTDB-4994] Unify reporter (#8144)
add 26bcaea5d7 Add readme docs for TsFile tools (#8154)
add e9b287c064 Update auth config (#8162)
add c1cd52be0a change log level of RatisConsensus(#8146)
add 818c3e6272 Update description of missing params to user-guide (#8157)
add 713f03ba74 Update doc of mem control (#8159)
add bcd0305f70 Fix the issue when doing distribution plan for aggregation
add b0c2d67f41 make simple consensuse as default for confignode (#8160)
add 1eb95896db add mqtt broker and rest service document (#8161)
add 53d69a7d33 Split trigger doc into muitlple files for better display (#8169)
add 4cd5a5d5d6 Update user guide (query part/en) (#8168)
add 2236421f2f update compaction docs (#8156)
add a4396a7302 Update CQ docs (#8171)
add c6f933fdb5 add trigger conf in common-config-manual (#8166)
add 55d9a7d284 Update config manual (sync part) (#8172)
add 0456270015 Update config manual (hot-load part) (#8174)
add b59ce4faa7 [IOTDB-4970] Enhanced sync safety management (#8028)
add 25e0cb6713 Fix timeout problems in CI (#8173)
add 31643b5622 add ratis configuration doc (#8180)
add 0b66a04019 Skip checking duplicated measurements in one write request (#8178)
add 816b99aba8 [IOTDB-5004] [Metrics] Fix the seq file size in grafana is inconsistent with the actual query (#8177)
add 5432ee79e5 make org.apache.iotdb.consensus.ratis.RatisConsensus as default for config_node_consensus_protocol_class (#8176)
add 40fe9e08db Update config manual (query part) (#8167)
add 2a1e33a176 print status code name when dispatch failed (#8150)
add aa9d16cec5 [IOTDB-4334] Verify durable cases of RegionGroup extension (#8133)
add 8de5264016 Update the cluster concept UserGuide (#8182)
add e5208e8907 [IOTDB-5049] Add parameters enable leader balance for specifed consensus protocol class (#8170)
add b18b7bfdd0 [IOTDB-5053] Update Metric Doc and fix. (#8179)
add 3fd50f7898 [IOTDB-4940] Optimize PartitonFetch Process in query (#8155)
add 992ae7f07e [IOTDB-4066] Allocate new RegionGroups through double keyword sort (#8140)
add 5200e266ea Update user document of storage engine (#8185)
add 51e3a9c99a [IOTDB-4945] Retry with sleep to avoid failure in connecting confignodes caused by Ratis election
add 8d153466b1 Rename MultiLeader to IoTConsensus (#8181)
add 2d6ba7c0ae Remove merge statement from docs (#8186)
add 48293ddfd1 Fix Compile error (#8187)
add d8397b4e79 Add wal parameters in the documentation (#8183)
add 583a87b11f [IOTDB-5044] Correct the show triggers error message if the user doesn't have corresponding auth (#8158)
add 10105f484a [IOTDB-5050] Try to make TsBlock returned by ScanOperator larger
add bdce979954 fix it
new 7bf78f1a94 merge
add 2567d2b083 [IOTDB-4708] add reserverd words (#8191)
add a2d86aabda update description of missing params to user-guide (#8189)
add 3d329af059 Change default value of timed flush memtable and primitive array size (#8188)
add d11c73590b [IOTDB-5052] Query release others' file reader by mistake (#8190)
add e0c5e30da5 [IOTDB-3928][IOTDB-4097]New Compaction Performer —— Fast Compaction (#7621)
add f7faed2b9b [IOTDB-5013] Added simple standalone logic for starting and stopping shells (#8152)
add 17036c94dc Fix insert tablets npe (#8193)
add 93b875c98e Change default consensus (#8194)
add c60783898a [IOTDB-4553] Make code of region migrate process tidy (#8138)
add fa2766c48a add faq for index out of bounds exception (#8197)
add ffbdaf3994 update ratis 2.4.1 formal version (#8196)
add 1966a070f6 [IOTDB-5058] Add custom RegionGroup extension policy (#8199)
add 4d7c15ddcd update doc of partition (#8201)
add 1ee088aac3 Deploy site using GitHub (#8203)
add 26cbba0205 [IOTDB-5056] Modify value of some parameters (#8195)
add d3b96a6e9d [IOTDB-4513] Improve load balance UserGuide (#8204)
add e5b4dfe033 Fix slot query bug; add optimization for getSchemaPartition (#8200)
add 01d10843ac add common config in config.js (#8205)
add d3d2cf9950 Try to fix query performance (#8208)
add 941b12ada3 [IOTDB-5050] Try to make TsBlock returned by ScanOperator larger (#8198)
add d3534b7180 fix restart problem in confignode simple (#8207)
add 68c06372d7 speed up ratis first election (#8209)
add 7c22141247 add docs for pattern_matching_threshold (#8212)
add 17ae35d5e7 rename Multi Leader Conesensus to IoTConsensus for RPC service name (#8211)
add f3938bfdad [IOTDB-5062][Metric] Update Doc And Update Grafana Dashboard (#8210)
add 82cc6bac49 change sleep time (#8213)
add c43deda65b Fix IT bug (#8206)
add 40a2596ee8 Update pom version and doc to 1.0 (#8214)
add 40de3ad14e Revert "Update pom version and doc to 1.0 (#8214)" (#8217)
new 6da84a5b0b merge master
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/client-go.yml | 4 +-
.github/workflows/client-python.yml | 4 +-
.github/workflows/site-build.yml | 33 +-
RELEASE_NOTES.md | 265 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 228 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 10 +-
cli/src/assembly/resources/tools/load-tsfile.bat | 107 +
cli/src/assembly/resources/tools/load-tsfile.sh | 132 +
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 65 +-
client-go | 2 +-
confignode/src/assembly/confignode.xml | 4 -
.../resources/conf/iotdb-confignode.properties | 60 +-
.../confignode/client/ConfigNodeRequestType.java | 2 +-
.../client/async/AsyncDataNodeClientPool.java | 13 +-
.../client/sync/SyncConfigNodeClientPool.java | 5 +-
.../client/sync/SyncDataNodeClientPool.java | 14 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 173 +-
.../confignode/conf/ConfigNodeDescriptor.java | 113 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 28 +-
.../confignode/conf/SystemPropertiesUtils.java | 6 +-
.../consensus/request/ConfigPhysicalPlan.java | 10 +-
.../consensus/request/ConfigPhysicalPlanType.java | 3 +-
.../write/region/CreateRegionGroupsPlan.java | 19 +
...tPlan.java => AdjustMaxRegionGroupNumPlan.java} | 46 +-
.../request/write/sync/RecordPipeMessagePlan.java | 65 +
.../statemachine/ConfigNodeRegionStateMachine.java | 2 +-
.../confignode/manager/ClusterSchemaManager.java | 121 +-
.../iotdb/confignode/manager/ConfigManager.java | 64 +-
.../iotdb/confignode/manager/ConsensusManager.java | 73 +-
.../apache/iotdb/confignode/manager/IManager.java | 8 +
.../iotdb/confignode/manager/SyncManager.java | 12 +
.../iotdb/confignode/manager/load/LoadManager.java | 2 +-
.../manager/load/LoadManagerMetrics.java | 112 +-
.../manager/load/balancer/RegionBalancer.java | 84 +-
.../manager/load/balancer/RouteBalancer.java | 162 +-
...cator.java => CopySetRegionGroupAllocator.java} | 15 +-
.../balancer/region/GreedyRegionAllocator.java | 68 -
.../region/GreedyRegionGroupAllocator.java | 101 +
...onAllocator.java => IRegionGroupAllocator.java} | 24 +-
.../manager/load/balancer/router/LeaderRouter.java | 90 -
.../router/leader/GreedyLeaderBalancer.java | 186 +
.../{IRouter.java => leader/ILeaderBalancer.java} | 30 +-
.../MinCostFlowLeaderBalancer.java} | 102 +-
.../manager/load/balancer/router/mcf/MCFEdge.java | 34 -
.../GreedyPriorityBalancer.java} | 65 +-
.../IPriorityBalancer.java} | 24 +-
.../LeaderPriorityBalancer.java} | 49 +-
.../iotdb/confignode/manager/node/NodeManager.java | 29 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 13 +
.../node/heartbeat/NodeHeartbeatSample.java | 21 +-
.../partition/DataRegionGroupExtensionPolicy.java | 33 +-
.../manager/partition/PartitionManager.java | 208 +-
.../persistence/executor/ConfigPlanExecutor.java | 9 +-
.../persistence/metric/NodeInfoMetrics.java | 95 -
.../persistence/metric/PartitionInfoMetrics.java | 30 +-
.../persistence/partition/PartitionInfo.java | 8 +-
.../persistence/schema/ClusterSchemaInfo.java | 22 +-
.../persistence/sync/ClusterSyncInfo.java | 9 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 113 +-
.../procedure/env/DataNodeRemoveHandler.java | 56 +-
.../impl/node/AddConfigNodeProcedure.java | 38 +-
.../impl/node/RemoveDataNodeProcedure.java | 2 +-
.../impl/schema/DeactivateTemplateProcedure.java | 6 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 6 +-
.../impl/schema/UnsetTemplateProcedure.java | 4 +-
.../statemachine/CreateRegionGroupsProcedure.java | 13 +-
.../procedure/state/AddConfigNodeState.java | 3 +-
.../procedure/state/CreateRegionGroupsState.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 9 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 18 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../balancer/region/GreedyRegionAllocatorTest.java | 92 -
.../region/GreedyRegionGroupAllocatorTest.java | 140 +
.../router/leader/GreedyLeaderBalancerTest.java | 146 +
.../leader/LeaderBalancerComparisonTest.java | 369 ++
.../MinCostFlowLeaderBalancerTest.java} | 33 +-
.../GreedyPriorityTest.java} | 8 +-
.../LeaderPriorityBalancerTest.java} | 56 +-
.../confignode1conf/iotdb-common.properties | 2 +-
.../confignode1conf/iotdb-confignode-metric.yml | 48 -
.../confignode1conf/iotdb-confignode.properties | 8 +-
.../confignode2conf/iotdb-common.properties | 2 +-
.../confignode2conf/iotdb-confignode-metric.yml | 48 -
.../confignode2conf/iotdb-confignode.properties | 8 +-
.../confignode3conf/iotdb-common.properties | 2 +-
.../confignode3conf/iotdb-confignode-metric.yml | 48 -
.../confignode3conf/iotdb-confignode.properties | 8 +-
consensus/pom.xml | 4 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 3 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 13 +-
.../common/request/IndexedConsensusRequest.java | 29 +-
...sensusRequest.java => IoTConsensusRequest.java} | 12 +-
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
...tiLeaderConfig.java => IoTConsensusConfig.java} | 71 +-
.../IoTConsensus.java} | 96 +-
.../IoTConsensusServerImpl.java} | 119 +-
.../IoTConsensusServerMetrics.java} | 36 +-
.../client/AsyncIoTConsensusServiceClient.java} | 27 +-
.../client/DispatchLogHandler.java | 10 +-
.../client/IoTConsensusClientPool.java} | 45 +-
.../client/SyncIoTConsensusServiceClient.java} | 32 +-
.../logdispatcher/IndexController.java | 13 +-
.../logdispatcher/IoTConsensusMemoryManager.java} | 24 +-
.../IoTConsensusMemoryManagerMetrics.java} | 20 +-
.../logdispatcher/LogDispatcher.java | 199 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 18 +-
.../logdispatcher/PendingBatch.java | 50 +-
.../logdispatcher/SyncStatus.java | 27 +-
.../service/IoTConsensusRPCService.java} | 32 +-
.../service/IoTConsensusRPCServiceHandler.java} | 8 +-
.../service/IoTConsensusRPCServiceMBean.java} | 4 +-
.../service/IoTConsensusRPCServiceProcessor.java} | 112 +-
.../snapshot/SnapshotFragment.java | 4 +-
.../snapshot/SnapshotFragmentReader.java | 2 +-
.../wal/ConsensusReqReader.java | 6 +-
.../wal/GetConsensusReqReaderPlan.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 3 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 21 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 57 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 31 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 4 +
.../IoTConsensusTest.java} | 20 +-
.../{multileader => iot}/RecoveryTest.java | 8 +-
.../logdispatcher/IndexControllerTest.java | 2 +-
.../logdispatcher/SyncStatusTest.java | 29 +-
.../util/FakeConsensusReqReader.java | 4 +-
.../{multileader => iot}/util/RequestSets.java | 2 +-
.../{multileader => iot}/util/TestEntry.java | 6 +-
.../util/TestStateMachine.java | 6 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 23 +-
distribution/src/assembly/all.xml | 16 -
distribution/src/assembly/confignode.xml | 6 -
distribution/src/assembly/datanode.xml | 12 -
.../GrafanaPlugin/iotdb/conf/iotdb-rest.properties | 61 -
docs/UserGuide/API/RestService.md | 60 +-
.../Administration-Management/Administration.md | 4 +-
docs/UserGuide/Cluster/Cluster-Concept.md | 49 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 286 +-
docs/UserGuide/Data-Concept/Deadband-Process.md | 2 +-
docs/UserGuide/Data-Concept/Schema-Template.md | 15 +
.../Ecosystem-Integration/Grafana-Plugin.md | 4 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 24 +-
docs/UserGuide/FAQ/Frequently-asked-questions.md | 6 +-
.../{Write-Data => Maintenance-Tools}/CSV-Tool.md | 0
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
.../Load-Tsfile.md} | 41 +-
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 6 +-
.../Maintenance-Tools/Maintenance-Command.md | 255 +-
docs/UserGuide/Maintenance-Tools/NodeTool.md | 297 -
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 6 +-
.../TsFile-Load-Export-Tool.md} | 5 +-
.../TsFile-Resource-Sketch-Tool.md | 79 +
.../Maintenance-Tools/TsFile-Sketch-Tool.md | 108 +
.../Maintenance-Tools/TsFile-Split-Tool.md | 25 +-
docs/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 601 +-
.../{Storage-Group.md => Database.md} | 4 +-
docs/UserGuide/Operate-Metadata/Template.md | 2 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 4 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 58 +
.../Anomaly-Detection.md | 0
docs/UserGuide/Operators-Functions/Comparison.md | 305 +
docs/UserGuide/Operators-Functions/Constant.md | 57 +
.../Operators-Functions/Continuous-Interval.md | 73 +
docs/UserGuide/Operators-Functions/Conversion.md | 127 +
.../Data-Matching.md | 0
.../Data-Profiling.md | 0
.../Data-Quality.md | 0
.../Data-Repairing.md | 0
.../Frequency-Domain.md | 0
docs/UserGuide/Operators-Functions/Lambda.md | 77 +
docs/UserGuide/Operators-Functions/Logical.md | 63 +
docs/UserGuide/Operators-Functions/Mathematical.md | 113 +
.../Overview.md} | 24 +
docs/UserGuide/Operators-Functions/Sample.md | 389 ++
docs/UserGuide/Operators-Functions/Selection.md | 51 +
.../Series-Discovery.md | 0
.../String.md} | 66 +
.../Time-Series.md} | 2 +-
.../User-Defined-Function.md} | 2 -
.../Operators-Functions/Variation-Trend.md | 54 +
docs/UserGuide/Query-Data/Align-By.md | 57 +
.../Continuous-Query.md | 0
.../Query-Data/{Fill-Null-Value.md => Fill.md} | 116 +-
.../Query-Data/{Aggregate-Query.md => Group-By.md} | 142 +-
docs/UserGuide/Query-Data/Having-Condition.md | 115 +
docs/UserGuide/Query-Data/Last-Query.md | 16 +-
.../M4.md => UserGuide/Query-Data/Order-By.md} | 6 +-
docs/UserGuide/Query-Data/Overview.md | 97 +-
docs/UserGuide/Query-Data/Pagination.md | 39 +-
.../Query-Data/Performance-Tracing-Tool.md | 53 -
docs/UserGuide/Query-Data/Result-Format.md | 82 -
docs/UserGuide/Query-Data/Select-Expression.md | 1087 +---
.../{Process-Data => Query-Data}/Select-Into.md | 22 +-
docs/UserGuide/Query-Data/Tracing-Tool.md | 48 -
.../{Query-Filter.md => Where-Condition.md} | 7 +-
docs/UserGuide/Query-Data/Without-Null.md | 172 -
docs/UserGuide/QuickStart/Files.md | 92 +-
docs/UserGuide/QuickStart/QuickStart.md | 49 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 1969 ++++++
.../Reference/ConfigNode-Config-Manual.md | 257 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 1192 +---
docs/UserGuide/Reference/Keywords.md | 406 +-
docs/UserGuide/Reference/SQL-Reference.md | 12 +-
docs/UserGuide/{API => Reference}/Status-Codes.md | 4 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 591 --
.../Detailed-Grammar.md} | 7 +-
docs/UserGuide/Syntax-Conventions/Identifier.md | 141 +
docs/UserGuide/Syntax-Conventions/KeyValue-Pair.md | 119 +
.../Keywords-And-Reserved-Words.md} | 7 +-
.../UserGuide/Syntax-Conventions/Literal-Values.md | 157 +
.../Syntax-Conventions/NodeName-In-Path.md | 119 +
.../Syntax-Conventions/Session-And-TsFile-API.md | 119 +
.../M4.md => Trigger/Configuration-Parameters.md} | 8 +-
.../Triggers.md => Trigger/Implement-Trigger.md} | 201 +-
docs/UserGuide/Trigger/Instructions.md | 51 +
docs/UserGuide/Trigger/Notes.md | 30 +
docs/UserGuide/Trigger/Trigger-Management.md | 152 +
docs/UserGuide/Write-Data/Batch-Load-Tool.md | 32 +
docs/UserGuide/Write-Data/REST-API.md | 6 +-
docs/zh/UserGuide/API/RestService.md | 78 +-
.../Administration-Management/Administration.md | 4 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 50 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 282 +-
docs/zh/UserGuide/Data-Concept/Deadband-Process.md | 2 +-
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 15 +
.../Ecosystem-Integration/Grafana-Plugin.md | 4 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 16 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 7 +-
.../{Write-Data => Maintenance-Tools}/CSV-Tool.md | 2 +-
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
.../Load-Tsfile.md} | 41 +-
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 6 +-
.../Maintenance-Tools/Maintenance-Command.md | 250 +-
docs/zh/UserGuide/Maintenance-Tools/NodeTool.md | 293 -
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 8 +-
.../TsFile-Load-Export-Tool.md} | 6 +-
.../TsFile-Resource-Sketch-Tool.md | 79 +
.../Maintenance-Tools/TsFile-Sketch-Tool.md | 108 +
.../Maintenance-Tools/TsFile-Split-Tool.md | 20 +-
docs/zh/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 755 ++-
.../{Storage-Group.md => Database.md} | 6 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 4 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 14 +-
.../UserGuide/Operators-Functions/Aggregation.md | 41 +
.../Anomaly-Detection.md | 32 +-
.../zh/UserGuide/Operators-Functions/Comparison.md | 309 +
docs/zh/UserGuide/Operators-Functions/Constant.md | 57 +
.../Operators-Functions/Continuous-Interval.md | 75 +
.../zh/UserGuide/Operators-Functions/Conversion.md | 131 +
.../Data-Matching.md | 32 +-
.../Data-Profiling.md | 32 +-
.../Data-Quality.md | 32 +-
.../Data-Repairing.md | 32 +-
.../Frequency-Domain.md | 32 +-
docs/zh/UserGuide/Operators-Functions/Lambda.md | 83 +
docs/zh/UserGuide/Operators-Functions/Logical.md | 63 +
.../UserGuide/Operators-Functions/Mathematical.md | 116 +
docs/zh/UserGuide/Operators-Functions/Overview.md | 239 +
docs/zh/UserGuide/Operators-Functions/Sample.md | 408 ++
docs/zh/UserGuide/Operators-Functions/Selection.md | 51 +
.../Series-Discovery.md | 32 +-
.../String.md} | 104 +-
.../Time-Series.md} | 36 +-
.../User-Defined-Function.md} | 4 +-
.../Operators-Functions/Variation-Trend.md | 54 +
docs/zh/UserGuide/Query-Data/Align-By.md | 61 +
.../Continuous-Query.md | 0
.../Query-Data/{Fill-Null-Value.md => Fill.md} | 134 +-
.../Query-Data/{Aggregate-Query.md => Group-By.md} | 346 +-
docs/zh/UserGuide/Query-Data/Having-Condition.md | 115 +
docs/zh/UserGuide/Query-Data/Last-Query.md | 24 +-
.../M4.md => zh/UserGuide/Query-Data/Order-By.md} | 7 +-
docs/zh/UserGuide/Query-Data/Overview.md | 121 +-
docs/zh/UserGuide/Query-Data/Pagination.md | 118 +-
.../Query-Data/Performance-Tracing-Tool.md | 51 -
docs/zh/UserGuide/Query-Data/Result-Format.md | 89 -
docs/zh/UserGuide/Query-Data/Select-Expression.md | 1173 +---
.../{Process-Data => Query-Data}/Select-Into.md | 24 +-
docs/zh/UserGuide/Query-Data/Tracing-Tool.md | 48 -
.../{Query-Filter.md => Where-Condition.md} | 21 +-
docs/zh/UserGuide/Query-Data/Without-Null.md | 172 -
docs/zh/UserGuide/QuickStart/Files.md | 88 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 38 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 2012 ++++++
.../Reference/ConfigNode-Config-Manual.md | 326 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 1782 +-----
docs/zh/UserGuide/Reference/Keywords.md | 406 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 12 +-
.../UserGuide/{API => Reference}/Status-Codes.md | 4 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 590 --
.../Syntax-Conventions/Detailed-Grammar.md} | 7 +-
docs/zh/UserGuide/Syntax-Conventions/Identifier.md | 142 +
.../UserGuide/Syntax-Conventions/KeyValue-Pair.md | 119 +
.../Keywords-And-Reserved-Words.md} | 7 +-
.../UserGuide/Syntax-Conventions/Literal-Values.md | 150 +
.../Syntax-Conventions/NodeName-In-Path.md | 120 +
.../Syntax-Conventions/Session-And-TsFile-API.md | 119 +
.../UserGuide/Trigger/Configuration-Parameters.md} | 8 +-
.../Triggers.md => Trigger/Implement-Trigger.md} | 198 +-
docs/zh/UserGuide/Trigger/Instructions.md | 46 +
docs/zh/UserGuide/Trigger/Notes.md | 33 +
docs/zh/UserGuide/Trigger/Trigger-Management.md | 152 +
docs/zh/UserGuide/UDF-Library/Quick-Start.md | 40 -
docs/zh/UserGuide/Write-Data/Batch-Load-Tool.md | 32 +
docs/zh/UserGuide/Write-Data/REST-API.md | 6 +-
...json => Apache IoTDB ConfigNode Dashboard.json} | 1440 ++++-
...0.json => Apache IoTDB DataNode Dashboard.json} | 2369 +++++--
.../standalone/Apache IoTDB Dashboard v0.14.0.json | 1519 -----
grafana-plugin/go.sum | 2 +-
grafana-plugin/pkg/plugin/plugin.go | 8 +-
.../trigger/example/TriggerFireTimesCounter.java | 5 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 58 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 12 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 47 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 18 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 46 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 10 +
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 85 +-
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 8 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 3 +-
.../it/partition/IoTDBPartitionDurableIT.java | 626 ++
.../it/partition/IoTDBPartitionDurableTest.java | 323 -
.../it/partition/IoTDBPartitionGetterIT.java | 164 +-
...est.java => IoTDBPartitionInheritPolicyIT.java} | 31 +-
.../it/partition/IoTDBRegionGroupExtensionIT.java | 156 +
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 14 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 2 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 2 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 75 +-
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 39 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 18 +-
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 6 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 2 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 8 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 2 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 4 +-
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 20 +
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 1324 -> 1397 bytes
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 14 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 102 -
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../sync/IoTDBSyncReceiverLoaderIT.java | 6 +-
.../iotdb/db/integration/sync/MockSyncClient.java | 4 +-
metrics/ReadMe.md | 29 +-
metrics/dropwizard-metrics/pom.xml | 5 -
.../dropwizard/DropwizardMetricManager.java | 3 +-
.../reporter/DropwizardIoTDBReporter.java | 79 -
.../dropwizard/reporter/DropwizardJmxReporter.java | 9 +-
.../dropwizard/reporter/DropwizardMetricType.java | 38 -
.../reporter/DropwizardMetricsExporter.java | 168 -
.../reporter/DropwizardPrometheusReporter.java | 118 -
.../metrics/dropwizard/reporter/IoTDBReporter.java | 278 -
.../dropwizard/type/DropwizardAutoGauge.java | 19 +-
.../type/DropwizardHistogramSnapshot.java | 7 -
... org.apache.iotdb.metrics.reporter.JmxReporter} | 4 +-
metrics/interface/pom.xml | 11 +-
.../resources/conf/iotdb-confignode-metric.yml | 49 -
.../resources/conf/iotdb-datanode-metric.yml | 49 -
.../iotdb/metrics/AbstractMetricManager.java | 201 +-
.../iotdb/metrics/AbstractMetricService.java | 231 +-
.../metrics/{reporter => }/CompositeReporter.java | 25 +-
.../iotdb/metrics/DoNothingMetricService.java | 8 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 248 +-
.../metrics/config/MetricConfigDescriptor.java | 221 +-
.../iotdb/metrics/config/MetricConstant.java | 37 -
.../apache/iotdb/metrics/config/ReloadLevel.java | 6 +-
.../iotdb/metrics/impl/DoNothingAutoGauge.java | 13 +-
.../iotdb/metrics/impl/DoNothingCounter.java | 2 +-
.../apache/iotdb/metrics/impl/DoNothingGauge.java | 2 +-
.../iotdb/metrics/impl/DoNothingHistogram.java | 2 +-
.../metrics/impl/DoNothingHistogramSnapshot.java | 9 +-
.../apache/iotdb/metrics/impl/DoNothingMetric.java | 4 +-
.../iotdb/metrics/impl/DoNothingMetricManager.java | 11 +-
.../apache/iotdb/metrics/impl/DoNothingRate.java | 2 +-
.../apache/iotdb/metrics/impl/DoNothingTimer.java | 2 +-
.../metricsets/jvm/JvmClassLoaderMetrics.java | 12 +-
.../metrics/metricsets/jvm/JvmCompileMetrics.java | 6 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 28 +-
.../metrics/metricsets/jvm/JvmMemoryMetrics.java | 48 +-
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 24 +-
.../metrics/metricsets/logback/LogbackMetrics.java | 10 +-
.../metricsets/logback/MetricsTurboFilter.java | 10 +-
.../apache/iotdb/metrics/reporter/JmxReporter.java | 11 +-
.../apache/iotdb/metrics/reporter/Reporter.java | 10 +-
.../reporter/iotdb/InternalIoTDBReporter.java | 67 +
.../metrics/reporter/iotdb/IoTDBReporter.java | 103 +
.../iotdb/MemoryInternalIoTDBReporter.java} | 38 +-
.../reporter/iotdb/SessionIoTDBReporter.java | 175 +
.../reporter/prometheus/PrometheusReporter.java | 222 +
.../reporter/prometheus}/PrometheusTextWriter.java | 44 +-
.../org/apache/iotdb/metrics/type/AutoGauge.java | 16 +-
.../org/apache/iotdb/metrics/type/Counter.java | 13 +-
.../java/org/apache/iotdb/metrics/type/Gauge.java | 15 +-
.../org/apache/iotdb/metrics/type/Histogram.java | 14 +-
.../iotdb/metrics/type/HistogramSnapshot.java | 34 +-
.../org/apache/iotdb/metrics/type/IMetric.java | 8 +-
.../java/org/apache/iotdb/metrics/type/Rate.java | 25 +-
.../java/org/apache/iotdb/metrics/type/Timer.java | 17 +-
...OutPutFormat.java => InternalReporterType.java} | 8 +-
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 74 +-
.../{MonitorType.java => MetricFrameType.java} | 2 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 18 +-
.../org/apache/iotdb/metrics/utils/MetricType.java | 1 +
.../iotdb/metrics/config/MetricConfigTest.java | 86 +-
.../interface/src/test/resources/iotdb-metric.yml | 52 -
.../micrometer/MicrometerMetricManager.java | 4 +-
.../micrometer/reporter/IoTDBMeterRegistry.java | 149 -
.../micrometer/reporter/IoTDBRegistryConfig.java | 50 -
.../reporter/MicrometerIoTDBReporter.java | 92 -
.../micrometer/reporter/MicrometerJmxReporter.java | 7 +-
.../reporter/MicrometerPrometheusReporter.java | 118 -
.../micrometer/type/MicrometerAutoGauge.java | 19 +-
.../type/MicrometerHistogramSnapshot.java | 7 -
... org.apache.iotdb.metrics.reporter.JmxReporter} | 4 +-
.../resources/conf/iotdb-common.properties | 351 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 2 +-
.../assembly/resources/sbin/start-standalone.bat | 42 +
.../assembly/resources/sbin/start-standalone.sh | 38 +-
.../assembly/resources/sbin/stop-standalone.bat | 40 +
.../src/assembly/resources/sbin/stop-standalone.sh | 31 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 4 +-
.../apache/iotdb/commons/client/ClientManager.java | 7 +-
.../sync/SyncThriftClientWithErrorHandler.java | 3 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 12 +-
.../iotdb/commons/conf/CommonDescriptor.java | 7 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 16 +
.../exception/sync}/SyncConnectionException.java | 2 +-
.../exception/sync/SyncHandshakeException.java | 10 +-
.../commons/partition/DataPartitionQueryParam.java | 6 +
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../commons/service/metric/MetricService.java | 105 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +-
.../iotdb/commons/sync/metadata/SyncMetadata.java | 3 +
.../iotdb/commons/sync/pipe/PipeMessage.java | 54 +-
.../commons/sync/transport/SyncIdentityInfo.java | 57 +
.../iotdb/commons/sync/utils/SyncPathUtil.java | 17 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 14 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 39 +-
openapi/src/main/openapi3/iotdb-rest.yaml | 17 +-
pom.xml | 4 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 138 +-
.../schemaregion/rocksdb/mnode/REntityMNode.java | 16 -
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 32 -
.../rocksdb/mnode/RMeasurementMNode.java | 32 -
.../rocksdb/mnode/RStorageGroupMNode.java | 8 -
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 85 +-
.../utils/ShowTimeSeriesResultUtils.java | 4 +-
.../src/assembly/resources/conf/datanode-env.bat | 2 +-
.../resources/conf/iotdb-datanode.properties | 128 +-
.../assembly/resources/conf/iotdb-rest.properties | 64 -
.../assembly/resources/sbin/start-new-server.bat | 167 -
.../assembly/resources/sbin/start-new-server.sh | 249 -
.../assembly/resources/tools/detect-watermark.bat | 65 -
.../assembly/resources/tools/rocksdb-transfer.bat | 126 -
.../assembly/resources/tools/rocksdb-transfer.sh | 82 -
...chemaFileSketcher.bat => print-schema-file.bat} | 0
...{SchemaFileSketcher.sh => print-schema-file.sh} | 0
.../{mLogParser.bat => print-schema-log.bat} | 0
.../schema/{mLogParser.sh => print-schema-log.sh} | 0
.../assembly/resources/tools/start-WalChecker.bat | 111 -
.../assembly/resources/tools/start-WalChecker.sh | 91 -
.../print-iotdb-data-dir.bat | 0
.../print-iotdb-data-dir.sh | 0
.../print-tsfile-resource-files.bat | 0
.../print-tsfile-resource-files.sh | 0
.../print-tsfile.bat} | 0
.../print-tsfile.sh} | 0
.../split-tsfile-tool.bat | 0
.../{tsfileToolSet => tsfile}/split-tsfile-tool.sh | 0
.../{tsfileToolSet => tsfile}/validate-tsfile.bat | 0
.../{tsfileToolSet => tsfile}/validate-tsfile.sh | 0
.../tools/tsfileToolSet/print-tsfile-visdata.bat | 62 -
.../tools/tsfileToolSet/print-tsfile-visdata.sh | 51 -
.../resources/tools/tsfileToolSet/settle.bat | 62 -
.../resources/tools/tsfileToolSet/settle.sh | 51 -
server/src/assembly/server.xml | 4 -
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 8 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 179 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 6 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 101 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 70 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 -
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 10 +-
.../consensus/statemachine/BaseStateMachine.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 23 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 2 +-
.../iotdb/db/engine/TsFileMetricManager.java | 6 +-
.../iotdb/db/engine/cache/ChunkCacheMetrics.java | 4 +-
.../cache/TimeSeriesMetadataCacheMetrics.java | 8 +-
.../compaction/CompactionExceptionHandler.java | 6 +-
.../db/engine/compaction/CompactionUtils.java | 91 +-
.../constant/CrossCompactionPerformer.java | 11 +-
.../constant/InnerSeqCompactionPerformer.java | 11 +-
.../constant/InnerUnseqCompactionPerformer.java | 12 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 46 +-
.../RewriteCrossSpaceCompactionSelector.java | 13 +-
.../task/FastCompactionPerformerSubTask.java | 146 +
.../utils/AlignedSeriesCompactionExecutor.java | 339 +
.../cross/utils/ChunkMetadataElement.java | 48 +-
.../compaction/cross/utils/FileElement.java} | 20 +-
.../utils/NonAlignedSeriesCompactionExecutor.java | 208 +
.../engine/compaction/cross/utils/PageElement.java | 101 +
.../compaction/cross/utils/PointElement.java | 50 +
.../cross/utils/SeriesCompactionExecutor.java | 591 ++
.../compaction/inner/InnerSpaceCompactionTask.java | 32 +-
.../inner/utils/MultiTsFileDeviceIterator.java | 110 +-
.../compaction/performer/ICompactionPerformer.java | 8 +-
.../performer/impl/FastCompactionPerformer.java | 294 +
.../impl/ReadPointCompactionPerformer.java | 93 +-
.../compaction/reader/PointPriorityReader.java | 152 +
.../compaction/task/SubCompactionTaskSummary.java | 40 +
.../writer/AbstractCompactionWriter.java | 289 +-
.../writer/AbstractCrossCompactionWriter.java | 233 +
.../writer/AbstractInnerCompactionWriter.java | 108 +
.../writer/CrossSpaceCompactionWriter.java | 256 -
.../writer/FastCrossCompactionWriter.java | 203 +
.../writer/FastInnerCompactionWriter.java | 212 +
.../writer/InnerSpaceCompactionWriter.java | 140 -
.../writer/ReadPointCrossCompactionWriter.java | 94 +
.../writer/ReadPointInnerCompactionWriter.java | 79 +
.../iotdb/db/engine/flush/FlushManagerMetrics.java | 8 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 17 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 30 +-
.../db/engine/storagegroup/DataRegionMetrics.java | 8 +-
.../db/engine/storagegroup/TsFileManager.java | 12 +-
.../db/engine/storagegroup/TsFileProcessor.java | 196 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 4 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 250 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 550 +-
.../metadata/cache/DataNodeLastCacheManager.java | 2 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 4 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 4 +-
.../lastCache/container/ILastCacheContainer.java | 2 +-
.../lastCache/container/LastCacheContainer.java | 6 +-
.../lastCache/container/value/ILastCacheValue.java | 2 +-
.../lastCache/container/value/LastCacheValue.java | 2 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 45 -
.../db/metadata/idtable/IDTableHashmapImpl.java | 65 -
.../idtable/entry/InsertMeasurementMNode.java | 31 -
.../db/metadata/idtable/entry/SchemaEntry.java | 82 +-
.../db/metadata/lastCache/LastCacheManager.java | 255 -
.../iotdb/db/metadata/logfile/MLogTxtReader.java | 78 -
.../iotdb/db/metadata/logfile/MLogTxtWriter.java | 458 --
.../iotdb/db/metadata/logfile/MLogWriter.java | 43 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 24 -
.../iotdb/db/metadata/mnode/IEntityMNode.java | 6 -
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 11 -
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 5 -
.../iotdb/db/metadata/mnode/InternalMNode.java | 56 -
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 56 -
.../db/metadata/mnode/StorageGroupEntityMNode.java | 10 -
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 19 -
.../mnode/estimator/BasicMNodSizeEstimator.java | 9 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 10 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 93 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 653 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 594 +-
.../store/disk/schemafile/AliasIndexPage.java | 2 +-
.../mtree/store/disk/schemafile/InternalPage.java | 2 +-
.../store/disk/schemafile/MockSchemaFile.java | 1 -
.../mtree/store/disk/schemafile/RecordUtils.java | 16 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 51 +-
.../store/disk/schemafile/WrappedSegment.java | 2 +-
.../disk/schemafile/pagemgr/IPageManager.java | 5 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 28 +-
.../db/metadata/mtree/traverser/Traverser.java | 51 +-
.../mtree/traverser/collector/MNodeCollector.java | 18 -
.../mtree/traverser/counter/CounterTraverser.java | 4 +-
.../counter/MeasurementGroupByLevelCounter.java | 12 +-
.../plan/schemaregion/SchemaRegionPlanType.java | 6 +-
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 15 -
.../impl/SchemaRegionPlanDeserializer.java | 44 +-
.../schemaregion/impl/SchemaRegionPlanFactory.java | 11 -
.../impl/SchemaRegionPlanSerializer.java | 49 -
.../impl/SchemaRegionPlanTxtSerializer.java | 29 -
.../schemaregion/impl/SetTemplatePlanImpl.java | 69 -
.../schemaregion/impl/UnsetTemplatePlanImpl.java | 69 -
.../schemaregion/write/IActivateTemplatePlan.java | 42 -
.../plan/schemaregion/write/ISetTemplatePlan.java | 45 -
.../schemaregion/write/IUnsetTemplatePlan.java | 45 -
.../rescon/SchemaStatisticsManagerMetrics.java | 4 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 80 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 299 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 307 +-
.../storagegroup/IStorageGroupSchemaManager.java | 7 +-
.../storagegroup/StorageGroupSchemaManager.java | 9 +-
.../db/metadata/template/TemplateLogReader.java | 46 -
.../db/metadata/template/TemplateLogWriter.java | 64 -
.../db/metadata/template/TemplateManager.java | 384 --
.../db/metadata/upgrade/MetadataUpgrader.java | 437 --
.../metadata/visitor/SchemaExecutionVisitor.java | 4 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 14 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 6 +-
.../execution/exchange/MPPDataExchangeManager.java | 8 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 4 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 4 +-
.../execution/executor/RegionWriteExecutor.java | 17 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 84 +-
.../operator/process/AbstractIntoOperator.java | 21 +-
.../operator/process/DeviceViewIntoOperator.java | 2 +-
.../operator/process/DeviceViewOperator.java | 16 +-
.../execution/operator/process/IntoOperator.java | 2 +-
.../process/join/merge/MultiColumnMerger.java | 18 +-
.../operator/process/last/LastQueryOperator.java | 6 +-
.../operator/schema/CountMergeOperator.java | 18 +-
.../operator/schema/DevicesCountOperator.java | 4 +-
.../schema/LevelTimeSeriesCountOperator.java | 4 +-
.../operator/schema/NodePathsCountOperator.java | 2 +-
.../schema/NodePathsSchemaScanOperator.java | 3 +-
.../operator/schema/TimeSeriesCountOperator.java | 4 +-
.../operator/source/AlignedSeriesScanOperator.java | 123 +-
.../operator/source/SeriesScanOperator.java | 120 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 26 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 135 +-
.../plan/analyze/StandalonePartitionFetcher.java | 2 +-
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 7 -
.../db/mpp/plan/execution/QueryExecution.java | 2 +-
.../config/metadata/ShowFunctionsTask.java | 15 +-
.../memory/StatementMemorySourceVisitor.java | 21 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 671 +-
.../db/mpp/plan/parser/StatementGenerator.java | 22 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 19 +-
.../planner/distribution/DistributionPlanner.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 111 +
.../plan/planner/distribution/SourceRewriter.java | 4 +-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 16 +-
.../write/CreateAlignedTimeSeriesNode.java | 6 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 5 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 6 +-
.../plan/node/metedata/write/MeasurementGroup.java | 6 +-
.../plan/node/write/InsertMultiTabletsNode.java | 2 +-
.../plan/planner/plan/node/write/InsertNode.java | 15 +-
.../planner/plan/node/write/InsertRowNode.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 6 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 22 +-
.../plan/statement/crud/LoadTsFileStatement.java | 12 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +
.../metadata/DeleteStorageGroupStatement.java | 18 +-
.../statement/metadata/ShowTriggersStatement.java | 6 -
.../rest/handler/RequestValidationHandler.java | 14 +-
.../rest/handler/StatementConstructionHandler.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 119 +-
.../db/qp/physical/sys/ActivateTemplatePlan.java | 4 +-
.../db/qp/physical/sys/AppendTemplatePlan.java | 2 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 8 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 6 +-
.../db/qp/physical/sys/CreateTemplatePlan.java | 7 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 6 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 3 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 3 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 3407 ----------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 51 +-
.../control/clientsession/IClientSession.java | 2 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 65 +-
.../pool/RawQueryReadTaskPoolManagerMetrics.java | 8 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 18 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 29 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 4 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 12 +
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 1 +
.../org/apache/iotdb/db/service/RPCService.java | 8 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 4 +-
.../iotdb/db/service/RegionMigrateService.java | 367 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 14 +-
.../iotdb/db/service/metrics/FileMetrics.java | 30 +-
.../db/service/metrics/IoTDBInternalReporter.java | 164 +
.../iotdb/db/service/metrics/ProcessMetrics.java | 39 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 41 +-
.../metrics/recorder/CacheMetricsRecorder.java | 2 +-
.../recorder/CompactionMetricsRecorder.java | 8 +-
.../InternalServiceThriftHandlerMetrics.java | 7 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 4 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 27 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 86 +-
.../db/service/thrift/impl/TSServiceImpl.java | 136 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 31 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 12 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 4 +-
.../apache/iotdb/db/sync/pipedata/PipeData.java | 2 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 4 +-
.../load/DeletionLoader.java | 2 +-
.../sync/{receiver => pipedata}/load/ILoader.java | 2 +-
.../{receiver => pipedata}/load/TsFileLoader.java | 4 +-
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 16 +-
.../db/sync/transport/client/ISyncClient.java | 7 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 34 +-
.../db/sync/transport/client/SenderManager.java | 49 +-
.../sync/transport/client/SyncClientFactory.java | 34 +-
.../db/sync/transport/server/ReceiverManager.java | 101 +-
.../apache/iotdb/db/tools/schema/MLogParser.java | 2 +-
.../db/tools/schema/SchemaFileSketchTool.java | 5 +-
.../db/tools/validate/TsFileValidationTool.java | 7 +-
.../iotdb/db/tools/vis/TsFileExtractVisdata.java | 170 -
.../main/java/org/apache/iotdb/db/tools/vis/vis.m | 290 -
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 24 -
.../java/org/apache/iotdb/db/wal/WALManager.java | 20 +-
.../db/wal/allocation/FirstCreateStrategy.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 4 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 22 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 +-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 2 +-
.../engine/compaction/AbstractCompactionTest.java | 208 +-
.../compaction/CompactionTaskComparatorTest.java | 4 +-
.../compaction/CompactionTaskManagerTest.java | 74 +-
.../compaction/FastAlignedCrossCompactionTest.java | 6689 ++++++++++++++++++++
....java => FastCrossCompactionPerformerTest.java} | 4215 ++++--------
.../FastInnerCompactionPerformerTest.java | 1824 ++++++
.../FastNonAlignedCrossCompactionTest.java | 6655 +++++++++++++++++++
.../ReadPointCompactionPerformerTest.java | 929 ++-
.../cross/CrossSpaceCompactionValidationTest.java | 98 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 10 +-
...ava => FastCompactionPerformerAlignedTest.java} | 43 +-
...a => FastCompactionPerformerNoAlignedTest.java} | 64 +-
...> InnerSeqCompactionWithFastPerformerTest.java} | 99 +-
...erSeqCompactionWithReadChunkPerformerTest.java} | 14 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 26 +-
...InnerUnseqCompactionWithFastPerformerTest.java} | 17 +-
...UnseqCompactionWithReadPointPerformerTest.java} | 11 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 36 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 48 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 7 +-
.../SizeTieredCompactionRecoverTest.java | 48 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 33 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 26 +-
.../recover/SizeTieredCompactionRecoverTest.java | 38 +-
.../compaction/utils/TsFileGeneratorUtils.java | 257 +
.../db/engine/storagegroup/DataRegionTest.java | 7 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 16 +-
.../iotdb/db/metadata/SchemaAdvancedTest.java | 25 -
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 1285 +---
.../org/apache/iotdb/db/metadata/TemplateTest.java | 307 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 149 -
.../db/metadata/idtable/LastQueryWithIDTable.java | 145 -
.../db/metadata/idtable/entry/SchemaEntryTest.java | 18 -
.../metadata/idtable/trigger_example/Counter.java | 97 -
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 19 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 75 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 86 +-
.../plan/SchemaRegionPlanCompatibilityTest.java | 55 -
.../schemaRegion/SchemaRegionBasicTest.java | 10 +-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 318 -
.../apache/iotdb/db/metric/MetricServiceTest.java | 77 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 48 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 88 +-
.../mpp/execution/exchange/SourceHandleTest.java | 70 +-
.../operator/AlignedSeriesScanOperatorTest.java | 191 +-
.../operator/DeviceMergeOperatorTest.java | 82 +-
.../execution/operator/DeviceViewOperatorTest.java | 21 +-
.../mpp/execution/operator/LimitOperatorTest.java | 42 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 90 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 4 +-
.../operator/RawDataAggregationOperatorTest.java | 41 +-
.../execution/operator/SeriesScanOperatorTest.java | 29 +-
.../execution/operator/TimeJoinOperatorTest.java | 115 +-
.../operator/schema/CountMergeOperatorTest.java | 8 +-
.../operator/schema/SchemaCountOperatorTest.java | 10 +-
.../schedule/queue/L2PriorityQueueTest.java | 20 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 2 +-
.../mpp/plan/analyze/QueryTimePartitionTest.java | 532 ++
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 3 +
.../distribution/AggregationDistributionTest.java | 97 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 3 +
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 3 +
.../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 11 +-
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 66 +-
.../iotdb/db/qp/sql/IoTDBsqlVisitorTest.java | 99 -
.../iotdb/db/query/dataset/ListDataSetTest.java | 3 +
.../org/apache/iotdb/db/tools/MLogParserTest.java | 41 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 14 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 6 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 6 +-
.../datastructure/PrimitiveArrayManagerTest.java | 18 +-
.../db/wal/allocation/ElasticStrategyTest.java | 17 +-
.../db/wal/allocation/FirstCreateStrategyTest.java | 17 +-
.../db/wal/allocation/RoundRobinStrategyTest.java | 17 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 2 +-
.../datanode1conf/iotdb-datanode-metric.yml | 48 -
.../datanode1conf/iotdb-datanode.properties | 7 +
.../resources/datanode1conf/iotdb-rest.properties | 18 -
.../datanode2conf/iotdb-datanode-metric.yml | 48 -
.../datanode2conf/iotdb-datanode.properties | 7 +
.../resources/datanode2conf/iotdb-rest.properties | 18 -
.../datanode3conf/iotdb-datanode-metric.yml | 48 -
.../datanode3conf/iotdb-datanode.properties | 9 +-
.../resources/datanode3conf/iotdb-rest.properties | 18 -
...tdb-rest.properties => iotdb-common.properties} | 0
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 6 +-
.../java/org/apache/iotdb/session/Session.java | 15 +-
...tdb-rest.properties => iotdb-common.properties} | 0
site/src/main/.vuepress/config.js | 218 +-
thrift-commons/src/main/thrift/common.thrift | 1 +
.../src/main/thrift/confignode.thrift | 16 +-
.../pom.xml | 6 +-
.../src/main/thrift/iotconsensus.thrift | 6 +-
thrift/src/main/thrift/client.thrift | 11 +-
thrift/src/main/thrift/datanode.thrift | 11 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../tsfile/common/constant/TsFileConstant.java | 3 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 15 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 69 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 2 +-
.../read/common/block/column/BinaryColumn.java | 9 -
.../read/common/block/column/BooleanColumn.java | 9 -
.../read/common/block/column/ColumnBuilder.java | 2 +
.../read/common/block/column/DoubleColumn.java | 9 -
.../read/common/block/column/FloatColumn.java | 9 -
.../tsfile/read/common/block/column/IntColumn.java | 9 -
.../read/common/block/column/LongColumn.java | 9 -
.../block/column/RunLengthEncodedColumn.java | 15 -
.../read/common/block/column/TimeColumn.java | 7 -
.../iotdb/tsfile/read/filter/GroupByFilter.java | 10 +
.../iotdb/tsfile/read/filter/TimeFilter.java | 84 +
.../iotdb/tsfile/read/filter/basic/Filter.java | 7 +
.../tsfile/read/filter/operator/AndFilter.java | 40 +
.../tsfile/read/filter/operator/NotFilter.java | 27 +
.../tsfile/read/filter/operator/OrFilter.java | 66 +
.../read/reader/chunk/AlignedChunkReader.java | 69 +
.../tsfile/read/reader/chunk/ChunkReader.java | 67 +
.../iotdb/tsfile/utils/TsFileGeneratorUtils.java | 8 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 36 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 26 +
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 12 +
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 8 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 24 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 36 +-
.../tsfile/common/block/NullColumnUnitTest.java | 30 -
.../iotdb/tsfile/read/common/ColumnTest.java | 152 +-
.../iotdb/udf/api/collector/PointCollector.java | 4 +-
839 files changed, 49390 insertions(+), 39280 deletions(-)
create mode 100644 cli/src/assembly/resources/tools/load-tsfile.bat
create mode 100644 cli/src/assembly/resources/tools/load-tsfile.sh
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/{AdjustMaxRegionGroupCountPlan.java => AdjustMaxRegionGroupNumPlan.java} (61%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/RecordPipeMessagePlan.java
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/{CopySetRegionAllocator.java => CopySetRegionGroupAllocator.java} (91%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionAllocator.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionGroupAllocator.java
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/{IRegionAllocator.java => IRegionGroupAllocator.java} (70%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LeaderRouter.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/GreedyLeaderBalancer.java
copy confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/{IRouter.java => leader/ILeaderBalancer.java} (58%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/{mcf/MCFLeaderBalancer.java => leader/MinCostFlowLeaderBalancer.java} (78%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFEdge.java
copy confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/{LoadScoreGreedyRouter.java => priority/GreedyPriorityBalancer.java} (51%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/{IRouter.java => priority/IPriorityBalancer.java} (64%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/{LoadScoreGreedyRouter.java => priority/LeaderPriorityBalancer.java} (50%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/ActivateTemplatePlanImpl.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/DataRegionGroupExtensionPolicy.java (53%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/NodeInfoMetrics.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionAllocatorTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyRegionGroupAllocatorTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/GreedyLeaderBalancerTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/LeaderBalancerComparisonTest.java
rename confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/{mcf/MCFLeaderBalancerTest.java => leader/MinCostFlowLeaderBalancerTest.java} (88%)
rename confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/{LoadScoreGreedyRouterTest.java => priority/GreedyPriorityTest.java} (97%)
rename confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/{LeaderRouterTest.java => priority/LeaderPriorityBalancerTest.java} (69%)
delete mode 100644 confignode/src/test/resources/confignode1conf/iotdb-confignode-metric.yml
delete mode 100644 confignode/src/test/resources/confignode2conf/iotdb-confignode-metric.yml
delete mode 100644 confignode/src/test/resources/confignode3conf/iotdb-confignode-metric.yml
rename consensus/src/main/java/org/apache/iotdb/consensus/common/request/{MultiLeaderConsensusRequest.java => IoTConsensusRequest.java} (69%)
rename consensus/src/main/java/org/apache/iotdb/consensus/config/{MultiLeaderConfig.java => IoTConsensusConfig.java} (84%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/MultiLeaderConsensus.java => iot/IoTConsensus.java} (78%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/MultiLeaderServerImpl.java => iot/IoTConsensusServerImpl.java} (87%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/MultiLeaderServerMetrics.java => iot/IoTConsensusServerMetrics.java} (75%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/client/AsyncMultiLeaderServiceClient.java => iot/client/AsyncIoTConsensusServiceClient.java} (79%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/client/DispatchLogHandler.java (92%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/client/MultiLeaderConsensusClientPool.java => iot/client/IoTConsensusClientPool.java} (61%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/client/SyncMultiLeaderServiceClient.java => iot/client/SyncIoTConsensusServiceClient.java} (78%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/IndexController.java (89%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/logdispatcher/MultiLeaderMemoryManager.java => iot/logdispatcher/IoTConsensusMemoryManager.java} (71%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/logdispatcher/MultiLeaderMemoryManagerMetrics.java => iot/logdispatcher/IoTConsensusMemoryManagerMetrics.java} (69%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/LogDispatcher.java (74%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/LogDispatcherThreadMetrics.java (89%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/PendingBatch.java (58%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/SyncStatus.java (75%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCService.java => iot/service/IoTConsensusRPCService.java} (71%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCServiceHandler.java => iot/service/IoTConsensusRPCServiceHandler.java} (84%)
copy consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCServiceMBean.java => iot/service/IoTConsensusRPCServiceMBean.java} (88%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader/service/MultiLeaderRPCServiceProcessor.java => iot/service/IoTConsensusRPCServiceProcessor.java} (74%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/snapshot/SnapshotFragment.java (93%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/snapshot/SnapshotFragmentReader.java (97%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/wal/ConsensusReqReader.java (93%)
rename consensus/src/main/java/org/apache/iotdb/consensus/{multileader => iot}/wal/GetConsensusReqReaderPlan.java (95%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader/MultiLeaderConsensusTest.java => iot/IoTConsensusTest.java} (94%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/RecoveryTest.java (92%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/IndexControllerTest.java (98%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/logdispatcher/SyncStatusTest.java (89%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/util/FakeConsensusReqReader.java (95%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/util/RequestSets.java (96%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/util/TestEntry.java (91%)
rename consensus/src/test/java/org/apache/iotdb/consensus/{multileader => iot}/util/TestStateMachine.java (95%)
delete mode 100644 docker/src/main/DockerCompose/GrafanaPlugin/iotdb/conf/iotdb-rest.properties
rename docs/UserGuide/{Write-Data => Maintenance-Tools}/CSV-Tool.md (100%)
create mode 100644 docs/UserGuide/Maintenance-Tools/IoTDB-Data-Dir-Overview-Tool.md
rename docs/UserGuide/{Write-Data/Load-External-Tsfile.md => Maintenance-Tools/Load-Tsfile.md} (66%)
delete mode 100644 docs/UserGuide/Maintenance-Tools/NodeTool.md
delete mode 100644 docs/UserGuide/Maintenance-Tools/Rewrite-TsFile-Tool.md
rename docs/UserGuide/{Write-Data/TsFile-Tool.md => Maintenance-Tools/TsFile-Load-Export-Tool.md} (95%)
create mode 100644 docs/UserGuide/Maintenance-Tools/TsFile-Resource-Sketch-Tool.md
create mode 100644 docs/UserGuide/Maintenance-Tools/TsFile-Sketch-Tool.md
rename docs/UserGuide/Operate-Metadata/{Storage-Group.md => Database.md} (99%)
create mode 100644 docs/UserGuide/Operators-Functions/Aggregation.md
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Anomaly-Detection.md (100%)
create mode 100644 docs/UserGuide/Operators-Functions/Comparison.md
create mode 100644 docs/UserGuide/Operators-Functions/Constant.md
create mode 100644 docs/UserGuide/Operators-Functions/Continuous-Interval.md
create mode 100644 docs/UserGuide/Operators-Functions/Conversion.md
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Data-Matching.md (100%)
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Data-Profiling.md (100%)
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Data-Quality.md (100%)
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Data-Repairing.md (100%)
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Frequency-Domain.md (100%)
create mode 100644 docs/UserGuide/Operators-Functions/Lambda.md
create mode 100644 docs/UserGuide/Operators-Functions/Logical.md
create mode 100644 docs/UserGuide/Operators-Functions/Mathematical.md
rename docs/UserGuide/{UDF-Library/Quick-Start.md => Operators-Functions/Overview.md} (63%)
create mode 100644 docs/UserGuide/Operators-Functions/Sample.md
create mode 100644 docs/UserGuide/Operators-Functions/Selection.md
rename docs/UserGuide/{UDF-Library => Operators-Functions}/Series-Discovery.md (100%)
rename docs/UserGuide/{UDF-Library/String-Processing.md => Operators-Functions/String.md} (92%)
rename docs/UserGuide/{UDF-Library/Series-Processing.md => Operators-Functions/Time-Series.md} (99%)
rename docs/UserGuide/{Process-Data/UDF-User-Defined-Function.md => Operators-Functions/User-Defined-Function.md} (99%)
create mode 100644 docs/UserGuide/Operators-Functions/Variation-Trend.md
create mode 100644 docs/UserGuide/Query-Data/Align-By.md
rename docs/UserGuide/{Process-Data => Query-Data}/Continuous-Query.md (100%)
rename docs/UserGuide/Query-Data/{Fill-Null-Value.md => Fill.md} (64%)
rename docs/UserGuide/Query-Data/{Aggregate-Query.md => Group-By.md} (82%)
create mode 100644 docs/UserGuide/Query-Data/Having-Condition.md
rename docs/{zh/UserGuide/UDF-Library/M4.md => UserGuide/Query-Data/Order-By.md} (86%)
delete mode 100644 docs/UserGuide/Query-Data/Performance-Tracing-Tool.md
delete mode 100644 docs/UserGuide/Query-Data/Result-Format.md
rename docs/UserGuide/{Process-Data => Query-Data}/Select-Into.md (93%)
delete mode 100644 docs/UserGuide/Query-Data/Tracing-Tool.md
rename docs/UserGuide/Query-Data/{Query-Filter.md => Where-Condition.md} (97%)
delete mode 100644 docs/UserGuide/Query-Data/Without-Null.md
create mode 100644 docs/UserGuide/Reference/Common-Config-Manual.md
rename docs/UserGuide/{API => Reference}/Status-Codes.md (98%)
delete mode 100644 docs/UserGuide/Reference/Syntax-Conventions.md
copy docs/UserGuide/{UDF-Library/M4.md => Syntax-Conventions/Detailed-Grammar.md} (74%)
create mode 100644 docs/UserGuide/Syntax-Conventions/Identifier.md
create mode 100644 docs/UserGuide/Syntax-Conventions/KeyValue-Pair.md
copy docs/UserGuide/{UDF-Library/M4.md => Syntax-Conventions/Keywords-And-Reserved-Words.md} (75%)
create mode 100644 docs/UserGuide/Syntax-Conventions/Literal-Values.md
create mode 100644 docs/UserGuide/Syntax-Conventions/NodeName-In-Path.md
create mode 100644 docs/UserGuide/Syntax-Conventions/Session-And-TsFile-API.md
copy docs/UserGuide/{UDF-Library/M4.md => Trigger/Configuration-Parameters.md} (61%)
rename docs/UserGuide/{Process-Data/Triggers.md => Trigger/Implement-Trigger.md} (51%)
create mode 100644 docs/UserGuide/Trigger/Instructions.md
create mode 100644 docs/UserGuide/Trigger/Notes.md
create mode 100644 docs/UserGuide/Trigger/Trigger-Management.md
create mode 100644 docs/UserGuide/Write-Data/Batch-Load-Tool.md
rename docs/zh/UserGuide/{Write-Data => Maintenance-Tools}/CSV-Tool.md (99%)
create mode 100644 docs/zh/UserGuide/Maintenance-Tools/IoTDB-Data-Dir-Overview-Tool.md
rename docs/zh/UserGuide/{Write-Data/Load-External-Tsfile.md => Maintenance-Tools/Load-Tsfile.md} (68%)
delete mode 100644 docs/zh/UserGuide/Maintenance-Tools/NodeTool.md
delete mode 100644 docs/zh/UserGuide/Maintenance-Tools/Rewrite-TsFile-Tool.md
rename docs/zh/UserGuide/{Write-Data/TsFile-Tool.md => Maintenance-Tools/TsFile-Load-Export-Tool.md} (96%)
create mode 100644 docs/zh/UserGuide/Maintenance-Tools/TsFile-Resource-Sketch-Tool.md
create mode 100644 docs/zh/UserGuide/Maintenance-Tools/TsFile-Sketch-Tool.md
rename docs/zh/UserGuide/Operate-Metadata/{Storage-Group.md => Database.md} (96%)
create mode 100644 docs/zh/UserGuide/Operators-Functions/Aggregation.md
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Anomaly-Detection.md (95%)
create mode 100644 docs/zh/UserGuide/Operators-Functions/Comparison.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Constant.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Continuous-Interval.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Conversion.md
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Data-Matching.md (93%)
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Data-Profiling.md (98%)
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Data-Quality.md (96%)
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Data-Repairing.md (95%)
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Frequency-Domain.md (96%)
create mode 100644 docs/zh/UserGuide/Operators-Functions/Lambda.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Logical.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Mathematical.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Overview.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Sample.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Selection.md
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Series-Discovery.md (89%)
rename docs/zh/UserGuide/{UDF-Library/String-Processing.md => Operators-Functions/String.md} (89%)
rename docs/zh/UserGuide/{UDF-Library/Series-Processing.md => Operators-Functions/Time-Series.md} (83%)
rename docs/zh/UserGuide/{Process-Data/UDF-User-Defined-Function.md => Operators-Functions/User-Defined-Function.md} (99%)
create mode 100644 docs/zh/UserGuide/Operators-Functions/Variation-Trend.md
create mode 100644 docs/zh/UserGuide/Query-Data/Align-By.md
rename docs/zh/UserGuide/{Process-Data => Query-Data}/Continuous-Query.md (100%)
rename docs/zh/UserGuide/Query-Data/{Fill-Null-Value.md => Fill.md} (60%)
rename docs/zh/UserGuide/Query-Data/{Aggregate-Query.md => Group-By.md} (81%)
create mode 100644 docs/zh/UserGuide/Query-Data/Having-Condition.md
copy docs/{UserGuide/UDF-Library/M4.md => zh/UserGuide/Query-Data/Order-By.md} (84%)
delete mode 100644 docs/zh/UserGuide/Query-Data/Performance-Tracing-Tool.md
delete mode 100644 docs/zh/UserGuide/Query-Data/Result-Format.md
rename docs/zh/UserGuide/{Process-Data => Query-Data}/Select-Into.md (93%)
delete mode 100644 docs/zh/UserGuide/Query-Data/Tracing-Tool.md
rename docs/zh/UserGuide/Query-Data/{Query-Filter.md => Where-Condition.md} (85%)
delete mode 100644 docs/zh/UserGuide/Query-Data/Without-Null.md
create mode 100644 docs/zh/UserGuide/Reference/Common-Config-Manual.md
rename docs/zh/UserGuide/{API => Reference}/Status-Codes.md (98%)
delete mode 100644 docs/zh/UserGuide/Reference/Syntax-Conventions.md
copy docs/{UserGuide/UDF-Library/M4.md => zh/UserGuide/Syntax-Conventions/Detailed-Grammar.md} (76%)
create mode 100644 docs/zh/UserGuide/Syntax-Conventions/Identifier.md
create mode 100644 docs/zh/UserGuide/Syntax-Conventions/KeyValue-Pair.md
copy docs/{UserGuide/UDF-Library/M4.md => zh/UserGuide/Syntax-Conventions/Keywords-And-Reserved-Words.md} (74%)
create mode 100644 docs/zh/UserGuide/Syntax-Conventions/Literal-Values.md
create mode 100644 docs/zh/UserGuide/Syntax-Conventions/NodeName-In-Path.md
create mode 100644 docs/zh/UserGuide/Syntax-Conventions/Session-And-TsFile-API.md
rename docs/{UserGuide/UDF-Library/M4.md => zh/UserGuide/Trigger/Configuration-Parameters.md} (64%)
rename docs/zh/UserGuide/{Process-Data/Triggers.md => Trigger/Implement-Trigger.md} (51%)
create mode 100644 docs/zh/UserGuide/Trigger/Instructions.md
create mode 100644 docs/zh/UserGuide/Trigger/Notes.md
create mode 100644 docs/zh/UserGuide/Trigger/Trigger-Management.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/Quick-Start.md
create mode 100644 docs/zh/UserGuide/Write-Data/Batch-Load-Tool.md
rename grafana-metrics-example/cluster/{Apache IoTDB ConfigNode Dashboard v0.14.0.json => Apache IoTDB ConfigNode Dashboard.json} (64%)
rename grafana-metrics-example/cluster/{Apache IoTDB DataNode Dashboard v0.14.0.json => Apache IoTDB DataNode Dashboard.json} (66%)
delete mode 100644 grafana-metrics-example/standalone/Apache IoTDB Dashboard v0.14.0.json
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionDurableIT.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionDurableTest.java
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBPartitionInheritPolicyTest.java => IoTDBPartitionInheritPolicyIT.java} (85%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBRegionGroupExtensionIT.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardIoTDBReporter.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardMetricType.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardMetricsExporter.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardPrometheusReporter.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/IoTDBReporter.java
rename metrics/dropwizard-metrics/src/main/resources/META-INF/services/{org.apache.iotdb.metrics.reporter.Reporter => org.apache.iotdb.metrics.reporter.JmxReporter} (85%)
delete mode 100644 metrics/interface/src/main/assembly/resources/conf/iotdb-confignode-metric.yml
delete mode 100644 metrics/interface/src/main/assembly/resources/conf/iotdb-datanode-metric.yml
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/{reporter => }/CompositeReporter.java (85%)
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/config/MetricConstant.java
copy confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/AddConfigNodeState.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingAutoGauge.java (80%)
rename consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceMBean.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingMetric.java (88%)
copy confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/AddConfigNodeState.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/JmxReporter.java (76%)
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/InternalIoTDBReporter.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/IoTDBReporter.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/{impl/DoNothingRate.java => reporter/iotdb/MemoryInternalIoTDBReporter.java} (55%)
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/SessionIoTDBReporter.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/prometheus/PrometheusReporter.java
rename metrics/{dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter => interface/src/main/java/org/apache/iotdb/metrics/reporter/prometheus}/PrometheusTextWriter.java (72%)
copy confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/AddConfigNodeState.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/type/AutoGauge.java (74%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/{OutPutFormat.java => InternalReporterType.java} (89%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/{MonitorType.java => MetricFrameType.java} (96%)
delete mode 100644 metrics/interface/src/test/resources/iotdb-metric.yml
delete mode 100644 metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/IoTDBMeterRegistry.java
delete mode 100644 metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/IoTDBRegistryConfig.java
delete mode 100644 metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/MicrometerIoTDBReporter.java
delete mode 100644 metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/MicrometerPrometheusReporter.java
rename metrics/micrometer-metrics/src/main/resources/META-INF/services/{org.apache.iotdb.metrics.reporter.Reporter => org.apache.iotdb.metrics.reporter.JmxReporter} (85%)
create mode 100644 node-commons/src/assembly/resources/sbin/start-standalone.bat
rename server/src/assembly/resources/tools/detect-watermark.sh => node-commons/src/assembly/resources/sbin/start-standalone.sh (55%)
create mode 100644 node-commons/src/assembly/resources/sbin/stop-standalone.bat
copy server/src/test/resources/datanode1conf/iotdb-datanode.properties => node-commons/src/assembly/resources/sbin/stop-standalone.sh (61%)
rename {server/src/main/java/org/apache/iotdb/db/exception => node-commons/src/main/java/org/apache/iotdb/commons/exception/sync}/SyncConnectionException.java (96%)
copy confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/AddConfigNodeState.java => node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/SyncHandshakeException.java (80%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/sync/transport/SyncIdentityInfo.java
delete mode 100644 server/src/assembly/resources/conf/iotdb-rest.properties
delete mode 100644 server/src/assembly/resources/sbin/start-new-server.bat
delete mode 100644 server/src/assembly/resources/sbin/start-new-server.sh
delete mode 100644 server/src/assembly/resources/tools/detect-watermark.bat
delete mode 100644 server/src/assembly/resources/tools/rocksdb-transfer.bat
delete mode 100644 server/src/assembly/resources/tools/rocksdb-transfer.sh
rename server/src/assembly/resources/tools/schema/{SchemaFileSketcher.bat => print-schema-file.bat} (100%)
rename server/src/assembly/resources/tools/schema/{SchemaFileSketcher.sh => print-schema-file.sh} (100%)
rename server/src/assembly/resources/tools/schema/{mLogParser.bat => print-schema-log.bat} (100%)
rename server/src/assembly/resources/tools/schema/{mLogParser.sh => print-schema-log.sh} (100%)
delete mode 100644 server/src/assembly/resources/tools/start-WalChecker.bat
delete mode 100755 server/src/assembly/resources/tools/start-WalChecker.sh
rename server/src/assembly/resources/tools/{tsfileToolSet => tsfile}/print-iotdb-data-dir.bat (100%)
rename server/src/assembly/resources/tools/{tsfileToolSet => tsfile}/print-iotdb-data-dir.sh (100%)
rename server/src/assembly/resources/tools/{tsfileToolSet => tsfile}/print-tsfile-resource-files.bat (100%)
rename server/src/assembly/resources/tools/{tsfileToolSet => tsfile}/print-tsfile-resource-files.sh (100%)
rename server/src/assembly/resources/tools/{tsfileToolSet/print-tsfile-sketch.bat => tsfile/print-tsfile.bat} (100%)
rename server/src/assembly/resources/tools/{tsfileToolSet/print-tsfile-sketch.sh => tsfile/print-tsfile.sh} (100%)
mode change 100755 => 100644
rename server/src/assembly/resources/tools/{tsfileToolSet => tsfile}/split-tsfile-tool.bat (100%)
rename server/src/assembly/resources/tools/{tsfileToolSet => tsfile}/split-tsfile-tool.sh (100%)
rename server/src/assembly/resources/tools/{tsfileToolSet => tsfile}/validate-tsfile.bat (100%)
rename server/src/assembly/resources/tools/{tsfileToolSet => tsfile}/validate-tsfile.sh (100%)
delete mode 100644 server/src/assembly/resources/tools/tsfileToolSet/print-tsfile-visdata.bat
delete mode 100644 server/src/assembly/resources/tools/tsfileToolSet/print-tsfile-visdata.sh
delete mode 100644 server/src/assembly/resources/tools/tsfileToolSet/settle.bat
delete mode 100644 server/src/assembly/resources/tools/tsfileToolSet/settle.sh
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/FastCompactionPerformerSubTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/AlignedSeriesCompactionExecutor.java
copy integration/src/test/java/org/apache/iotdb/db/integration/sync/MockSyncClient.java => server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/ChunkMetadataElement.java (50%)
rename server/src/main/java/org/apache/iotdb/db/{mpp/common/SchemaRegion.java => engine/compaction/cross/utils/FileElement.java} (69%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/NonAlignedSeriesCompactionExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/PageElement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/PointElement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/SeriesCompactionExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/FastCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/reader/PointPriorityReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/SubCompactionTaskSummary.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/AbstractCrossCompactionWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/AbstractInnerCompactionWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/CrossSpaceCompactionWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/FastCrossCompactionWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/FastInnerCompactionWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/InnerSpaceCompactionWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/ReadPointCrossCompactionWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/ReadPointInnerCompactionWriter.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{ => cache}/lastCache/container/ILastCacheContainer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ => cache}/lastCache/container/LastCacheContainer.java (91%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ => cache}/lastCache/container/value/ILastCacheValue.java (94%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ => cache}/lastCache/container/value/LastCacheValue.java (95%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/lastCache/LastCacheManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogTxtReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogTxtWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/SetTemplatePlanImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/UnsetTemplatePlanImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IActivateTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/ISetTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/IUnsetTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateLogWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/upgrade/MetadataUpgrader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/IoTDBInternalReporter.java
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver => pipedata}/load/DeletionLoader.java (98%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver => pipedata}/load/ILoader.java (97%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver => pipedata}/load/TsFileLoader.java (97%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/tools/vis/TsFileExtractVisdata.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/tools/vis/vis.m
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/FastAlignedCrossCompactionTest.java
copy server/src/test/java/org/apache/iotdb/db/engine/compaction/{ReadPointCompactionPerformerTest.java => FastCrossCompactionPerformerTest.java} (62%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/FastInnerCompactionPerformerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/FastNonAlignedCrossCompactionTest.java
copy server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{ReadChunkCompactionPerformerAlignedTest.java => FastCompactionPerformerAlignedTest.java} (92%)
copy server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{ReadChunkCompactionPerformerNoAlignedTest.java => FastCompactionPerformerNoAlignedTest.java} (94%)
copy server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerSeqCompactionTest.java => InnerSeqCompactionWithFastPerformerTest.java} (94%)
rename server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerSeqCompactionTest.java => InnerSeqCompactionWithReadChunkPerformerTest.java} (98%)
copy server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerUnseqCompactionTest.java => InnerUnseqCompactionWithFastPerformerTest.java} (98%)
rename server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerUnseqCompactionTest.java => InnerUnseqCompactionWithReadPointPerformerTest.java} (99%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/utils/TsFileGeneratorUtils.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/LastQueryWithIDTable.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/trigger_example/Counter.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/upgrade/MetadataUpgradeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/QueryTimePartitionTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/sql/IoTDBsqlVisitorTest.java
delete mode 100644 server/src/test/resources/datanode1conf/iotdb-datanode-metric.yml
delete mode 100644 server/src/test/resources/datanode1conf/iotdb-rest.properties
delete mode 100644 server/src/test/resources/datanode2conf/iotdb-datanode-metric.yml
delete mode 100644 server/src/test/resources/datanode2conf/iotdb-rest.properties
delete mode 100644 server/src/test/resources/datanode3conf/iotdb-datanode-metric.yml
delete mode 100644 server/src/test/resources/datanode3conf/iotdb-rest.properties
rename server/src/test/resources/{iotdb-rest.properties => iotdb-common.properties} (100%)
rename session/src/test/resources/{iotdb-rest.properties => iotdb-common.properties} (100%)
rename {thrift-multi-leader-consensus => thrift-iot-consensus}/pom.xml (93%)
rename thrift-multi-leader-consensus/src/main/thrift/mutlileader.thrift => thrift-iot-consensus/src/main/thrift/iotconsensus.thrift (96%)
[iotdb] 01/02: merge
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch QueryMetrics
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7bf78f1a94eb014628bdf51be2b5bc9f3fadb9ff
Merge: 40717cc921 bdce979954
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Sat Nov 26 21:02:43 2022 +0800
merge
RELEASE_NOTES.md | 265 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 228 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 10 +-
cli/src/assembly/resources/tools/load-tsfile.bat | 107 +
cli/src/assembly/resources/tools/load-tsfile.sh | 132 +
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 65 +-
client-go | 2 +-
confignode/src/assembly/confignode.xml | 4 -
.../resources/conf/iotdb-confignode.properties | 60 +-
.../confignode/client/ConfigNodeRequestType.java | 2 +-
.../client/async/AsyncDataNodeClientPool.java | 13 +-
.../client/sync/SyncConfigNodeClientPool.java | 5 +-
.../client/sync/SyncDataNodeClientPool.java | 14 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 97 +-
.../confignode/conf/ConfigNodeDescriptor.java | 62 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 28 +-
.../consensus/request/ConfigPhysicalPlan.java | 10 +-
.../consensus/request/ConfigPhysicalPlanType.java | 3 +-
.../write/region/CreateRegionGroupsPlan.java | 19 +
...tPlan.java => AdjustMaxRegionGroupNumPlan.java} | 46 +-
.../request/write/sync/RecordPipeMessagePlan.java | 65 +
.../statemachine/ConfigNodeRegionStateMachine.java | 2 +-
.../confignode/manager/ClusterSchemaManager.java | 107 +-
.../iotdb/confignode/manager/ConfigManager.java | 20 +-
.../iotdb/confignode/manager/ConsensusManager.java | 52 +-
.../apache/iotdb/confignode/manager/IManager.java | 8 +
.../iotdb/confignode/manager/SyncManager.java | 12 +
.../iotdb/confignode/manager/load/LoadManager.java | 2 +-
.../manager/load/LoadManagerMetrics.java | 112 +-
.../manager/load/balancer/RegionBalancer.java | 84 +-
.../manager/load/balancer/RouteBalancer.java | 162 +-
...cator.java => CopySetRegionGroupAllocator.java} | 15 +-
.../balancer/region/GreedyRegionAllocator.java | 68 -
.../region/GreedyRegionGroupAllocator.java | 101 +
...onAllocator.java => IRegionGroupAllocator.java} | 24 +-
.../manager/load/balancer/router/LeaderRouter.java | 90 -
.../router/leader/GreedyLeaderBalancer.java | 186 ++
.../{IRouter.java => leader/ILeaderBalancer.java} | 30 +-
.../MinCostFlowLeaderBalancer.java} | 102 +-
.../manager/load/balancer/router/mcf/MCFEdge.java | 34 -
.../GreedyPriorityBalancer.java} | 65 +-
.../IPriorityBalancer.java} | 24 +-
.../LeaderPriorityBalancer.java} | 49 +-
.../iotdb/confignode/manager/node/NodeManager.java | 27 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 13 +
.../node/heartbeat/NodeHeartbeatSample.java | 21 +-
.../manager/partition/PartitionManager.java | 76 +-
.../persistence/executor/ConfigPlanExecutor.java | 9 +-
.../persistence/metric/NodeInfoMetrics.java | 95 -
.../persistence/metric/PartitionInfoMetrics.java | 30 +-
.../persistence/partition/PartitionInfo.java | 8 +-
.../persistence/schema/ClusterSchemaInfo.java | 22 +-
.../persistence/sync/ClusterSyncInfo.java | 9 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 111 +-
.../procedure/env/DataNodeRemoveHandler.java | 41 +-
.../impl/node/AddConfigNodeProcedure.java | 38 +-
.../impl/node/RemoveDataNodeProcedure.java | 2 +-
.../impl/schema/DeactivateTemplateProcedure.java | 6 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 6 +-
.../impl/schema/UnsetTemplateProcedure.java | 4 +-
.../statemachine/CreateRegionGroupsProcedure.java | 13 +-
.../procedure/state/AddConfigNodeState.java | 3 +-
.../iotdb/confignode/service/ConfigNode.java | 7 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 18 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../balancer/region/GreedyRegionAllocatorTest.java | 92 -
.../region/GreedyRegionGroupAllocatorTest.java | 140 +
.../router/leader/GreedyLeaderBalancerTest.java | 146 +
.../leader/LeaderBalancerComparisonTest.java | 369 +++
.../MinCostFlowLeaderBalancerTest.java} | 33 +-
.../GreedyPriorityTest.java} | 8 +-
.../LeaderPriorityBalancerTest.java} | 56 +-
.../confignode1conf/iotdb-common.properties | 2 +-
.../confignode1conf/iotdb-confignode-metric.yml | 48 -
.../confignode1conf/iotdb-confignode.properties | 8 +-
.../confignode2conf/iotdb-common.properties | 2 +-
.../confignode2conf/iotdb-confignode-metric.yml | 48 -
.../confignode2conf/iotdb-confignode.properties | 8 +-
.../confignode3conf/iotdb-common.properties | 2 +-
.../confignode3conf/iotdb-confignode-metric.yml | 48 -
.../confignode3conf/iotdb-confignode.properties | 8 +-
consensus/pom.xml | 11 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 3 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 13 +-
.../common/request/IndexedConsensusRequest.java | 27 +-
...sensusRequest.java => IoTConsensusRequest.java} | 12 +-
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
...tiLeaderConfig.java => IoTConsensusConfig.java} | 71 +-
.../IoTConsensus.java} | 96 +-
.../IoTConsensusServerImpl.java} | 119 +-
.../IoTConsensusServerMetrics.java} | 36 +-
.../client/AsyncIoTConsensusServiceClient.java} | 27 +-
.../client/DispatchLogHandler.java | 10 +-
.../client/IoTConsensusClientPool.java} | 45 +-
.../client/SyncIoTConsensusServiceClient.java} | 32 +-
.../logdispatcher/IndexController.java | 13 +-
.../logdispatcher/IoTConsensusMemoryManager.java} | 24 +-
.../IoTConsensusMemoryManagerMetrics.java} | 20 +-
.../logdispatcher/LogDispatcher.java | 199 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 18 +-
.../logdispatcher/PendingBatch.java | 50 +-
.../logdispatcher/SyncStatus.java | 27 +-
.../service/IoTConsensusRPCService.java} | 32 +-
.../service/IoTConsensusRPCServiceHandler.java} | 8 +-
.../service/IoTConsensusRPCServiceMBean.java} | 4 +-
.../service/IoTConsensusRPCServiceProcessor.java} | 112 +-
.../snapshot/SnapshotFragment.java | 4 +-
.../snapshot/SnapshotFragmentReader.java | 2 +-
.../wal/ConsensusReqReader.java | 2 +-
.../wal/GetConsensusReqReaderPlan.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 3 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 21 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 57 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 31 +-
.../IoTConsensusTest.java} | 20 +-
.../{multileader => iot}/RecoveryTest.java | 8 +-
.../logdispatcher/IndexControllerTest.java | 2 +-
.../logdispatcher/SyncStatusTest.java | 29 +-
.../util/FakeConsensusReqReader.java | 4 +-
.../{multileader => iot}/util/RequestSets.java | 2 +-
.../{multileader => iot}/util/TestEntry.java | 6 +-
.../util/TestStateMachine.java | 6 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 23 +-
distribution/src/assembly/all.xml | 16 -
distribution/src/assembly/confignode.xml | 6 -
distribution/src/assembly/datanode.xml | 12 -
.../GrafanaPlugin/iotdb/conf/iotdb-rest.properties | 61 -
docs/UserGuide/API/RestService.md | 60 +-
.../Administration-Management/Administration.md | 4 +-
docs/UserGuide/Cluster/Cluster-Concept.md | 49 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 228 +-
docs/UserGuide/Data-Concept/Deadband-Process.md | 2 +-
docs/UserGuide/Data-Concept/Schema-Template.md | 15 +
.../Ecosystem-Integration/Grafana-Plugin.md | 4 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 24 +-
docs/UserGuide/FAQ/Frequently-asked-questions.md | 2 +-
.../{Write-Data => Maintenance-Tools}/CSV-Tool.md | 0
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
.../Load-Tsfile.md} | 41 +-
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 6 +-
.../Maintenance-Tools/Maintenance-Command.md | 255 +-
docs/UserGuide/Maintenance-Tools/NodeTool.md | 297 --
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 6 +-
.../TsFile-Load-Export-Tool.md} | 5 +-
.../TsFile-Resource-Sketch-Tool.md | 79 +
.../Maintenance-Tools/TsFile-Sketch-Tool.md | 108 +
.../Maintenance-Tools/TsFile-Split-Tool.md | 25 +-
docs/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 585 ++--
.../{Storage-Group.md => Database.md} | 4 +-
docs/UserGuide/Operate-Metadata/Template.md | 2 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 4 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 58 +
.../Anomaly-Detection.md | 0
docs/UserGuide/Operators-Functions/Comparison.md | 305 ++
docs/UserGuide/Operators-Functions/Constant.md | 57 +
.../Operators-Functions/Continuous-Interval.md | 73 +
docs/UserGuide/Operators-Functions/Conversion.md | 127 +
.../Data-Matching.md | 0
.../Data-Profiling.md | 0
.../Data-Quality.md | 0
.../Data-Repairing.md | 0
.../Frequency-Domain.md | 0
docs/UserGuide/Operators-Functions/Lambda.md | 77 +
docs/UserGuide/Operators-Functions/Logical.md | 63 +
docs/UserGuide/Operators-Functions/Mathematical.md | 113 +
.../Overview.md} | 24 +
docs/UserGuide/Operators-Functions/Sample.md | 389 +++
docs/UserGuide/Operators-Functions/Selection.md | 51 +
.../Series-Discovery.md | 0
.../String.md} | 66 +
.../Time-Series.md} | 2 +-
.../User-Defined-Function.md} | 2 -
.../Operators-Functions/Variation-Trend.md | 54 +
docs/UserGuide/Query-Data/Align-By.md | 57 +
.../Continuous-Query.md | 0
.../Query-Data/{Fill-Null-Value.md => Fill.md} | 116 +-
.../Query-Data/{Aggregate-Query.md => Group-By.md} | 142 +-
docs/UserGuide/Query-Data/Having-Condition.md | 115 +
docs/UserGuide/Query-Data/Last-Query.md | 16 +-
.../M4.md => UserGuide/Query-Data/Order-By.md} | 6 +-
docs/UserGuide/Query-Data/Overview.md | 97 +-
docs/UserGuide/Query-Data/Pagination.md | 39 +-
.../Query-Data/Performance-Tracing-Tool.md | 53 -
docs/UserGuide/Query-Data/Result-Format.md | 82 -
docs/UserGuide/Query-Data/Select-Expression.md | 1087 +------
.../{Process-Data => Query-Data}/Select-Into.md | 22 +-
docs/UserGuide/Query-Data/Tracing-Tool.md | 48 -
.../{Query-Filter.md => Where-Condition.md} | 7 +-
docs/UserGuide/Query-Data/Without-Null.md | 172 -
docs/UserGuide/QuickStart/Files.md | 92 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 1888 +++++++++++
.../Reference/ConfigNode-Config-Manual.md | 257 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 1192 +------
docs/UserGuide/Reference/Keywords.md | 401 ++-
docs/UserGuide/Reference/SQL-Reference.md | 12 +-
docs/UserGuide/{API => Reference}/Status-Codes.md | 4 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 591 ----
.../Detailed-Grammar.md} | 7 +-
docs/UserGuide/Syntax-Conventions/Identifier.md | 141 +
docs/UserGuide/Syntax-Conventions/KeyValue-Pair.md | 119 +
.../Keywords-And-Reserved-Words.md} | 7 +-
.../UserGuide/Syntax-Conventions/Literal-Values.md | 157 +
.../Syntax-Conventions/NodeName-In-Path.md | 119 +
.../Syntax-Conventions/Session-And-TsFile-API.md | 119 +
.../M4.md => Trigger/Configuration-Parameters.md} | 8 +-
.../Triggers.md => Trigger/Implement-Trigger.md} | 201 +-
docs/UserGuide/Trigger/Instructions.md | 51 +
docs/UserGuide/Trigger/Notes.md | 30 +
docs/UserGuide/Trigger/Trigger-Management.md | 152 +
docs/UserGuide/Write-Data/Batch-Load-Tool.md | 32 +
docs/UserGuide/Write-Data/REST-API.md | 6 +-
docs/zh/UserGuide/API/RestService.md | 78 +-
.../Administration-Management/Administration.md | 4 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 50 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 231 +-
docs/zh/UserGuide/Data-Concept/Deadband-Process.md | 2 +-
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 15 +
.../Ecosystem-Integration/Grafana-Plugin.md | 4 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 16 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 2 +-
.../{Write-Data => Maintenance-Tools}/CSV-Tool.md | 2 +-
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
.../Load-Tsfile.md} | 41 +-
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 6 +-
.../Maintenance-Tools/Maintenance-Command.md | 250 +-
docs/zh/UserGuide/Maintenance-Tools/NodeTool.md | 293 --
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 8 +-
.../TsFile-Load-Export-Tool.md} | 6 +-
.../TsFile-Resource-Sketch-Tool.md | 79 +
.../Maintenance-Tools/TsFile-Sketch-Tool.md | 108 +
.../Maintenance-Tools/TsFile-Split-Tool.md | 20 +-
docs/zh/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 757 +++--
.../{Storage-Group.md => Database.md} | 6 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 4 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 14 +-
.../UserGuide/Operators-Functions/Aggregation.md | 41 +
.../Anomaly-Detection.md | 32 +-
.../zh/UserGuide/Operators-Functions/Comparison.md | 309 ++
docs/zh/UserGuide/Operators-Functions/Constant.md | 57 +
.../Operators-Functions/Continuous-Interval.md | 75 +
.../zh/UserGuide/Operators-Functions/Conversion.md | 131 +
.../Data-Matching.md | 32 +-
.../Data-Profiling.md | 32 +-
.../Data-Quality.md | 32 +-
.../Data-Repairing.md | 32 +-
.../Frequency-Domain.md | 32 +-
docs/zh/UserGuide/Operators-Functions/Lambda.md | 83 +
docs/zh/UserGuide/Operators-Functions/Logical.md | 63 +
.../UserGuide/Operators-Functions/Mathematical.md | 116 +
docs/zh/UserGuide/Operators-Functions/Overview.md | 239 ++
docs/zh/UserGuide/Operators-Functions/Sample.md | 408 +++
docs/zh/UserGuide/Operators-Functions/Selection.md | 51 +
.../Series-Discovery.md | 32 +-
.../String.md} | 104 +-
.../Time-Series.md} | 36 +-
.../User-Defined-Function.md} | 4 +-
.../Operators-Functions/Variation-Trend.md | 54 +
docs/zh/UserGuide/Query-Data/Align-By.md | 61 +
.../Continuous-Query.md | 0
.../Query-Data/{Fill-Null-Value.md => Fill.md} | 134 +-
.../Query-Data/{Aggregate-Query.md => Group-By.md} | 346 +-
docs/zh/UserGuide/Query-Data/Having-Condition.md | 115 +
docs/zh/UserGuide/Query-Data/Last-Query.md | 24 +-
.../M4.md => zh/UserGuide/Query-Data/Order-By.md} | 7 +-
docs/zh/UserGuide/Query-Data/Overview.md | 121 +-
docs/zh/UserGuide/Query-Data/Pagination.md | 118 +-
.../Query-Data/Performance-Tracing-Tool.md | 51 -
docs/zh/UserGuide/Query-Data/Result-Format.md | 89 -
docs/zh/UserGuide/Query-Data/Select-Expression.md | 1173 +------
.../{Process-Data => Query-Data}/Select-Into.md | 24 +-
docs/zh/UserGuide/Query-Data/Tracing-Tool.md | 48 -
.../{Query-Filter.md => Where-Condition.md} | 21 +-
docs/zh/UserGuide/Query-Data/Without-Null.md | 172 -
docs/zh/UserGuide/QuickStart/Files.md | 88 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 1932 +++++++++++
.../Reference/ConfigNode-Config-Manual.md | 326 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 1782 +---------
docs/zh/UserGuide/Reference/Keywords.md | 401 ++-
docs/zh/UserGuide/Reference/SQL-Reference.md | 12 +-
.../UserGuide/{API => Reference}/Status-Codes.md | 4 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 590 ----
.../Syntax-Conventions/Detailed-Grammar.md} | 7 +-
docs/zh/UserGuide/Syntax-Conventions/Identifier.md | 142 +
.../UserGuide/Syntax-Conventions/KeyValue-Pair.md | 119 +
.../Keywords-And-Reserved-Words.md} | 6 +-
.../UserGuide/Syntax-Conventions/Literal-Values.md | 150 +
.../Syntax-Conventions/NodeName-In-Path.md | 120 +
.../Syntax-Conventions/Session-And-TsFile-API.md | 119 +
.../UserGuide/Trigger/Configuration-Parameters.md} | 8 +-
.../Triggers.md => Trigger/Implement-Trigger.md} | 198 +-
docs/zh/UserGuide/Trigger/Instructions.md | 46 +
docs/zh/UserGuide/Trigger/Notes.md | 33 +
docs/zh/UserGuide/Trigger/Trigger-Management.md | 152 +
docs/zh/UserGuide/UDF-Library/Quick-Start.md | 40 -
docs/zh/UserGuide/Write-Data/Batch-Load-Tool.md | 32 +
docs/zh/UserGuide/Write-Data/REST-API.md | 6 +-
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 20 +-
grafana-plugin/go.sum | 2 +-
grafana-plugin/pkg/plugin/plugin.go | 8 +-
.../trigger/example/TriggerFireTimesCounter.java | 5 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 58 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 12 +-
.../java/org/apache/iotdb/it/env/MppConfig.java | 30 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 18 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 28 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 10 +
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 82 +-
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 8 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 3 +-
.../it/partition/IoTDBPartitionDurableIT.java | 626 ++++
.../it/partition/IoTDBPartitionDurableTest.java | 323 --
.../it/partition/IoTDBPartitionGetterIT.java | 88 +-
...est.java => IoTDBPartitionInheritPolicyIT.java} | 31 +-
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 14 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 2 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 2 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 75 +-
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 39 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 18 +-
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 6 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 2 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 8 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 2 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 4 +-
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 20 +
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 1324 -> 1397 bytes
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 14 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 102 -
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../sync/IoTDBSyncReceiverLoaderIT.java | 6 +-
.../iotdb/db/integration/sync/MockSyncClient.java | 4 +-
metrics/ReadMe.md | 29 +-
metrics/dropwizard-metrics/pom.xml | 5 -
.../dropwizard/DropwizardMetricManager.java | 3 +-
.../reporter/DropwizardIoTDBReporter.java | 79 -
.../dropwizard/reporter/DropwizardJmxReporter.java | 9 +-
.../dropwizard/reporter/DropwizardMetricType.java | 38 -
.../reporter/DropwizardMetricsExporter.java | 168 -
.../reporter/DropwizardPrometheusReporter.java | 118 -
.../metrics/dropwizard/reporter/IoTDBReporter.java | 278 --
.../dropwizard/type/DropwizardAutoGauge.java | 19 +-
.../type/DropwizardHistogramSnapshot.java | 7 -
... org.apache.iotdb.metrics.reporter.JmxReporter} | 4 +-
metrics/interface/pom.xml | 11 +-
.../resources/conf/iotdb-confignode-metric.yml | 49 -
.../resources/conf/iotdb-datanode-metric.yml | 49 -
.../iotdb/metrics/AbstractMetricManager.java | 201 +-
.../iotdb/metrics/AbstractMetricService.java | 231 +-
.../metrics/{reporter => }/CompositeReporter.java | 25 +-
.../iotdb/metrics/DoNothingMetricService.java | 8 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 248 +-
.../metrics/config/MetricConfigDescriptor.java | 221 +-
.../iotdb/metrics/config/MetricConstant.java | 37 -
.../apache/iotdb/metrics/config/ReloadLevel.java | 6 +-
.../iotdb/metrics/impl/DoNothingAutoGauge.java | 13 +-
.../iotdb/metrics/impl/DoNothingCounter.java | 2 +-
.../apache/iotdb/metrics/impl/DoNothingGauge.java | 2 +-
.../iotdb/metrics/impl/DoNothingHistogram.java | 2 +-
.../metrics/impl/DoNothingHistogramSnapshot.java | 9 +-
.../apache/iotdb/metrics/impl/DoNothingMetric.java | 4 +-
.../iotdb/metrics/impl/DoNothingMetricManager.java | 11 +-
.../apache/iotdb/metrics/impl/DoNothingRate.java | 2 +-
.../apache/iotdb/metrics/impl/DoNothingTimer.java | 2 +-
.../metricsets/jvm/JvmClassLoaderMetrics.java | 12 +-
.../metrics/metricsets/jvm/JvmCompileMetrics.java | 6 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 28 +-
.../metrics/metricsets/jvm/JvmMemoryMetrics.java | 48 +-
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 24 +-
.../metrics/metricsets/logback/LogbackMetrics.java | 10 +-
.../metricsets/logback/MetricsTurboFilter.java | 10 +-
.../apache/iotdb/metrics/reporter/JmxReporter.java | 14 +-
.../apache/iotdb/metrics/reporter/Reporter.java | 10 +-
.../reporter/iotdb/InternalIoTDBReporter.java | 67 +
.../metrics/reporter/iotdb/IoTDBReporter.java | 103 +
.../iotdb/MemoryInternalIoTDBReporter.java} | 38 +-
.../reporter/iotdb/SessionIoTDBReporter.java | 175 +
.../reporter/prometheus/PrometheusReporter.java | 222 ++
.../reporter/prometheus}/PrometheusTextWriter.java | 44 +-
.../org/apache/iotdb/metrics/type/AutoGauge.java | 19 +-
.../org/apache/iotdb/metrics/type/Counter.java | 13 +-
.../java/org/apache/iotdb/metrics/type/Gauge.java | 15 +-
.../org/apache/iotdb/metrics/type/Histogram.java | 14 +-
.../iotdb/metrics/type/HistogramSnapshot.java | 34 +-
.../org/apache/iotdb/metrics/type/IMetric.java | 8 +-
.../java/org/apache/iotdb/metrics/type/Rate.java | 25 +-
.../java/org/apache/iotdb/metrics/type/Timer.java | 17 +-
...OutPutFormat.java => InternalReporterType.java} | 8 +-
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 74 +-
.../{MonitorType.java => MetricFrameType.java} | 2 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 18 +-
.../org/apache/iotdb/metrics/utils/MetricType.java | 1 +
.../iotdb/metrics/config/MetricConfigTest.java | 86 +-
.../interface/src/test/resources/iotdb-metric.yml | 52 -
.../micrometer/MicrometerMetricManager.java | 4 +-
.../micrometer/reporter/IoTDBMeterRegistry.java | 149 -
.../micrometer/reporter/IoTDBRegistryConfig.java | 50 -
.../reporter/MicrometerIoTDBReporter.java | 92 -
.../micrometer/reporter/MicrometerJmxReporter.java | 7 +-
.../reporter/MicrometerPrometheusReporter.java | 118 -
.../micrometer/type/MicrometerAutoGauge.java | 19 +-
.../type/MicrometerHistogramSnapshot.java | 7 -
... org.apache.iotdb.metrics.reporter.JmxReporter} | 4 +-
.../resources/conf/iotdb-common.properties | 274 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 4 +-
.../apache/iotdb/commons/client/ClientManager.java | 7 +-
.../sync/SyncThriftClientWithErrorHandler.java | 3 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 12 +-
.../iotdb/commons/conf/CommonDescriptor.java | 7 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 16 +
.../exception/sync}/SyncConnectionException.java | 2 +-
.../exception/sync/SyncHandshakeException.java | 10 +-
.../commons/partition/DataPartitionQueryParam.java | 6 +
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../commons/service/metric/MetricService.java | 105 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +-
.../iotdb/commons/sync/metadata/SyncMetadata.java | 3 +
.../iotdb/commons/sync/pipe/PipeMessage.java | 54 +-
.../commons/sync/transport/SyncIdentityInfo.java | 57 +
.../iotdb/commons/sync/utils/SyncPathUtil.java | 17 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 14 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 39 +-
openapi/src/main/openapi3/iotdb-rest.yaml | 17 +-
pom.xml | 4 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 138 +-
.../schemaregion/rocksdb/mnode/REntityMNode.java | 16 -
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 32 -
.../rocksdb/mnode/RMeasurementMNode.java | 32 -
.../rocksdb/mnode/RStorageGroupMNode.java | 8 -
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 85 +-
.../utils/ShowTimeSeriesResultUtils.java | 4 +-
.../src/assembly/resources/conf/datanode-env.bat | 2 +-
.../resources/conf/iotdb-datanode.properties | 128 +-
.../assembly/resources/conf/iotdb-rest.properties | 64 -
.../assembly/resources/sbin/start-new-server.bat | 167 -
.../assembly/resources/sbin/start-new-server.sh | 249 --
.../assembly/resources/tools/detect-watermark.bat | 65 -
.../assembly/resources/tools/detect-watermark.sh | 47 -
.../assembly/resources/tools/rocksdb-transfer.bat | 126 -
.../assembly/resources/tools/rocksdb-transfer.sh | 82 -
...chemaFileSketcher.bat => print-schema-file.bat} | 0
...{SchemaFileSketcher.sh => print-schema-file.sh} | 0
.../{mLogParser.bat => print-schema-log.bat} | 0
.../schema/{mLogParser.sh => print-schema-log.sh} | 0
.../assembly/resources/tools/start-WalChecker.bat | 111 -
.../assembly/resources/tools/start-WalChecker.sh | 91 -
.../print-iotdb-data-dir.bat | 0
.../print-iotdb-data-dir.sh | 0
.../print-tsfile-resource-files.bat | 0
.../print-tsfile-resource-files.sh | 0
.../print-tsfile.bat} | 0
.../print-tsfile.sh} | 0
.../split-tsfile-tool.bat | 0
.../{tsfileToolSet => tsfile}/split-tsfile-tool.sh | 0
.../{tsfileToolSet => tsfile}/validate-tsfile.bat | 0
.../{tsfileToolSet => tsfile}/validate-tsfile.sh | 0
.../tools/tsfileToolSet/print-tsfile-visdata.bat | 62 -
.../tools/tsfileToolSet/print-tsfile-visdata.sh | 51 -
.../resources/tools/tsfileToolSet/settle.bat | 62 -
.../resources/tools/tsfileToolSet/settle.sh | 51 -
server/src/assembly/server.xml | 4 -
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 8 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 173 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 6 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 85 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 70 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 -
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 10 +-
.../consensus/statemachine/BaseStateMachine.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 23 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 2 +-
.../iotdb/db/engine/TsFileMetricManager.java | 6 +-
.../iotdb/db/engine/cache/ChunkCacheMetrics.java | 4 +-
.../cache/TimeSeriesMetadataCacheMetrics.java | 8 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 19 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 9 +-
.../iotdb/db/engine/flush/FlushManagerMetrics.java | 8 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 17 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 28 +-
.../db/engine/storagegroup/DataRegionMetrics.java | 8 +-
.../db/engine/storagegroup/TsFileProcessor.java | 196 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 4 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 250 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 550 +---
.../metadata/cache/DataNodeLastCacheManager.java | 2 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 4 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 4 +-
.../lastCache/container/ILastCacheContainer.java | 2 +-
.../lastCache/container/LastCacheContainer.java | 6 +-
.../lastCache/container/value/ILastCacheValue.java | 2 +-
.../lastCache/container/value/LastCacheValue.java | 2 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 45 -
.../db/metadata/idtable/IDTableHashmapImpl.java | 65 -
.../idtable/entry/InsertMeasurementMNode.java | 31 -
.../db/metadata/idtable/entry/SchemaEntry.java | 82 +-
.../db/metadata/lastCache/LastCacheManager.java | 255 --
.../iotdb/db/metadata/logfile/MLogTxtReader.java | 78 -
.../iotdb/db/metadata/logfile/MLogTxtWriter.java | 458 ---
.../iotdb/db/metadata/logfile/MLogWriter.java | 43 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 24 -
.../iotdb/db/metadata/mnode/IEntityMNode.java | 6 -
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 11 -
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 5 -
.../iotdb/db/metadata/mnode/InternalMNode.java | 56 -
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 56 -
.../db/metadata/mnode/StorageGroupEntityMNode.java | 10 -
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 19 -
.../mnode/estimator/BasicMNodSizeEstimator.java | 9 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 10 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 93 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 653 +---
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 594 +---
.../store/disk/schemafile/AliasIndexPage.java | 2 +-
.../mtree/store/disk/schemafile/InternalPage.java | 2 +-
.../store/disk/schemafile/MockSchemaFile.java | 1 -
.../mtree/store/disk/schemafile/RecordUtils.java | 16 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 51 +-
.../store/disk/schemafile/WrappedSegment.java | 2 +-
.../disk/schemafile/pagemgr/IPageManager.java | 5 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 28 +-
.../db/metadata/mtree/traverser/Traverser.java | 51 +-
.../mtree/traverser/collector/MNodeCollector.java | 18 -
.../mtree/traverser/counter/CounterTraverser.java | 4 +-
.../counter/MeasurementGroupByLevelCounter.java | 12 +-
.../plan/schemaregion/SchemaRegionPlanType.java | 6 +-
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 15 -
.../impl/ActivateTemplatePlanImpl.java | 44 -
.../impl/SchemaRegionPlanDeserializer.java | 44 +-
.../schemaregion/impl/SchemaRegionPlanFactory.java | 11 -
.../impl/SchemaRegionPlanSerializer.java | 49 -
.../impl/SchemaRegionPlanTxtSerializer.java | 29 -
.../schemaregion/impl/SetTemplatePlanImpl.java | 69 -
.../schemaregion/impl/UnsetTemplatePlanImpl.java | 69 -
.../schemaregion/write/IActivateTemplatePlan.java | 42 -
.../plan/schemaregion/write/ISetTemplatePlan.java | 45 -
.../schemaregion/write/IUnsetTemplatePlan.java | 45 -
.../rescon/SchemaStatisticsManagerMetrics.java | 4 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 80 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 299 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 307 +-
.../storagegroup/IStorageGroupSchemaManager.java | 7 +-
.../storagegroup/StorageGroupSchemaManager.java | 9 +-
.../db/metadata/template/TemplateLogReader.java | 46 -
.../db/metadata/template/TemplateLogWriter.java | 64 -
.../db/metadata/template/TemplateManager.java | 384 ---
.../db/metadata/upgrade/MetadataUpgrader.java | 437 ---
.../metadata/visitor/SchemaExecutionVisitor.java | 4 +-
.../apache/iotdb/db/mpp/common/SchemaRegion.java | 29 -
.../db/mpp/common/header/ColumnHeaderConstant.java | 14 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 4 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 4 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 4 +-
.../execution/executor/RegionWriteExecutor.java | 17 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 84 +-
.../operator/process/AbstractIntoOperator.java | 21 +-
.../operator/process/DeviceViewIntoOperator.java | 2 +-
.../operator/process/DeviceViewOperator.java | 16 +-
.../execution/operator/process/IntoOperator.java | 2 +-
.../operator/process/last/LastQueryOperator.java | 6 +-
.../operator/schema/CountMergeOperator.java | 18 +-
.../operator/schema/DevicesCountOperator.java | 4 +-
.../schema/LevelTimeSeriesCountOperator.java | 4 +-
.../operator/schema/NodePathsCountOperator.java | 2 +-
.../schema/NodePathsSchemaScanOperator.java | 3 +-
.../operator/schema/TimeSeriesCountOperator.java | 4 +-
.../operator/source/AlignedSeriesScanOperator.java | 114 +-
.../operator/source/SeriesScanOperator.java | 108 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 26 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 135 +-
.../plan/analyze/StandalonePartitionFetcher.java | 2 +-
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 7 -
.../db/mpp/plan/execution/QueryExecution.java | 2 +-
.../config/metadata/ShowFunctionsTask.java | 15 +-
.../memory/StatementMemorySourceVisitor.java | 21 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 669 ++--
.../db/mpp/plan/parser/StatementGenerator.java | 26 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 19 +-
.../planner/distribution/DistributionPlanner.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 111 +
.../plan/planner/distribution/SourceRewriter.java | 4 +-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 16 +-
.../write/CreateAlignedTimeSeriesNode.java | 6 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 5 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 6 +-
.../plan/node/metedata/write/MeasurementGroup.java | 6 +-
.../plan/node/write/InsertMultiTabletsNode.java | 2 +-
.../plan/planner/plan/node/write/InsertNode.java | 13 +-
.../planner/plan/node/write/InsertRowNode.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 6 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 22 +-
.../plan/statement/crud/LoadTsFileStatement.java | 12 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +
.../metadata/DeleteStorageGroupStatement.java | 18 +-
.../statement/metadata/ShowTriggersStatement.java | 6 -
.../rest/handler/RequestValidationHandler.java | 14 +-
.../rest/handler/StatementConstructionHandler.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 119 +-
.../db/qp/physical/sys/ActivateTemplatePlan.java | 4 +-
.../db/qp/physical/sys/AppendTemplatePlan.java | 2 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 8 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 6 +-
.../db/qp/physical/sys/CreateTemplatePlan.java | 7 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 6 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 3 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 3 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 3407 --------------------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 51 +-
.../control/clientsession/IClientSession.java | 2 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 65 +-
.../pool/RawQueryReadTaskPoolManagerMetrics.java | 8 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 29 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 4 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 12 +
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 1 +
.../org/apache/iotdb/db/service/RPCService.java | 8 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 4 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 14 +-
.../iotdb/db/service/metrics/FileMetrics.java | 30 +-
.../db/service/metrics/IoTDBInternalReporter.java | 164 +
.../iotdb/db/service/metrics/ProcessMetrics.java | 39 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 41 +-
.../metrics/recorder/CacheMetricsRecorder.java | 2 +-
.../recorder/CompactionMetricsRecorder.java | 8 +-
.../InternalServiceThriftHandlerMetrics.java | 7 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 4 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 27 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 64 +-
.../db/service/thrift/impl/TSServiceImpl.java | 136 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 31 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 12 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 4 +-
.../apache/iotdb/db/sync/pipedata/PipeData.java | 2 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 4 +-
.../load/DeletionLoader.java | 2 +-
.../sync/{receiver => pipedata}/load/ILoader.java | 2 +-
.../{receiver => pipedata}/load/TsFileLoader.java | 4 +-
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 16 +-
.../db/sync/transport/client/ISyncClient.java | 7 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 34 +-
.../db/sync/transport/client/SenderManager.java | 49 +-
.../sync/transport/client/SyncClientFactory.java | 34 +-
.../db/sync/transport/server/ReceiverManager.java | 101 +-
.../apache/iotdb/db/tools/schema/MLogParser.java | 2 +-
.../db/tools/schema/SchemaFileSketchTool.java | 5 +-
.../iotdb/db/tools/vis/TsFileExtractVisdata.java | 170 -
.../main/java/org/apache/iotdb/db/tools/vis/vis.m | 290 --
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 24 -
.../java/org/apache/iotdb/db/wal/WALManager.java | 16 +-
.../db/wal/allocation/FirstCreateStrategy.java | 2 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 18 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 +-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 2 +-
.../iotdb/db/metadata/SchemaAdvancedTest.java | 25 -
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 1285 +-------
.../org/apache/iotdb/db/metadata/TemplateTest.java | 307 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 149 -
.../db/metadata/idtable/LastQueryWithIDTable.java | 145 -
.../db/metadata/idtable/entry/SchemaEntryTest.java | 18 -
.../metadata/idtable/trigger_example/Counter.java | 97 -
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 19 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 75 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 86 +-
.../plan/SchemaRegionPlanCompatibilityTest.java | 55 -
.../schemaRegion/SchemaRegionBasicTest.java | 10 +-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 318 --
.../apache/iotdb/db/metric/MetricServiceTest.java | 77 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 88 +-
.../mpp/execution/exchange/SourceHandleTest.java | 70 +-
.../operator/DeviceMergeOperatorTest.java | 9 +
.../execution/operator/DeviceViewOperatorTest.java | 3 +
.../mpp/execution/operator/OperatorMemoryTest.java | 4 +-
.../operator/schema/CountMergeOperatorTest.java | 8 +-
.../operator/schema/SchemaCountOperatorTest.java | 10 +-
.../schedule/queue/L2PriorityQueueTest.java | 20 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 2 +-
.../mpp/plan/analyze/QueryTimePartitionTest.java | 532 +++
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 3 +
.../distribution/AggregationDistributionTest.java | 97 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 3 +
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 3 +
.../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 11 +-
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 66 +-
.../iotdb/db/qp/sql/IoTDBsqlVisitorTest.java | 99 -
.../iotdb/db/query/dataset/ListDataSetTest.java | 3 +
.../org/apache/iotdb/db/tools/MLogParserTest.java | 41 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 14 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 6 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 6 +-
.../db/wal/allocation/ElasticStrategyTest.java | 17 +-
.../db/wal/allocation/FirstCreateStrategyTest.java | 17 +-
.../db/wal/allocation/RoundRobinStrategyTest.java | 17 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 2 +-
.../datanode1conf/iotdb-datanode-metric.yml | 48 -
.../datanode1conf/iotdb-datanode.properties | 7 +
.../resources/datanode1conf/iotdb-rest.properties | 18 -
.../datanode2conf/iotdb-datanode-metric.yml | 48 -
.../datanode2conf/iotdb-datanode.properties | 7 +
.../resources/datanode2conf/iotdb-rest.properties | 18 -
.../datanode3conf/iotdb-datanode-metric.yml | 48 -
.../datanode3conf/iotdb-datanode.properties | 9 +-
.../resources/datanode3conf/iotdb-rest.properties | 18 -
...tdb-rest.properties => iotdb-common.properties} | 0
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 6 +-
.../java/org/apache/iotdb/session/Session.java | 15 +-
...tdb-rest.properties => iotdb-common.properties} | 0
site/src/main/.vuepress/config.js | 216 +-
thrift-commons/src/main/thrift/common.thrift | 1 +
.../src/main/thrift/confignode.thrift | 16 +-
.../pom.xml | 2 +-
.../src/main/thrift/iotconsensus.thrift | 6 +-
thrift/src/main/thrift/client.thrift | 11 +-
thrift/src/main/thrift/datanode.thrift | 11 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 2 +-
.../read/common/block/column/BinaryColumn.java | 9 -
.../read/common/block/column/BooleanColumn.java | 9 -
.../read/common/block/column/DoubleColumn.java | 9 -
.../read/common/block/column/FloatColumn.java | 9 -
.../tsfile/read/common/block/column/IntColumn.java | 9 -
.../read/common/block/column/LongColumn.java | 9 -
.../block/column/RunLengthEncodedColumn.java | 15 -
.../read/common/block/column/TimeColumn.java | 7 -
.../iotdb/tsfile/read/filter/GroupByFilter.java | 10 +
.../iotdb/tsfile/read/filter/TimeFilter.java | 84 +
.../iotdb/tsfile/read/filter/basic/Filter.java | 7 +
.../tsfile/read/filter/operator/AndFilter.java | 40 +
.../tsfile/read/filter/operator/NotFilter.java | 27 +
.../tsfile/read/filter/operator/OrFilter.java | 66 +
.../iotdb/udf/api/collector/PointCollector.java | 4 +-
737 files changed, 23049 insertions(+), 31855 deletions(-)
diff --cc server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AlignedSeriesScanOperator.java
index e22d7b1f65,f4b67be984..0cd49756cd
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AlignedSeriesScanOperator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AlignedSeriesScanOperator.java
@@@ -28,9 -33,8 +33,10 @@@ import org.apache.iotdb.tsfile.read.fil
import java.io.IOException;
import java.util.HashSet;
+ import java.util.concurrent.TimeUnit;
+import static org.apache.iotdb.db.mpp.statistics.QueryStatistics.ALIGNED_SERIES_SCAN_OPERATOR;
+
public class AlignedSeriesScanOperator implements DataSourceOperator {
private final OperatorContext operatorContext;
@@@ -72,53 -77,50 +79,58 @@@
@Override
public TsBlock next() {
- if (hasCachedTsBlock || hasNext()) {
- hasCachedTsBlock = false;
- TsBlock res = tsBlock;
- tsBlock = null;
- return res;
- TsBlock block = builder.build();
- builder.reset();
- return block;
++ long startTime = System.nanoTime();
++ try {
++ TsBlock block = builder.build();
++ builder.reset();
++ return block;
++ } finally {
++ operatorContext.addOperatorTime(ALIGNED_SERIES_SCAN_OPERATOR, System.nanoTime() - startTime);
+ }
- throw new IllegalStateException("no next batch");
}
@Override
public boolean hasNext() {
+ long startTime = System.nanoTime();
try {
- if (hasCachedTsBlock) {
- return true;
- }
- /*
- * consume page data firstly
- */
- if (readPageData()) {
- hasCachedTsBlock = true;
- return true;
- }
-
- /*
- * consume chunk data secondly
- */
- if (readChunkData()) {
- hasCachedTsBlock = true;
- return true;
- }
+ // start stopwatch
+ long maxRuntime = operatorContext.getMaxRunTime().roundTo(TimeUnit.NANOSECONDS);
+ long start = System.nanoTime();
+
+ // here use do-while to promise doing this at least once
+ do {
+ /*
+ * consume page data firstly
+ */
+ if (readPageData()) {
+ continue;
+ }
- /*
- * consume next file finally
- */
- while (seriesScanUtil.hasNextFile()) {
+ /*
+ * consume chunk data secondly
+ */
if (readChunkData()) {
- hasCachedTsBlock = true;
- return true;
+ continue;
}
- }
- return hasCachedTsBlock;
+
+ /*
+ * consume next file finally
+ */
+ if (readFileData()) {
+ continue;
+ }
+ break;
+
+ } while (System.nanoTime() - start < maxRuntime && !builder.isFull());
+
+ finished = builder.isEmpty();
+
+ return !finished;
} catch (IOException e) {
throw new RuntimeException("Error happened while scanning the file", e);
+ } finally {
+ operatorContext.addOperatorTime(ALIGNED_SERIES_SCAN_OPERATOR, System.nanoTime() - startTime);
}
}
diff --cc server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanOperator.java
index a993230378,308fcfcb13..f937c2a818
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanOperator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanOperator.java
@@@ -29,9 -34,8 +34,10 @@@ import org.apache.iotdb.tsfile.read.fil
import java.io.IOException;
import java.util.Set;
+ import java.util.concurrent.TimeUnit;
+import static org.apache.iotdb.db.mpp.statistics.QueryStatistics.SERIES_SCAN_OPERATOR;
+
public class SeriesScanOperator implements DataSourceOperator {
private final OperatorContext operatorContext;
@@@ -73,53 -78,50 +80,58 @@@
@Override
public TsBlock next() {
- if (hasCachedTsBlock || hasNext()) {
- hasCachedTsBlock = false;
- TsBlock res = tsBlock;
- tsBlock = null;
- return res;
- TsBlock block = builder.build();
- builder.reset();
- return block;
++ long startTime = System.nanoTime();
++ try {
++ TsBlock block = builder.build();
++ builder.reset();
++ return block;
++ } finally {
++ operatorContext.addOperatorTime(SERIES_SCAN_OPERATOR, System.nanoTime() - startTime);
+ }
- throw new IllegalStateException("no next batch");
}
@Override
public boolean hasNext() {
+ long startTime = System.nanoTime();
try {
- if (hasCachedTsBlock) {
- return true;
- }
- /*
- * consume page data firstly
- */
- if (readPageData()) {
- hasCachedTsBlock = true;
- return true;
- }
-
- /*
- * consume chunk data secondly
- */
- if (readChunkData()) {
- hasCachedTsBlock = true;
- return true;
- }
+ // start stopwatch
+ long maxRuntime = operatorContext.getMaxRunTime().roundTo(TimeUnit.NANOSECONDS);
+ long start = System.nanoTime();
+
+ // here use do-while to promise doing this at least once
+ do {
+ /*
+ * consume page data firstly
+ */
+ if (readPageData()) {
+ continue;
+ }
- /*
- * consume next file finally
- */
- while (seriesScanUtil.hasNextFile()) {
+ /*
+ * consume chunk data secondly
+ */
if (readChunkData()) {
- hasCachedTsBlock = true;
- return true;
+ continue;
}
- }
- return hasCachedTsBlock;
+
+ /*
+ * consume next file finally
+ */
+ if (readFileData()) {
+ continue;
+ }
+ break;
+
+ } while (System.nanoTime() - start < maxRuntime && !builder.isFull());
+
+ finished = builder.isEmpty();
+
+ return !finished;
} catch (IOException e) {
throw new RuntimeException("Error happened while scanning the file", e);
+ } finally {
+ operatorContext.addOperatorTime(SERIES_SCAN_OPERATOR, System.nanoTime() - startTime);
}
}
diff --cc server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
index 19c21ce307,0a8966c95c..fdcba680c6
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
@@@ -1117,14 -1131,53 +1141,58 @@@ public class AnalyzeVisitor extends Sta
.computeIfAbsent(schemaTree.getBelongedDatabase(devicePath), key -> new ArrayList<>())
.add(queryParam);
}
- return partitionFetcher.getDataPartition(sgNameToQueryParamsMap);
+
+ long startTime = System.nanoTime();
+ DataPartition dataPartition = partitionFetcher.getDataPartition(sgNameToQueryParamsMap);
+ QueryStatistics.getInstance()
+ .addCost(QueryStatistics.PARTITION_FETCHER, System.nanoTime() - startTime);
+ return dataPartition;
}
+ public static List<TTimePartitionSlot> getTimePartitionSlotList(Filter timeFilter) {
+ if (timeFilter == null) {
+ return Collections.emptyList();
+ }
+ List<TimeRange> timeRangeList = timeFilter.getTimeRanges();
+ if (timeRangeList.isEmpty()) {
+ return Collections.emptyList();
+ }
+ if (timeRangeList.get(0).getMin() == Long.MIN_VALUE
+ || timeRangeList.get(timeRangeList.size() - 1).getMax() == Long.MAX_VALUE) {
+ return Collections.emptyList();
+ }
+
+ List<TTimePartitionSlot> result = new ArrayList<>();
+ long startTime =
+ (timeRangeList.get(0).getMin() / TimePartitionUtils.timePartitionInterval)
+ * TimePartitionUtils.timePartitionInterval; // included
+ long endTime = startTime + TimePartitionUtils.timePartitionInterval; // excluded
+ TTimePartitionSlot timePartitionSlot =
+ TimePartitionUtils.getTimePartition(timeRangeList.get(0).getMin());
+ int index = 0, size = timeRangeList.size();
+ while (index < size) {
+ long curLeft = timeRangeList.get(index).getMin();
+ long curRight = timeRangeList.get(index).getMax();
+ if (curLeft >= endTime) {
+ result.add(timePartitionSlot);
+ // next init
+ endTime =
+ (curLeft / TimePartitionUtils.timePartitionInterval + 1)
+ * TimePartitionUtils.timePartitionInterval;
+ timePartitionSlot = TimePartitionUtils.getTimePartition(curLeft);
+ } else if (curRight >= endTime) {
+ result.add(timePartitionSlot);
+ // next init
+ timePartitionSlot = new TTimePartitionSlot(endTime);
+ endTime = endTime + TimePartitionUtils.timePartitionInterval;
+ } else {
+ index++;
+ }
+ }
+ result.add(timePartitionSlot);
+ return result;
+ }
+
private void analyzeInto(
Analysis analysis,
QueryStatement queryStatement,
[iotdb] 02/02: merge master
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch QueryMetrics
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6da84a5b0bd477aac91dc2a560feeeb8cd45113a
Merge: 7bf78f1a94 40de3ad14e
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Mon Nov 28 16:34:33 2022 +0800
merge master
.github/workflows/client-go.yml | 4 +-
.github/workflows/client-python.yml | 4 +-
.github/workflows/site-build.yml | 33 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 104 +-
.../confignode/conf/ConfigNodeDescriptor.java | 65 +-
.../confignode/conf/SystemPropertiesUtils.java | 6 +-
.../confignode/manager/ClusterSchemaManager.java | 14 +
.../iotdb/confignode/manager/ConfigManager.java | 44 +-
.../iotdb/confignode/manager/ConsensusManager.java | 21 +-
.../manager/load/balancer/RegionBalancer.java | 4 +-
.../manager/load/balancer/RouteBalancer.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../partition/DataRegionGroupExtensionPolicy.java | 36 +-
.../manager/partition/PartitionManager.java | 192 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 2 +-
.../procedure/env/DataNodeRemoveHandler.java | 15 +-
.../procedure/state/CreateRegionGroupsState.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 2 +-
consensus/pom.xml | 7 -
.../common/request/IndexedConsensusRequest.java | 2 +-
.../consensus/iot/wal/ConsensusReqReader.java | 4 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 4 +
docs/UserGuide/Cluster/Cluster-Concept.md | 2 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 68 +-
docs/UserGuide/FAQ/Frequently-asked-questions.md | 4 +
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 56 +-
docs/UserGuide/QuickStart/QuickStart.md | 49 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 281 +-
docs/UserGuide/Reference/Keywords.md | 7 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 2 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 59 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 5 +
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 74 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 38 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 304 +-
docs/zh/UserGuide/Reference/Keywords.md | 7 +-
...json => Apache IoTDB ConfigNode Dashboard.json} | 1440 ++++-
...0.json => Apache IoTDB DataNode Dashboard.json} | 2377 +++++--
.../standalone/Apache IoTDB Dashboard v0.14.0.json | 1519 -----
.../java/org/apache/iotdb/it/env/MppConfig.java | 25 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 26 +-
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 19 +-
.../it/partition/IoTDBPartitionDurableIT.java | 4 +-
.../it/partition/IoTDBPartitionGetterIT.java | 82 +-
.../it/partition/IoTDBRegionGroupExtensionIT.java | 156 +
.../resources/conf/iotdb-common.properties | 79 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 2 +-
.../assembly/resources/sbin/start-standalone.bat | 42 +
.../assembly/resources/sbin/start-standalone.sh | 43 +
.../assembly/resources/sbin/stop-standalone.bat | 40 +
.../src/assembly/resources/sbin/stop-standalone.sh | 40 +
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 8 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 16 +-
.../compaction/CompactionExceptionHandler.java | 6 +-
.../db/engine/compaction/CompactionUtils.java | 91 +-
.../constant/CrossCompactionPerformer.java | 11 +-
.../constant/InnerSeqCompactionPerformer.java | 11 +-
.../constant/InnerUnseqCompactionPerformer.java | 12 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 27 +-
.../RewriteCrossSpaceCompactionSelector.java | 13 +-
.../task/FastCompactionPerformerSubTask.java | 146 +
.../utils/AlignedSeriesCompactionExecutor.java | 339 +
.../cross/utils/ChunkMetadataElement.java | 56 +
.../compaction/cross/utils/FileElement.java} | 25 +-
.../utils/NonAlignedSeriesCompactionExecutor.java | 208 +
.../engine/compaction/cross/utils/PageElement.java | 101 +
.../compaction/cross/utils/PointElement.java | 50 +
.../cross/utils/SeriesCompactionExecutor.java | 591 ++
.../compaction/inner/InnerSpaceCompactionTask.java | 23 +-
.../inner/utils/MultiTsFileDeviceIterator.java | 110 +-
.../compaction/performer/ICompactionPerformer.java | 8 +-
.../performer/impl/FastCompactionPerformer.java | 294 +
.../impl/ReadPointCompactionPerformer.java | 93 +-
.../compaction/reader/PointPriorityReader.java | 152 +
.../compaction/task/SubCompactionTaskSummary.java | 40 +
.../writer/AbstractCompactionWriter.java | 289 +-
.../writer/AbstractCrossCompactionWriter.java | 233 +
.../writer/AbstractInnerCompactionWriter.java | 108 +
.../writer/CrossSpaceCompactionWriter.java | 256 -
.../writer/FastCrossCompactionWriter.java | 203 +
.../writer/FastInnerCompactionWriter.java | 212 +
.../writer/InnerSpaceCompactionWriter.java | 140 -
.../writer/ReadPointCrossCompactionWriter.java | 94 +
.../writer/ReadPointInnerCompactionWriter.java | 79 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../db/engine/storagegroup/TsFileManager.java | 12 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 2 +-
.../execution/exchange/MPPDataExchangeManager.java | 8 +-
.../process/join/merge/MultiColumnMerger.java | 18 +-
.../operator/source/AlignedSeriesScanOperator.java | 15 +-
.../operator/source/SeriesScanOperator.java | 20 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 2 +-
.../db/mpp/plan/parser/StatementGenerator.java | 4 -
.../plan/planner/plan/node/write/InsertNode.java | 2 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 18 +-
.../iotdb/db/service/RegionMigrateService.java | 367 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 22 +-
.../db/tools/validate/TsFileValidationTool.java | 7 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 4 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 4 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 4 +-
.../engine/compaction/AbstractCompactionTest.java | 208 +-
.../compaction/CompactionTaskComparatorTest.java | 4 +-
.../compaction/CompactionTaskManagerTest.java | 74 +-
.../compaction/FastAlignedCrossCompactionTest.java | 6689 ++++++++++++++++++++
....java => FastCrossCompactionPerformerTest.java} | 4215 ++++--------
.../FastInnerCompactionPerformerTest.java | 1824 ++++++
.../FastNonAlignedCrossCompactionTest.java | 6655 +++++++++++++++++++
.../ReadPointCompactionPerformerTest.java | 929 ++-
.../cross/CrossSpaceCompactionValidationTest.java | 98 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 10 +-
...ava => FastCompactionPerformerAlignedTest.java} | 43 +-
...a => FastCompactionPerformerNoAlignedTest.java} | 64 +-
...> InnerSeqCompactionWithFastPerformerTest.java} | 99 +-
...erSeqCompactionWithReadChunkPerformerTest.java} | 14 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 26 +-
...InnerUnseqCompactionWithFastPerformerTest.java} | 17 +-
...UnseqCompactionWithReadPointPerformerTest.java} | 11 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 36 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 48 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 7 +-
.../SizeTieredCompactionRecoverTest.java | 48 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 33 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 26 +-
.../recover/SizeTieredCompactionRecoverTest.java | 38 +-
.../compaction/utils/TsFileGeneratorUtils.java | 257 +
.../db/engine/storagegroup/DataRegionTest.java | 7 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 16 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 48 +-
.../operator/AlignedSeriesScanOperatorTest.java | 191 +-
.../operator/DeviceMergeOperatorTest.java | 73 +-
.../execution/operator/DeviceViewOperatorTest.java | 18 +-
.../mpp/execution/operator/LimitOperatorTest.java | 42 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 90 +-
.../operator/RawDataAggregationOperatorTest.java | 41 +-
.../execution/operator/SeriesScanOperatorTest.java | 29 +-
.../execution/operator/TimeJoinOperatorTest.java | 115 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../datastructure/PrimitiveArrayManagerTest.java | 18 +-
site/src/main/.vuepress/config.js | 2 +
thrift-iot-consensus/pom.xml | 4 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../tsfile/common/constant/TsFileConstant.java | 3 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 15 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 69 +-
.../read/common/block/column/ColumnBuilder.java | 2 +
.../read/reader/chunk/AlignedChunkReader.java | 69 +
.../tsfile/read/reader/chunk/ChunkReader.java | 67 +
.../iotdb/tsfile/utils/TsFileGeneratorUtils.java | 8 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 36 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 26 +
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 12 +
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 8 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 24 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 36 +-
.../tsfile/common/block/NullColumnUnitTest.java | 30 -
.../iotdb/tsfile/read/common/ColumnTest.java | 152 +-
158 files changed, 26812 insertions(+), 7897 deletions(-)