You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/12/06 03:56:18 UTC
[iotdb] branch kubernetes_version updated (1961020186 -> c5e8a29884)
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch kubernetes_version
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1961020186 tmp saved
add 89268825f8 [IOTDB-4875][IOTDB-4918] Fix timeseries creation check bug (#7987)
add 09ab7fae87 Resolve some TODO in ITs (#7981)
add e46df71015 [IOTDB-4896] Fix error in closing a TsFileProcessor with an empty memtable (#7971)
add ba7814d6ac Rename storage_groups dir name to databases (#7990)
add 8d9a021da6 [IOTDB-3831] Fix TTL doesn't take effect in last query (#7988)
add 058ca73097 [IOTDB-4921]Add auth check to deactivate and unset and drop template (#7994)
add 4f65f89698 [IOTDB-4941] Prevent compatibility problems in PipeData (#7996)
add d3d50e49bf [IOTDB-4893] modify the data type check of IN operation (#7979)
add a46e565a5d [IOTDB-4704] Modified sync data node retry wait (#7982)
add 7f01748284 [IOTDB-4942] Only checkDirectory when start DataNode (#7999)
add 917c8cff42 [IOTDB-4901][IOTDB-4860] Fix concurrent auto create schema bug (#7993)
add 8b5d429ea7 [IOTDB-4900] Add check for URI when create Trigger/UDF (#8000)
add 37c2792ab8 [IOTDB-4823] Adjust maxRegionGroupCount failed because StorageGroup doesn't exist (#7984)
add b5d9068596 Bump jackson-databind from 2.10.5 to 2.13.4.1 (#7986)
add c0f5d6c0ff Remove more todo in IT (#7998)
add e7a4838e0d [IOTDB-4401] DataNode should not be stopped when any regions are migrated failed (#7997)
add 6d486c9fc9 Bump jackson-databind from 2.13.4 to 2.13.4.1 (#8005)
add f87401b793 [IOTDB-4943][IOTDB-4956] Check type of Class and add detailed message for StateWindowStrategy
add 76e3d015dc [IOTDB-4951] Response failure if drop non-existent pipe (#8008)
add 64eac68ab5 Clear useless code in SchemaFileSketchTool (#8014)
add ee49d420f3 [IOTDB-4498] Update StatusCode to the latest (#7985)
add 0615b672e6 [IOTDB-4950] Add TsFileResourceStatus DELETED
add b594531af6 [IOTDB-4948] Optimize out-of-ttl error message (#8013)
add 31e93324ea [IOTDB-4965] Fix ttl info lost in data region after datanode restarted (#8018)
add e03efc25bc [IOTDB-4414] On using the CLI with OpenID Connect Auth enabled on Server side fails (#8011)
add e1351fbbd6 [IOTDB-4934]Modify error message of use 'null' directly in SQL
add d548214fad use AutoScalingBufferWriteTransport (#8012)
add b84845de2d [IOTDB-4923] Enable metric module in default config (#7973)
add 92c6a57f21 [IOTDB-4954] remove enable_partition and time_partition_interval_for_storage (#8002)
add 32675729ef [IOTDB-4872][IOTDB-4962] Improve delete timeseries msg when using template (#8006)
add 9170255e07 [IOTDB-4939] Remove unsupported compression type (#8009)
add 958064f1bb [IOTDB-4946] Implement show timeseries with deadband process info (#8021)
add cd35746b28 [IOTDB-4955] Make DataPartition inherit policy configurable (#8017)
add 9cdab6e955 [IOTDB-4973] add a copy of time instead of calling getTimestamp
add 3d5eeae81e [IOTDB-4953] Fix some sync-tool document description errors (#8038)
add 313645047e [IOTDB-4975] Explain support last query
add 601169295c [IOTDB-4899] Fix error in loading anonymous class of UDF
add c99fee30c7 Add website compile CI and fix website compile error (#8042)
add e988e7228f [IOTDB-4771]BufferedPipeDataQueueTest.testOfferWhileTakingWithDiscontinuousSerialNumber fail (#8020)
add 176e637a1a [IOTDB-4498] Adjust error code (#8026)
add 3d310e5d4e [IOTDB-4957] Add check for create pipesink and optimize re-connection (#8019)
add 92c1b197a6 [IOTDB-4850] Disable first election feature
add 7bb3f4b2d4 [IOTDB-4668] Add Database name length constraint (#8037)
add c84c97ae96 [IOTDB-4974] Clarify the boundary of how to be in one group in SessionWindow and StateWindow
add 10d054e9b0 Fix multi timeseries creation split bug (#8043)
add 4a856bd5e0 [IOTDB-4969] Fix the distribution plan for AggregationQuery with align by device (#8024)
add 36d98436be Fix some bug about clear environment after testing (#8046)
add e3b89b3c5d Clean some usage of Java in CI workflows (#8052)
add 33dcf2fc14 Make select into error more user-friendly (#8027)
add 5a6b4081de [IOTDB-4959] Remove createPeer state when confignode restart (#8051)
add 9edc7ea31a [IOTDB-4809] Broadcast the RegionRouteMap to all DataNodes except the unknown ones (#8053)
add bf49535e88 [IOTDB-4815] Apply SchemaCache for explicit timeseries query
add b0384095cb [IOTDB-4863] Fix a bug in memory estimation in DeviceViewNode
add fa5a00b19d [IOTDB-3671] Make thread group of ProcedureExecutor warn (#8055)
add fd579587fb improve issue template (#8056)
add 748b8835f1 Remove trigger of old standalone version
add 0152d95887 [IOTDB-4915][IOTDB-4956] Fix ClassCastException and drop trigger when onDrop throws exception (#8045)
add 53bc567b3e [IOTDB-4967] Fix SlidingTimeWindow stops when encounter an empty window (#8033)
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 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)
add 7bc76e6d40 add html auto-rediect for M4 under-review paper temporarily (#8252)
add ca2d255485 add back the M4 doc temporarily (#8273)
add b9393ceacf start rel/1.0
add db62a30d6e Fix IT bug (#8216)
add 9f8f2372c4 enable IT workflow for rel/1.0 (#8222)
add 8d9e50395f [To rel/1.0] fix data inserted into incorrect data region (#8219)
add 89add7bae6 [To rel/1.0] [IOTDB-5067] Add check of URI scheme
add 2b822766b4 [To rel/1.0] Modified some documents (#8220)
add 61139d98f1 [To rel/1.0] [IOTDB-5068] Fix CompactionSchedulerTest (#8224)
add f95389f37a Disable integration-tests and testcontainer in mvn install (#8228)
add 6e2fe0723b [To rel/1.0] fix snapshot init warning (#8226)
add 352bf6a431 [To rel/1.0] [IOTDB-5074] Add storage group name and region id to the path of snapshot (#8231)
add eeaaef0071 [To rel/1.0] [IOTDB-4940] Optimize query fetch data partition process while containg unclosed time filter (#8230)
add e01d5ccab9 [To rel/1.0] [IOTDB-5067] Change error log in ConfigExecutin to warn level (#8227)
add 6b6c5d72c5 [To rel/1.0] Add logs for AdjustRegionGroupNum process (#8233)
add 50e969b07a [To rel/1.0] Simplify IoTDBCustomRegionGroupExtensionIT (#8232)
add b263e7c228 [To rel/1.0][IOTDB-5045] fix delete database, wal and tsfile still left (#8234)
add a2aa6aad39 [To rel/1.0] [IOTDB-4972] Fix NPE caused by timeseries not exists when disable auto create schema (#8235)
add 30acf2eae4 [To rel/1.0][IOTDB-5072] Fix UDF example and set some logs to warn level
add 5f262fbba4 [To rel/1.0] [IOTDB-5059] Remove redundant database check in SchemaEngine (#8236)
add 251c237f8d [To rel/1.0][IOTDB-5039] Add info when load tsfile error (#8243)
add cd757e559a [To rel/1.0][IOTDB-5039] Change load log error to warn (#8247)
add 6ed77dbd43 [To rel/1.0] [IOTDB-5070] Fix wrong isBlocked() method implementation in TagAggregationOperator
add 7b67bbe689 [To rel/1.0][IOTDB-5079] Update the doc of dashboard and fix some minor problem (#8248)
add a63b5d72f9 [To rel/1.0] Add CUSTOM policy for schema region group (#8246)
add fec7890df2 Change user or network error log to warn log (#8250)
add 80e97a4938 [To rel/1.0] Ratis disk usage control (#8202)
add c9b4613325 [To rel/1.0][Fix] Fix dataregion snapshot transfer in RatisConsensus (#8249)
add 45640ea308 Add v1.0 docs in website (#8255)
add da5744e383 [To rel/1.0] Disable cross space compaction in default config (#8256)
add 0d484793bc [To rel/1.0] add 1.0.0 release note (#8258)
add 6a878a313e disable tests (#8257)
add 27f9e971d9 Update client-py & jdbc version
add 88fe81cf06 disable integration tests
add d75b118eb4 disable integration tests
add b32a011694 disable integration tests
add dffb1d9470 [maven-release-plugin] prepare release v1.0.0
add a7a1738c1e [maven-release-plugin] prepare for next development iteration
add 8553d9e08d [To rel/1.0] [IOTDB-5047] Fix iotdb.jmx.port missing from data-env.sh (#8240)
add 06bc2c3d9c fix logs in compaction writer (#8262)
add 41ba0f2896 [To rel/1.0][IOTDB-5093]Fix compaction selector bug (#8267)
add 4f233bf3b8 [To rel/1.0][IOTDB-4730] Database name check when passed in Session (#8266)
add 4c77331807 set cross_compaction to true and add compaction validation (#8268)
add 701072af05 Revert "[maven-release-plugin] prepare for next development iteration"
add 88db5b214f Revert "[maven-release-plugin] prepare release v1.0.0"
add 4d0b3af94e [maven-release-plugin] prepare release v1.0.0
add 7a1415ecec [maven-release-plugin] prepare for next development iteration
add 7522b82520 [To rel/1.0] Enable tests after v1.0.0 released (#8272)
add c621ca87ed [To rel/1.0] [IOTDB-4414] Modify openId related documents and configuration files (#8270)
add 739bf205f4 [To rel/1.0] fix compaction ci (#8277)
add 942bedaca8 Revert "[To rel/1.0] Enable tests after v1.0.0 released (#8272)"
add 2cd5b43de1 Revert "[maven-release-plugin] prepare for next development iteration"
add d92e5fd9c1 Revert "[maven-release-plugin] prepare release v1.0.0"
add 3ed60f37a6 [maven-release-plugin] prepare release v1.0.0
add 7db3d5654a [maven-release-plugin] prepare for next development iteration
add 539b02732b [To rel/1.0] Enable tests after v1.0.0 released (#8283)
add d2d1142835 Merge branch 'rel/1.0' of https://github.com/apache/iotdb
add b411c1ef28 Fix site compile OOM (#8284)
add f21edc60f1 Add v1.0.x in site navigation bar (#8288)
add cdf7d6dab2 [To rel/1.0][IOTDB-4730] Add IT for DB name check passed in by Session (#8281)
add 1e3665193f [To rel/1.0] add IT for IoTDBCustomRegionGroupExtension (#8264)
add 84c01ae81c [To rel/1.0] [IOTDB-4433][IOTDB-4497] Add Cluster Maintenance doc (#8286)
add 1484436e2e fix (#8285)
add 59cc2f2932 [To rel/1.0][IOTDB-5105] Remove least_data_region_group_num check when register Non-Seed-ConfigNode (#8289)
add 7dfd121668 Revert "[To rel/1.0] Enable tests after v1.0.0 released (#8283)"
add 49baf307b7 Revert "[maven-release-plugin] prepare for next development iteration"
add 7e05e78d97 Revert "[maven-release-plugin] prepare release v1.0.0"
add 50d7863f17 update testcontainer version
add ea2fdef0c0 [maven-release-plugin] prepare release v1.0.0
add dc67933e98 [maven-release-plugin] prepare for next development iteration
add bc1e4ea189 Revert "Revert "[To rel/1.0] Enable tests after v1.0.0 released (#8283)""
add 77e9071692 Merge branch 'rel/1.0' of https://github.com/apache/iotdb
add 93e0209fa8 [To rel/1.0] Fix snapshot bug (#8294)
add 3f1d7d04e8 Revert "[To rel/1.0] Fix snapshot bug (#8294)" (#8295)
add 8b29938117 Add 1.0.0 download links (#8293)
add 8e262dc538 [To rel/1.0] Fix snapshot bug (#8296)
add cf9545b244 [To rel/1.0] add auth link in quick start doc (#8299)
add f9360c53a6 [To rel/1.0] [IOTDB-5109] Fix the load of role snapshot (#8302)
add ff953d36c3 add more logs for snapshot (#8298)
add 586c241967 Revert "Revert "Revert "[To rel/1.0] Enable tests after v1.0.0 released (#8283)"""
add a92372d92a Revert "[maven-release-plugin] prepare for next development iteration"
add 0b9275f8dc Revert "[maven-release-plugin] prepare release v1.0.0"
add fbbca3ffa3 [maven-release-plugin] prepare release v1.0.0
add 9f3600d165 [maven-release-plugin] prepare for next development iteration
add 774806fce3 update testcontainer version
add b140acb1a0 Revert "Revert "Revert "Revert "[To rel/1.0] Enable tests after v1.0.0 released (#8283)""""
add 1d06983a94 [To rel/1.0] Update doc on DataRegion using RatisConsensus (#8308)
add 759fcaa8f0 add confignode notice (#8309)
add ca7f58e16e [To rel/1.0] Add Deploy recommendation in docs (#8306)
add 8a443e8e70 Merge branch 'rel/1.0' of https://github.com/apache/iotdb
add 22457f5527 add ratis log doc (#8312)
add 393a8d673f fix cluster doc (#8314)
add 36b96fd078 Fix readme of start-server to start-standalone (#8316)
add 5510c79fbf Fix linux CI (#8310)
add c4b153d3de [IOTDB-5026] Improve last query on aligned timeseries
add fe3c779b8c [To rel/1.0] Rename StorageEngineV2 to StorageEngine (#8238)
add 985b1bb16d [IOTDB-5102] Support Align by deivce in VisitExplain (#8287)
add aabae384bf [IOTDB-5090] Add npe check in DataNode (#8328)
add e2e69bb730 Bump maven-bundle-plugin from 5.1.7 to 5.1.8 (#8276)
add 1d89d1ab60 Rename SeriesSlotId to SeriesSlotNum in show regions (#8326)
add dc69fee679 [IOTDB-4978] Fix deadLock caused by blocked operation in IntoOperator (#8269)
add 4f0b5751b3 [IOTDB-5066] Upgraded the GetSlots SQLs (#8333)
add ff5d9c04e9 Update Site,Add 'Edit this page on GitHub' (#8335)
add ac2ee40cfb [IOTDB-4902]Optimize process logic for aggregation when there is only one data region
add 9a72a2aa20 [IOTDB-5122] forward exception when Ratis request failed (#8338)
add 1384d892e3 Fix RatisConsensus Param errors related to LogPurgePreservation (#8340)
new c5e8a29884 Merge branch 'master' into kubernetes_version
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/ISSUE_TEMPLATE/bug_report.md | 31 -
.github/ISSUE_TEMPLATE/bug_report.yml | 85 +
.github/ISSUE_TEMPLATE/feature_request.md | 17 -
.github/ISSUE_TEMPLATE/feature_request.yml | 66 +
.github/workflows/client-cpp.yml | 11 +-
.github/workflows/client-go.yml | 12 +-
.github/workflows/client-python.yml | 12 +-
.github/workflows/cluster-it-1c1d.yml | 4 +
.github/workflows/cluster-it-1c3d.yml | 4 +
.github/workflows/e2e.yml | 2 +
.github/workflows/grafana-plugin.yml | 6 +
.github/workflows/influxdb-protocol.yml | 8 +-
.github/workflows/main-unix.yml | 4 +-
.github/workflows/main-win.yml | 2 +
.github/workflows/site-build.yml | 61 +
.github/workflows/sonar-coveralls.yml | 7 +-
.github/workflows/sync.yml | 2 +
Jenkinsfile | 8 +-
README.md | 16 +-
README_ZH.md | 14 +-
RELEASE_NOTES.md | 354 +-
antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 233 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 14 +-
cli/pom.xml | 2 +-
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 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 3 -
client-cpp/pom.xml | 6 +-
client-go | 2 +-
client-py/pom.xml | 2 +-
client-py/requirements_dev.txt | 2 +-
client-py/setup.py | 2 +-
client-py/tests/test_dataframe.py | 4 +
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 8 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 2 +-
confignode/src/assembly/confignode.xml | 4 -
.../src/assembly/resources/conf/confignode-env.bat | 2 +
.../src/assembly/resources/conf/confignode-env.sh | 2 +-
.../resources/conf/iotdb-confignode.properties | 60 +-
.../confignode/client/ConfigNodeRequestType.java | 2 +-
.../client/async/AsyncDataNodeClientPool.java | 13 +-
.../client/sync/SyncConfigNodeClientPool.java | 10 +-
.../client/sync/SyncDataNodeClientPool.java | 40 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 229 +-
.../confignode/conf/ConfigNodeDescriptor.java | 164 +-
.../confignode/conf/ConfigNodeRemoveCheck.java | 2 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 28 +-
.../confignode/conf/SystemPropertiesUtils.java | 6 +-
.../consensus/request/ConfigPhysicalPlan.java | 10 +-
.../consensus/request/ConfigPhysicalPlanType.java | 3 +-
.../read/partition/GetDataPartitionPlan.java | 34 +-
.../partition/GetOrCreateDataPartitionPlan.java | 5 +-
.../request/read/region/GetRegionIdPlan.java | 2 +-
.../write/region/CreateRegionGroupsPlan.java | 19 +
.../AdjustMaxRegionGroupCountPlan.java | 89 -
.../storagegroup/AdjustMaxRegionGroupNumPlan.java | 89 +
.../request/write/sync/RecordPipeMessagePlan.java | 65 +
.../consensus/response/DataNodeRegisterResp.java | 20 +
.../statemachine/ConfigNodeRegionStateMachine.java | 2 +-
.../exception/NoAvailableRegionGroupException.java | 36 +
.../NotAvailableRegionGroupException.java | 27 -
.../confignode/manager/ClusterSchemaManager.java | 179 +-
.../iotdb/confignode/manager/ConfigManager.java | 100 +-
.../iotdb/confignode/manager/ConsensusManager.java | 85 +-
.../apache/iotdb/confignode/manager/IManager.java | 12 +-
.../iotdb/confignode/manager/ProcedureManager.java | 4 +-
.../iotdb/confignode/manager/SyncManager.java | 20 +-
.../iotdb/confignode/manager/TriggerManager.java | 2 +-
.../iotdb/confignode/manager/load/LoadManager.java | 18 +-
.../manager/load/LoadManagerMetrics.java | 112 +-
.../manager/load/balancer/PartitionBalancer.java | 11 +-
.../manager/load/balancer/RegionBalancer.java | 84 +-
.../manager/load/balancer/RouteBalancer.java | 164 +-
.../partition/GreedyPartitionAllocator.java | 89 +-
.../balancer/partition/IPartitionAllocator.java | 11 +-
.../balancer/region/CopySetRegionAllocator.java | 159 -
.../region/CopySetRegionGroupAllocator.java | 160 +
.../balancer/region/GreedyRegionAllocator.java | 68 -
.../region/GreedyRegionGroupAllocator.java | 101 +
.../load/balancer/region/IRegionAllocator.java | 48 -
.../balancer/region/IRegionGroupAllocator.java | 46 +
.../manager/load/balancer/router/IRouter.java | 45 -
.../manager/load/balancer/router/LeaderRouter.java | 90 -
.../balancer/router/LoadScoreGreedyRouter.java | 78 -
.../load/balancer/router/RegionRouteMap.java | 5 +
.../router/leader/GreedyLeaderBalancer.java | 186 +
.../balancer/router/leader/ILeaderBalancer.java | 45 +
.../router/leader/MinCostFlowLeaderBalancer.java | 357 ++
.../manager/load/balancer/router/mcf/MCFEdge.java | 34 -
.../balancer/router/mcf/MCFLeaderBalancer.java | 305 -
.../router/priority/GreedyPriorityBalancer.java | 85 +
.../router/priority/IPriorityBalancer.java | 45 +
.../router/priority/LeaderPriorityBalancer.java | 67 +
.../iotdb/confignode/manager/node/NodeManager.java | 82 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 13 +
.../node/heartbeat/NodeHeartbeatSample.java | 21 +-
.../manager/partition/PartitionManager.java | 269 +-
.../partition/RegionGroupExtensionPolicy.java | 47 +
.../iotdb/confignode/persistence/AuthorInfo.java | 28 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 2 +-
.../persistence/executor/ConfigPlanExecutor.java | 23 +-
.../persistence/metric/NodeInfoMetrics.java | 95 -
.../persistence/metric/PartitionInfoMetrics.java | 30 +-
.../confignode/persistence/node/NodeInfo.java | 4 +-
.../persistence/partition/PartitionInfo.java | 24 +-
.../partition/StorageGroupPartitionTable.java | 10 +-
.../persistence/schema/ClusterSchemaInfo.java | 44 +-
.../persistence/sync/ClusterSyncInfo.java | 23 +-
.../confignode/procedure/ProcedureExecutor.java | 7 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 130 +-
.../procedure/env/DataNodeRemoveHandler.java | 78 +-
.../impl/node/AddConfigNodeProcedure.java | 38 +-
.../impl/node/RemoveDataNodeProcedure.java | 122 +-
.../impl/schema/DeactivateTemplateProcedure.java | 12 +-
.../impl/schema/DeleteStorageGroupProcedure.java | 5 +
.../impl/schema/DeleteTimeSeriesProcedure.java | 9 +-
.../impl/schema/UnsetTemplateProcedure.java | 4 +-
.../statemachine/CreateRegionGroupsProcedure.java | 13 +-
.../impl/statemachine/RegionMigrateProcedure.java | 7 +-
.../procedure/impl/sync/DropPipeProcedure.java | 10 +-
.../procedure/state/AddConfigNodeState.java | 3 +-
.../procedure/state/CreateRegionGroupsState.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 17 +-
.../confignode/service/ConfigNodeCommandLine.java | 3 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 6 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 33 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 35 +-
.../balancer/region/GreedyRegionAllocatorTest.java | 92 -
.../region/GreedyRegionGroupAllocatorTest.java | 140 +
.../load/balancer/router/LeaderRouterTest.java | 117 -
.../balancer/router/LoadScoreGreedyRouterTest.java | 110 -
.../router/leader/GreedyLeaderBalancerTest.java | 146 +
.../leader/LeaderBalancerComparisonTest.java | 369 ++
.../leader/MinCostFlowLeaderBalancerTest.java | 215 +
.../balancer/router/mcf/MCFLeaderBalancerTest.java | 216 -
.../router/priority/GreedyPriorityTest.java | 110 +
.../priority/LeaderPriorityBalancerTest.java | 167 +
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../persistence/ClusterSyncInfoTest.java | 40 +-
.../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 | 6 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 3 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 13 +-
.../org/apache/iotdb/consensus/common/Utils.java | 33 +
.../common/request/IndexedConsensusRequest.java | 29 +-
.../common/request/IoTConsensusRequest.java | 42 +
.../request/MultiLeaderConsensusRequest.java | 42 -
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 375 ++
.../iotdb/consensus/config/MultiLeaderConfig.java | 338 -
.../apache/iotdb/consensus/config/RatisConfig.java | 36 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 396 ++
.../consensus/iot/IoTConsensusServerImpl.java | 745 +++
.../consensus/iot/IoTConsensusServerMetrics.java | 88 +
.../iot/client/AsyncIoTConsensusServiceClient.java | 147 +
.../consensus/iot/client/DispatchLogHandler.java | 124 +
.../iot/client/IoTConsensusClientPool.java | 86 +
.../iot/client/SyncIoTConsensusServiceClient.java | 144 +
.../iot/logdispatcher/IndexController.java | 177 +
.../logdispatcher/IoTConsensusMemoryManager.java | 90 +
.../IoTConsensusMemoryManagerMetrics.java | 52 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 512 ++
.../logdispatcher/LogDispatcherThreadMetrics.java | 95 +
.../consensus/iot/logdispatcher/PendingBatch.java | 109 +
.../consensus/iot/logdispatcher/SyncStatus.java | 104 +
.../iot/service/IoTConsensusRPCService.java | 104 +
.../iot/service/IoTConsensusRPCServiceHandler.java | 51 +
.../iot/service/IoTConsensusRPCServiceMBean.java | 22 +
.../service/IoTConsensusRPCServiceProcessor.java | 320 +
.../consensus/iot/snapshot/SnapshotFragment.java | 81 +
.../iot/snapshot/SnapshotFragmentReader.java | 69 +
.../consensus/iot/wal/ConsensusReqReader.java | 85 +
.../iot/wal/GetConsensusReqReaderPlan.java | 33 +
.../multileader/MultiLeaderConsensus.java | 394 --
.../multileader/MultiLeaderServerImpl.java | 742 ---
.../multileader/MultiLeaderServerMetrics.java | 88 -
.../client/AsyncMultiLeaderServiceClient.java | 146 -
.../multileader/client/DispatchLogHandler.java | 124 -
.../client/MultiLeaderConsensusClientPool.java | 87 -
.../client/SyncMultiLeaderServiceClient.java | 144 -
.../multileader/logdispatcher/IndexController.java | 172 -
.../multileader/logdispatcher/LogDispatcher.java | 509 --
.../logdispatcher/LogDispatcherThreadMetrics.java | 95 -
.../logdispatcher/MultiLeaderMemoryManager.java | 86 -
.../MultiLeaderMemoryManagerMetrics.java | 52 -
.../multileader/logdispatcher/PendingBatch.java | 81 -
.../multileader/logdispatcher/SyncStatus.java | 91 -
.../multileader/service/MultiLeaderRPCService.java | 104 -
.../service/MultiLeaderRPCServiceHandler.java | 51 -
.../service/MultiLeaderRPCServiceMBean.java | 22 -
.../service/MultiLeaderRPCServiceProcessor.java | 336 -
.../multileader/snapshot/SnapshotFragment.java | 81 -
.../snapshot/SnapshotFragmentReader.java | 69 -
.../multileader/wal/ConsensusReqReader.java | 85 -
.../multileader/wal/GetConsensusReqReaderPlan.java | 33 -
.../ratis/ApplicationStateMachineProxy.java | 7 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 21 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 116 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 44 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 16 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 2 +-
.../iotdb/consensus/iot/IoTConsensusTest.java | 247 +
.../apache/iotdb/consensus/iot/RecoveryTest.java | 97 +
.../iot/logdispatcher/IndexControllerTest.java | 85 +
.../iot/logdispatcher/SyncStatusTest.java | 235 +
.../consensus/iot/util/FakeConsensusReqReader.java | 100 +
.../iotdb/consensus/iot/util/RequestSets.java | 55 +
.../apache/iotdb/consensus/iot/util/TestEntry.java | 78 +
.../iotdb/consensus/iot/util/TestStateMachine.java | 121 +
.../multileader/MultiLeaderConsensusTest.java | 247 -
.../iotdb/consensus/multileader/RecoveryTest.java | 97 -
.../logdispatcher/IndexControllerTest.java | 85 -
.../multileader/logdispatcher/SyncStatusTest.java | 226 -
.../multileader/util/FakeConsensusReqReader.java | 100 -
.../consensus/multileader/util/RequestSets.java | 55 -
.../consensus/multileader/util/TestEntry.java | 78 -
.../multileader/util/TestStateMachine.java | 121 -
.../iotdb/consensus/ratis/RatisConsensusTest.java | 39 +-
cross-tests/pom.xml | 2 +-
distribution/pom.xml | 4 +-
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/Download/README.md | 46 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 2 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 4 +-
docs/UserGuide/API/Programming-TsFile-API.md | 4 +-
docs/UserGuide/API/RestService.md | 60 +-
docs/UserGuide/API/Status-Codes.md | 109 -
.../Administration-Management/Administration.md | 12 +-
docs/UserGuide/Cluster/Cluster-Concept.md | 56 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 416 ++
docs/UserGuide/Cluster/Cluster-Setup.md | 302 +-
.../UserGuide/Cluster/Deployment-Recommendation.md | 181 +
docs/UserGuide/Data-Concept/Compression.md | 93 +-
.../Data-Concept/Data-Model-and-Terminology.md | 2 +
docs/UserGuide/Data-Concept/Deadband-Process.md | 113 +
docs/UserGuide/Data-Concept/Schema-Template.md | 15 +
docs/UserGuide/Data-Concept/Time-Partition.md | 15 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 4 +-
.../UserGuide/Ecosystem-Integration/Hive-TsFile.md | 8 +-
.../Ecosystem-Integration/MapReduce-TsFile.md | 2 +-
.../Ecosystem-Integration/Spark-TsFile.md | 2 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 56 +-
docs/UserGuide/FAQ/Frequently-asked-questions.md | 6 +-
.../{Write-Data => Maintenance-Tools}/CSV-Tool.md | 0
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
docs/UserGuide/Maintenance-Tools/Load-Tsfile.md | 111 +
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 6 +-
.../Maintenance-Tools/Maintenance-Command.md | 424 +-
docs/UserGuide/Maintenance-Tools/NodeTool.md | 297 -
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 6 +-
.../Maintenance-Tools/TsFile-Load-Export-Tool.md | 83 +
.../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 | 767 ++-
docs/UserGuide/Operate-Metadata/Database.md | 137 +
docs/UserGuide/Operate-Metadata/Storage-Group.md | 137 -
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 +
docs/UserGuide/Operators-Functions/Overview.md | 65 +
docs/UserGuide/Operators-Functions/Sample.md | 389 ++
docs/UserGuide/Operators-Functions/Selection.md | 51 +
.../Series-Discovery.md | 0
docs/UserGuide/Operators-Functions/String.md | 863 +++
docs/UserGuide/Operators-Functions/Time-Series.md | 70 +
.../Operators-Functions/User-Defined-Function.md | 606 ++
.../Operators-Functions/Variation-Trend.md | 54 +
docs/UserGuide/Process-Data/Select-Into.md | 338 -
docs/UserGuide/Process-Data/Triggers.md | 469 --
.../Process-Data/UDF-User-Defined-Function.md | 603 --
docs/UserGuide/Query-Data/Aggregate-Query.md | 723 ---
docs/UserGuide/Query-Data/Align-By.md | 57 +
.../Continuous-Query.md | 0
docs/UserGuide/Query-Data/Fill-Null-Value.md | 199 -
docs/UserGuide/Query-Data/Fill.md | 209 +
docs/UserGuide/Query-Data/Group-By.md | 585 ++
docs/UserGuide/Query-Data/Having-Condition.md | 115 +
docs/UserGuide/Query-Data/Last-Query.md | 16 +-
docs/UserGuide/Query-Data/Order-By.md | 24 +
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/Query-Filter.md | 194 -
docs/UserGuide/Query-Data/Result-Format.md | 82 -
docs/UserGuide/Query-Data/Select-Expression.md | 1080 +---
docs/UserGuide/Query-Data/Select-Into.md | 340 +
docs/UserGuide/Query-Data/Tracing-Tool.md | 48 -
docs/UserGuide/Query-Data/Where-Condition.md | 191 +
docs/UserGuide/Query-Data/Without-Null.md | 172 -
.../UserGuide/QuickStart/Command-Line-Interface.md | 54 +-
docs/UserGuide/QuickStart/Files.md | 92 +-
docs/UserGuide/QuickStart/QuickStart.md | 62 +-
docs/UserGuide/QuickStart/ServerFileList.md | 49 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 8 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 1988 ++++++
.../Reference/ConfigNode-Config-Manual.md | 257 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 1212 +---
docs/UserGuide/Reference/Keywords.md | 406 +-
docs/UserGuide/Reference/SQL-Reference.md | 14 +-
docs/UserGuide/Reference/Status-Codes.md | 164 +
docs/UserGuide/Reference/Syntax-Conventions.md | 591 --
.../Syntax-Conventions/Detailed-Grammar.md | 28 +
docs/UserGuide/Syntax-Conventions/Identifier.md | 141 +
docs/UserGuide/Syntax-Conventions/KeyValue-Pair.md | 119 +
.../Keywords-And-Reserved-Words.md | 26 +
.../UserGuide/Syntax-Conventions/Literal-Values.md | 157 +
.../Syntax-Conventions/NodeName-In-Path.md | 119 +
.../Syntax-Conventions/Session-And-TsFile-API.md | 119 +
docs/UserGuide/Trigger/Configuration-Parameters.md | 29 +
docs/UserGuide/Trigger/Implement-Trigger.md | 294 +
docs/UserGuide/Trigger/Instructions.md | 51 +
docs/UserGuide/Trigger/Notes.md | 30 +
docs/UserGuide/Trigger/Trigger-Management.md | 152 +
docs/UserGuide/UDF-Library/M4.md | 3 +-
docs/UserGuide/UDF-Library/Quick-Start.md | 41 -
docs/UserGuide/UDF-Library/Series-Processing.md | 70 -
docs/UserGuide/UDF-Library/String-Processing.md | 797 ---
docs/UserGuide/Write-Data/Batch-Load-Tool.md | 32 +
docs/UserGuide/Write-Data/Load-External-Tsfile.md | 94 -
docs/UserGuide/Write-Data/REST-API.md | 6 +-
docs/UserGuide/Write-Data/TsFile-Tool.md | 80 -
docs/zh/Download/README.md | 54 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 2 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 2 +-
.../UserGuide/API/Programming-Java-Native-API.md | 4 +-
docs/zh/UserGuide/API/Programming-TsFile-API.md | 4 +-
docs/zh/UserGuide/API/RestService.md | 78 +-
docs/zh/UserGuide/API/Status-Codes.md | 108 -
.../Administration-Management/Administration.md | 12 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 52 +-
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 415 ++
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 280 +-
.../UserGuide/Cluster/Deployment-Recommendation.md | 179 +
docs/zh/UserGuide/Data-Concept/Compression.md | 88 +-
.../Data-Concept/Data-Model-and-Terminology.md | 2 +
docs/zh/UserGuide/Data-Concept/Deadband-Process.md | 108 +
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 15 +
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 25 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 4 +-
.../UserGuide/Ecosystem-Integration/Hive-TsFile.md | 8 +-
.../Ecosystem-Integration/MapReduce-TsFile.md | 2 +-
.../Ecosystem-Integration/Spark-TsFile.md | 2 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 47 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 7 +-
docs/zh/UserGuide/Maintenance-Tools/CSV-Tool.md | 255 +
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
docs/zh/UserGuide/Maintenance-Tools/Load-Tsfile.md | 110 +
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 6 +-
.../Maintenance-Tools/Maintenance-Command.md | 403 +-
docs/zh/UserGuide/Maintenance-Tools/NodeTool.md | 293 -
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 8 +-
.../Maintenance-Tools/TsFile-Load-Export-Tool.md | 85 +
.../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 | 748 ++-
docs/zh/UserGuide/Operate-Metadata/Database.md | 136 +
.../zh/UserGuide/Operate-Metadata/Storage-Group.md | 136 -
docs/zh/UserGuide/Operate-Metadata/Template.md | 4 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 14 +-
.../UserGuide/Operators-Functions/Aggregation.md | 41 +
.../Operators-Functions/Anomaly-Detection.md | 531 ++
.../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 +
.../UserGuide/Operators-Functions/Data-Matching.md | 333 +
.../Operators-Functions/Data-Profiling.md | 1879 ++++++
.../UserGuide/Operators-Functions/Data-Quality.md | 579 ++
.../Operators-Functions/Data-Repairing.md | 408 ++
.../Operators-Functions/Frequency-Domain.md | 598 ++
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 +
.../Operators-Functions/Series-Discovery.md | 173 +
docs/zh/UserGuide/Operators-Functions/String.md | 856 +++
.../UserGuide/Operators-Functions/Time-Series.md | 69 +
.../Operators-Functions/User-Defined-Function.md | 540 ++
.../Operators-Functions/Variation-Trend.md | 54 +
docs/zh/UserGuide/Process-Data/Select-Into.md | 348 -
docs/zh/UserGuide/Process-Data/Triggers.md | 457 --
.../Process-Data/UDF-User-Defined-Function.md | 536 --
docs/zh/UserGuide/Query-Data/Aggregate-Query.md | 708 ---
docs/zh/UserGuide/Query-Data/Align-By.md | 61 +
.../Continuous-Query.md | 0
docs/zh/UserGuide/Query-Data/Fill-Null-Value.md | 193 -
docs/zh/UserGuide/Query-Data/Fill.md | 207 +
docs/zh/UserGuide/Query-Data/Group-By.md | 572 ++
docs/zh/UserGuide/Query-Data/Having-Condition.md | 115 +
docs/zh/UserGuide/Query-Data/Last-Query.md | 24 +-
docs/zh/UserGuide/Query-Data/Order-By.md | 24 +
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/Query-Filter.md | 188 -
docs/zh/UserGuide/Query-Data/Result-Format.md | 89 -
docs/zh/UserGuide/Query-Data/Select-Expression.md | 1166 +---
docs/zh/UserGuide/Query-Data/Select-Into.md | 350 +
docs/zh/UserGuide/Query-Data/Tracing-Tool.md | 48 -
docs/zh/UserGuide/Query-Data/Where-Condition.md | 185 +
docs/zh/UserGuide/Query-Data/Without-Null.md | 172 -
.../UserGuide/QuickStart/Command-Line-Interface.md | 39 +-
docs/zh/UserGuide/QuickStart/Files.md | 88 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 51 +-
docs/zh/UserGuide/QuickStart/ServerFileList.md | 46 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 2030 ++++++
.../Reference/ConfigNode-Config-Manual.md | 326 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 1800 +-----
docs/zh/UserGuide/Reference/Keywords.md | 406 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 14 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 164 +
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 590 --
.../Syntax-Conventions/Detailed-Grammar.md | 28 +
docs/zh/UserGuide/Syntax-Conventions/Identifier.md | 142 +
.../UserGuide/Syntax-Conventions/KeyValue-Pair.md | 119 +
.../Keywords-And-Reserved-Words.md | 26 +
.../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 | 29 +
docs/zh/UserGuide/Trigger/Implement-Trigger.md | 297 +
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/Anomaly-Detection.md | 531 --
docs/zh/UserGuide/UDF-Library/Data-Matching.md | 333 -
docs/zh/UserGuide/UDF-Library/Data-Profiling.md | 1879 ------
docs/zh/UserGuide/UDF-Library/Data-Quality.md | 579 --
docs/zh/UserGuide/UDF-Library/Data-Repairing.md | 408 --
docs/zh/UserGuide/UDF-Library/Frequency-Domain.md | 598 --
docs/zh/UserGuide/UDF-Library/M4.md | 26 -
docs/zh/UserGuide/UDF-Library/Quick-Start.md | 40 -
docs/zh/UserGuide/UDF-Library/Series-Discovery.md | 173 -
docs/zh/UserGuide/UDF-Library/Series-Processing.md | 69 -
docs/zh/UserGuide/UDF-Library/String-Processing.md | 786 ---
docs/zh/UserGuide/Write-Data/Batch-Load-Tool.md | 32 +
docs/zh/UserGuide/Write-Data/CSV-Tool.md | 255 -
.../UserGuide/Write-Data/Load-External-Tsfile.md | 93 -
docs/zh/UserGuide/Write-Data/REST-API.md | 6 +-
docs/zh/UserGuide/Write-Data/TsFile-Tool.md | 81 -
example/client-cpp-example/pom.xml | 4 +-
example/ext-pipe-plugin-example/README.md | 2 +-
example/ext-pipe-plugin-example/pom.xml | 4 +-
example/flink/pom.xml | 2 +-
.../org/apache/iotdb/flink/FlinkIoTDBSource.java | 2 +-
example/hadoop/pom.xml | 2 +-
example/influxdb-protocol-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 4 +-
example/kafka/readme.md | 4 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pom.xml | 2 +-
example/pulsar/pom.xml | 2 +-
example/rabbitmq/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/rocketmq/readme.md | 4 +-
example/session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 2 +-
.../iotdb/SyntaxConventionRelatedExample.java | 2 +-
example/trigger/pom.xml | 4 +-
example/tsfile/pom.xml | 2 +-
example/tsfile/readme.md | 2 +-
example/udf/pom.xml | 4 +-
.../SlidingTimeWindowAccessStrategyExample.java | 105 +
.../java/org/apache/iotdb/udf/UDTFExample.java | 4 +-
external-api/pom.xml | 2 +-
external-pipe-api/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana-connector/pom.xml | 4 +-
.../Apache IoTDB ConfigNode Dashboard.json | 2495 ++++++++
.../Apache IoTDB DataNode Dashboard.json | 4617 ++++++++++++++
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 1634 -----
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 3247 ----------
.../standalone/Apache IoTDB Dashboard v0.14.0.json | 1519 -----
grafana-plugin/go.sum | 2 +-
grafana-plugin/pkg/plugin/plugin.go | 8 +-
grafana-plugin/pom.xml | 10 +-
hadoop/README.md | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
influxdb-protocol/pom.xml | 2 +-
integration-test/import-control.xml | 2 -
integration-test/pom.xml | 6 +-
.../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 | 97 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 18 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 92 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 10 +
.../confignode/it/IoTDBClusterAuthorityIT.java | 2 +-
.../confignode/it/IoTDBClusterPartitionIT.java | 781 ---
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 105 +-
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 12 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 12 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 21 +-
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 3 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 199 +
.../IoTDBCustomRegionGroupExtensionIT.java | 193 +
.../it/partition/IoTDBPartitionDurableIT.java | 625 ++
.../it/partition/IoTDBPartitionGetterIT.java | 555 ++
.../partition/IoTDBPartitionInheritPolicyIT.java | 188 +
.../confignode/it/utils/ConfigNodeTestUtils.java | 72 +
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 12 +-
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 14 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 32 +-
.../org/apache/iotdb/db/it/IoTDBEncodingIT.java | 91 +-
.../apache/iotdb/db/it/IoTDBFilterBetweenIT.java | 3 +-
.../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 8 +-
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 98 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 7 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 23 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 262 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 48 +-
.../java/org/apache/iotdb/db/it/IoTDBTtlIT.java | 11 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 2 -
.../db/it/aggregation/IoTDBAggregationIT.java | 62 +-
.../it/aggregation/IoTDBAggregationOptimizeIT.java | 181 +
.../aggregation/IoTDBAggregationSmallDataIT.java | 21 -
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 75 +-
.../aligned/IoTDBAggregationWithDeletion2IT.java | 4 +-
.../it/aligned/IoTDBAggregationWithDeletionIT.java | 7 +-
.../db/it/aligned/IoTDBAlignedDataDeletionIT.java | 32 +-
.../db/it/aligned/IoTDBAlignedLastQuery2IT.java | 4 +-
.../db/it/aligned/IoTDBAlignedLastQuery3IT.java | 4 +-
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 4 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 89 -
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 39 +-
...GroupByQueryWithValueFilterWithDeletion2IT.java | 4 +-
...BGroupByQueryWithValueFilterWithDeletionIT.java | 4 +-
...upByQueryWithoutValueFilterWithDeletion2IT.java | 4 +-
...oupByQueryWithoutValueFilterWithDeletionIT.java | 4 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 6 +-
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 6 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 26 +-
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 8 +-
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 8 +-
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 4 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 4 +-
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 8 +-
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 8 +-
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 3 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 18 +-
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 3 +-
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 53 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 18 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 29 +-
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 6 +-
.../apache/iotdb/db/it/groupby/IoTDBHavingIT.java | 16 +-
.../iotdb/db/it/last/IoTDBLastWithTTLIT.java | 106 +
.../org/apache/iotdb/db/it/query/IoTDBInIT.java | 33 +-
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 3 +-
.../iotdb/db/it/query/IoTDBNullValueFillIT.java | 3 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 4 +
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 11 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 2 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 33 +-
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 13 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 78 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 30 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 7 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto3IT.java | 7 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 21 +-
.../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 7 +-
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 4 +-
.../db/it/trigger/IoTDBTriggerManagementIT.java | 50 +-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 28 +
.../db/it/udf/IoTDBUDFOtherWindowQueryIT.java | 84 +-
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 31 +
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 20 +
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 7 +-
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 1 -
.../apache/iotdb/db/it/utils/AlignedWriteUtil.java | 4 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 4 +-
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 15 +-
.../db/it/withoutNull/IoTDBWithoutAnyNullIT.java | 3 +-
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 3 +-
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 3 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 76 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 12 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 57 +-
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 1324 -> 1397 bytes
integration/pom.xml | 8 +-
.../iotdb/integration/env/ClusterEnvConfig.java | 8 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 4 -
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 19 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 3 +-
.../integration/IoTDBCompactionWithIDTableIT.java | 3 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 102 -
.../db/integration/IoTDBLoadExternalTsfileIT.java | 1032 ---
.../IoTDBLoadExternalTsfileWithVirtualSGIT.java | 137 -
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 3 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 36 +-
.../db/integration/IoTDBRemovePartitionIT.java | 2 -
.../db/integration/IoTDBRewriteTsFileToolIT.java | 59 +-
.../db/integration/IoTDBSchemaTemplateIT.java | 21 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 9 +-
.../iotdb/db/integration/IoTDBSnapshotIT.java | 285 -
.../iotdb/db/integration/IoTDBTimePartitionIT.java | 5 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 678 --
.../db/integration/IoTDBTriggerForwardIT.java | 305 -
.../db/integration/IoTDBTriggerManagementIT.java | 539 --
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 20 +-
.../aggregation/IoTDBUDFNestAggregationIT.java | 3 +-
.../IoTDBUserDefinedAggregationFunctionIT.java | 8 +-
.../aligned/IoTDBGroupByFillQueryBigDataIT.java | 3 +-
.../aligned/IoTDBGroupByFillQueryIT.java | 3 +-
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 2027 +++---
.../db/integration/env/StandaloneEnvConfig.java | 7 +-
.../db/integration/groupby/IoTDBGroupByFillIT.java | 2 +-
.../groupby/IoTDBGroupByFillMixPathsIT.java | 2 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../sync/IoTDBSyncReceiverLoaderIT.java | 6 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 2 +-
.../iotdb/db/integration/sync/MockSyncClient.java | 4 +-
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 30 +-
.../IoTDBDeletionVersionAdaptionIT.java | 3 +-
jdbc/README.md | 4 +-
jdbc/pom.xml | 4 +-
jdbc/src/main/feature/feature.xml | 4 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 4 +-
library-udf/pom.xml | 2 +-
metrics/ReadMe.md | 29 +-
metrics/dropwizard-metrics/pom.xml | 7 +-
.../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/reporter/PrometheusTextWriter.java | 79 -
.../dropwizard/type/DropwizardAutoGauge.java | 19 +-
.../type/DropwizardHistogramSnapshot.java | 7 -
.../org.apache.iotdb.metrics.reporter.JmxReporter | 18 +
.../org.apache.iotdb.metrics.reporter.Reporter | 20 -
metrics/interface/pom.xml | 13 +-
.../resources/conf/iotdb-confignode-metric.yml | 51 -
.../resources/conf/iotdb-datanode-metric.yml | 51 -
.../iotdb/metrics/AbstractMetricManager.java | 201 +-
.../iotdb/metrics/AbstractMetricService.java | 231 +-
.../apache/iotdb/metrics/CompositeReporter.java | 91 +
.../iotdb/metrics/DoNothingMetricService.java | 8 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 255 +-
.../metrics/config/MetricConfigDescriptor.java | 221 +-
.../iotdb/metrics/config/MetricConstant.java | 37 -
.../apache/iotdb/metrics/config/ReloadLevel.java | 6 +-
.../iotdb/metrics/impl/DoNothingAutoGauge.java | 29 +
.../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 | 22 +
.../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 +-
.../iotdb/metrics/reporter/CompositeReporter.java | 96 -
.../apache/iotdb/metrics/reporter/JmxReporter.java | 27 +
.../apache/iotdb/metrics/reporter/Reporter.java | 10 +-
.../reporter/iotdb/InternalIoTDBReporter.java | 67 +
.../metrics/reporter/iotdb/IoTDBReporter.java | 103 +
.../iotdb/MemoryInternalIoTDBReporter.java | 57 +
.../reporter/iotdb/SessionIoTDBReporter.java | 175 +
.../reporter/prometheus/PrometheusReporter.java | 222 +
.../reporter/prometheus/PrometheusTextWriter.java | 81 +
.../org/apache/iotdb/metrics/type/AutoGauge.java | 32 +
.../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 +-
.../iotdb/metrics/utils/InternalReporterType.java | 30 +
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 74 +-
.../iotdb/metrics/utils/MetricFrameType.java | 30 +
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 18 +-
.../org/apache/iotdb/metrics/utils/MetricType.java | 1 +
.../apache/iotdb/metrics/utils/MonitorType.java | 30 -
.../apache/iotdb/metrics/utils/OutPutFormat.java | 30 -
.../iotdb/metrics/config/MetricConfigTest.java | 86 +-
.../interface/src/test/resources/iotdb-metric.yml | 52 -
metrics/micrometer-metrics/pom.xml | 4 +-
.../micrometer/MicrometerMetricManager.java | 6 +-
.../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 | 18 +
.../org.apache.iotdb.metrics.reporter.Reporter | 20 -
metrics/pom.xml | 2 +-
node-commons/pom.xml | 2 +-
.../resources/conf/iotdb-common.properties | 394 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 2 +-
.../assembly/resources/sbin/start-standalone.bat | 45 +
.../assembly/resources/sbin/start-standalone.sh | 43 +
.../assembly/resources/sbin/stop-standalone.bat | 43 +
.../src/assembly/resources/sbin/stop-standalone.sh | 40 +
.../commons/auth/authorizer/OpenIdAuthorizer.java | 41 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 4 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 13 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 23 +-
.../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 | 28 +-
.../commons/exception/ConfigurationException.java | 6 +-
.../commons/exception/IllegalPathException.java | 4 +-
.../commons/exception/sync/PipeSinkException.java | 4 +-
.../exception/sync/SyncConnectionException.java | 39 +
.../exception/sync/SyncHandshakeException.java | 26 +
.../iotdb/commons/partition/DataPartition.java | 21 +-
.../commons/partition/DataPartitionQueryParam.java | 41 +
.../commons/partition/DataPartitionTable.java | 29 +-
.../iotdb/commons/partition/SchemaPartition.java | 3 +-
.../commons/partition/SchemaPartitionTable.java | 6 +-
.../commons/partition/SeriesPartitionTable.java | 46 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 18 +
.../org/apache/iotdb/commons/path/PartialPath.java | 3 +
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../iotdb/commons/service/StartupChecks.java | 44 +-
.../commons/service/metric/MetricService.java | 105 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +-
.../iotdb/commons/sync/metadata/SyncMetadata.java | 5 +-
.../iotdb/commons/sync/pipe/PipeMessage.java | 54 +-
.../iotdb/commons/sync/pipe/TsFilePipeInfo.java | 3 +-
.../iotdb/commons/sync/pipesink/IoTDBPipeSink.java | 29 +-
.../iotdb/commons/sync/pipesink/PipeSink.java | 5 -
.../commons/sync/transport/SyncIdentityInfo.java | 57 +
.../iotdb/commons/sync/utils/SyncConstant.java | 7 +-
.../iotdb/commons/sync/utils/SyncPathUtil.java | 17 +-
.../apache/iotdb/commons/trigger/TriggerTable.java | 4 +-
.../org/apache/iotdb/commons/udf/UDFTable.java | 2 +-
.../commons/udf/service/UDFManagementService.java | 27 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 17 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 39 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 155 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 20 +
.../commons/sync/metedata/SyncMetadataTest.java | 4 +-
openapi/pom.xml | 2 +-
openapi/src/main/openapi3/iotdb-rest.yaml | 17 +-
pom.xml | 21 +-
rewrite-tsfile-tool/pom.xml | 2 +-
schema-engine-rocksdb/pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 157 +-
.../schemaregion/rocksdb/mnode/REntityMNode.java | 16 -
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 32 -
.../schemaregion/rocksdb/mnode/RMNode.java | 20 -
.../rocksdb/mnode/RMeasurementMNode.java | 43 -
.../rocksdb/mnode/RStorageGroupMNode.java | 8 -
schema-engine-tag/README.md | 4 +-
schema-engine-tag/pom.xml | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 87 +-
.../utils/ShowTimeSeriesResultUtils.java | 12 +-
server/pom.xml | 2 +-
.../src/assembly/resources/conf/datanode-env.bat | 4 +-
server/src/assembly/resources/conf/datanode-env.sh | 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 | 13 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 56 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 5 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 181 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 6 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 169 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 111 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 32 +-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 16 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 2 +
.../consensus/statemachine/BaseStateMachine.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 32 +-
.../statemachine/visitor/DataExecutionVisitor.java | 42 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 777 ++-
.../apache/iotdb/db/engine/StorageEngineV2.java | 816 ---
.../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 | 129 +-
.../constant/CrossCompactionPerformer.java | 11 +-
.../constant/InnerSeqCompactionPerformer.java | 11 +-
.../constant/InnerUnseqCompactionPerformer.java | 12 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 58 +-
.../rewrite/CrossSpaceCompactionResource.java | 13 +-
.../RewriteCrossSpaceCompactionSelector.java | 18 +-
.../task/FastCompactionPerformerSubTask.java | 146 +
.../utils/AlignedSeriesCompactionExecutor.java | 339 +
.../cross/utils/ChunkMetadataElement.java | 56 +
.../engine/compaction/cross/utils/FileElement.java | 31 +
.../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 | 43 +-
.../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/load/AlignedChunkData.java | 6 +-
.../iotdb/db/engine/load/NonAlignedChunkData.java | 4 +-
.../iotdb/db/engine/load/TsFileSplitter.java | 22 +-
.../db/engine/querycontext/QueryDataSource.java | 5 +
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 14 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 21 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 153 +-
.../db/engine/storagegroup/DataRegionMetrics.java | 8 +-
.../engine/storagegroup/HashLastFlushTimeMap.java | 3 +-
.../storagegroup/IDTableLastFlushTimeMap.java | 3 +-
.../db/engine/storagegroup/ILastFlushTimeMap.java | 2 +-
.../engine/storagegroup/TimePartitionManager.java | 4 +-
.../db/engine/storagegroup/TsFileManager.java | 12 +-
.../db/engine/storagegroup/TsFileProcessor.java | 224 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 4 +-
.../db/engine/storagegroup/TsFileResource.java | 4 +-
.../db/engine/storagegroup/TsFileResourceList.java | 4 +-
.../engine/storagegroup/TsFileResourceStatus.java | 3 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 9 +-
.../storagegroup/timeindex/FileTimeIndex.java | 6 +-
.../db/engine/trigger/builtin/ForwardTrigger.java | 2 +-
.../db/engine/trigger/executor/TriggerEngine.java | 64 -
.../db/engine/trigger/executor/TriggerEvent.java | 53 -
.../engine/trigger/executor/TriggerExecutor.java | 250 -
.../trigger/service/TriggerClassLoaderManager.java | 95 -
.../engine/trigger/service/TriggerLogReader.java | 48 -
.../engine/trigger/service/TriggerLogWriter.java | 68 -
.../service/TriggerRegistrationInformation.java | 82 -
.../service/TriggerRegistrationService.java | 505 --
.../db/exception/ContinuousQueryException.java | 36 -
.../iotdb/db/exception/DataRegionException.java | 4 +-
.../exception/DiskSpaceInsufficientException.java | 2 +-
.../apache/iotdb/db/exception/MergeException.java | 2 +-
.../db/exception/QueryIdNotExsitException.java | 29 -
.../exception/StorageEngineReadonlyException.java | 2 +-
.../db/exception/SyncConnectionException.java | 39 -
.../iotdb/db/exception/SystemCheckException.java | 34 -
.../db/exception/TriggerExecutionException.java | 32 -
.../db/exception/TriggerManagementException.java | 32 -
.../index/UnsupportedIndexTypeException.java | 32 -
.../metadata/AliasAlreadyExistException.java | 2 +-
.../exception/metadata/DeleteFailedException.java | 40 -
.../metadata/MeasurementAlreadyExistException.java | 2 +-
.../metadata/MeasurementInBlackListException.java | 2 +-
.../metadata/PathAlreadyExistException.java | 2 +-
.../exception/metadata/PathNotExistException.java | 24 +-
.../metadata/StorageGroupAlreadySetException.java | 4 +-
.../metadata/StorageGroupNotSetException.java | 4 +-
.../schemafile/ColossalRecordException.java | 6 +-
.../SchemaFileLogCorruptedException.java | 2 +-
.../template/NoTemplateOnMNodeException.java | 2 +-
.../template/TemplateImcompatibeException.java | 4 +-
.../db/exception/query/OutOfTTLException.java | 8 +-
.../iotdb/db/exception/query/PathException.java | 38 -
.../query/UnSupportedFillTypeException.java | 2 +-
.../apache/iotdb/db/index/common/IndexType.java | 10 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 258 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 550 +-
.../metadata/cache/DataNodeLastCacheManager.java | 2 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 47 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 4 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 16 +-
.../lastCache/container/ILastCacheContainer.java | 45 +
.../lastCache/container/LastCacheContainer.java | 70 +
.../lastCache/container/value/ILastCacheValue.java | 35 +
.../lastCache/container/value/LastCacheValue.java | 55 +
.../apache/iotdb/db/metadata/idtable/IDTable.java | 45 -
.../db/metadata/idtable/IDTableHashmapImpl.java | 65 -
.../iotdb/db/metadata/idtable/IDTableManager.java | 2 +-
.../idtable/entry/InsertMeasurementMNode.java | 68 -
.../db/metadata/idtable/entry/SchemaEntry.java | 82 +-
.../db/metadata/lastCache/LastCacheManager.java | 255 -
.../lastCache/container/ILastCacheContainer.java | 45 -
.../lastCache/container/LastCacheContainer.java | 70 -
.../lastCache/container/value/ILastCacheValue.java | 35 -
.../lastCache/container/value/LastCacheValue.java | 55 -
.../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 | 19 -
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 10 -
.../iotdb/db/metadata/mnode/InternalMNode.java | 56 -
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 29 -
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 67 -
.../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 | 697 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 638 +-
.../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 +-
.../metadata/schemaregion/RSchemaRegionLoader.java | 14 +-
.../db/metadata/schemaregion/SchemaEngine.java | 48 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 342 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 346 +-
.../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 --
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 22 +
.../metadata/visitor/SchemaExecutionVisitor.java | 4 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 20 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 28 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 27 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 21 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 1 +
.../db/mpp/aggregation/MinValueAccumulator.java | 21 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 1 +
.../apache/iotdb/db/mpp/common/SchemaRegion.java | 29 -
.../db/mpp/common/header/ColumnHeaderConstant.java | 32 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 23 +-
.../common/schematree/DeviceGroupSchemaTree.java | 7 +-
.../db/mpp/common/schematree/ISchemaTree.java | 7 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 9 +
.../iotdb/db/mpp/execution/driver/DataDriver.java | 6 +-
.../db/mpp/execution/exchange/ISourceHandle.java | 8 +
.../db/mpp/execution/exchange/LocalSinkHandle.java | 9 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 21 +
.../execution/exchange/MPPDataExchangeManager.java | 20 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 6 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 6 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 23 +-
.../db/mpp/execution/exchange/SinkHandle.java | 6 +-
.../db/mpp/execution/exchange/SourceHandle.java | 9 +-
.../execution/executor/RegionWriteExecutor.java | 57 +-
.../fragment/FragmentInstanceContext.java | 30 +-
.../fragment/FragmentInstanceManager.java | 21 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 84 +-
.../operator/process/AbstractIntoOperator.java | 199 +-
.../operator/process/DeviceViewIntoOperator.java | 105 +-
.../operator/process/DeviceViewOperator.java | 22 +-
.../execution/operator/process/IntoOperator.java | 48 +-
.../operator/process/TagAggregationOperator.java | 41 +-
.../process/join/VerticallyConcatOperator.java | 207 +
.../process/join/merge/MultiColumnMerger.java | 18 +-
.../last/AbstractUpdateLastCacheOperator.java | 112 +
.../last/AlignedUpdateLastCacheOperator.java | 89 +
.../operator/process/last/LastQueryOperator.java | 12 +-
.../process/last/LastQuerySortOperator.java | 11 +-
.../operator/process/last/LastQueryUtil.java | 18 +
.../process/last/UpdateLastCacheOperator.java | 73 +-
.../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 +-
.../schema/TimeSeriesSchemaScanOperator.java | 2 +
.../operator/source/AlignedSeriesScanOperator.java | 121 +-
.../operator/source/SeriesScanOperator.java | 118 +-
.../execution/schedule/AbstractDriverThread.java | 4 +-
.../schedule/FragmentInstanceAbortedException.java | 2 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 26 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 252 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 93 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 170 +-
.../db/mpp/plan/analyze/IPartitionFetcher.java | 9 +
.../plan/analyze/StandalonePartitionFetcher.java | 13 +-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 2 +-
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 7 -
.../db/mpp/plan/analyze/cache/PartitionCache.java | 2 +-
.../db/mpp/plan/execution/QueryExecution.java | 65 +-
.../mpp/plan/execution/config/ConfigExecution.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 212 +-
.../executor/StandaloneConfigTaskExecutor.java | 2 +-
.../config/metadata/GetTimeSlotListTask.java | 7 +-
.../config/metadata/ShowFunctionsTask.java | 15 +-
.../plan/execution/memory/MemorySourceHandle.java | 5 +
.../memory/StatementMemorySourceVisitor.java | 27 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 689 +-
.../db/mpp/plan/parser/StatementGenerator.java | 45 +-
.../plan/planner/LocalExecutionPlanContext.java | 18 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 5 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 20 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 191 +-
.../db/mpp/plan/planner/SubPlanTypeExtractor.java | 29 +
.../planner/distribution/DistributionPlanner.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 118 +
.../plan/planner/distribution/SourceRewriter.java | 293 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 57 +
.../db/mpp/plan/planner/plan/node/PlanNode.java | 16 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadSingleTsFileNode.java | 4 +-
.../write/CreateAlignedTimeSeriesNode.java | 6 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 5 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 6 +-
.../plan/node/metedata/write/MeasurementGroup.java | 60 +-
.../plan/node/process/VerticallyConcatNode.java | 103 +
.../plan/node/write/InsertMultiTabletsNode.java | 2 +-
.../plan/planner/plan/node/write/InsertNode.java | 45 +-
.../planner/plan/node/write/InsertRowNode.java | 6 +-
.../planner/plan/node/write/InsertRowsNode.java | 2 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 2 +-
.../planner/plan/node/write/InsertTabletNode.java | 28 +-
.../planner/plan/parameter/AggregationStep.java | 45 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 2 +-
.../scheduler/FixedRateFragInsStateTracker.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 26 +-
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 9 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 33 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 89 +-
.../crud/InsertMultiTabletsStatement.java | 2 +-
.../plan/statement/crud/InsertRowStatement.java | 4 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 3 +-
.../plan/statement/crud/InsertRowsStatement.java | 2 +-
.../mpp/plan/statement/crud/InsertStatement.java | 1 -
.../plan/statement/crud/InsertTabletStatement.java | 17 +-
.../plan/statement/crud/LoadTsFileStatement.java | 12 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +
.../metadata/DeleteStorageGroupStatement.java | 18 +-
.../statement/metadata/GetRegionIdStatement.java | 30 +-
.../statement/metadata/ShowTriggersStatement.java | 6 -
...izableRowRecordListBackedMultiColumnWindow.java | 12 +
...SerializableTVListBackedSingleColumnWindow.java | 12 +
.../dag/adapter/EmptyRowIterator.java | 40 +
.../dag/column/unary/InColumnTransformer.java | 40 +-
.../intermediate/ConstantIntermediateLayer.java | 3 +-
.../MultiInputColumnIntermediateLayer.java | 21 +-
...InputColumnMultiReferenceIntermediateLayer.java | 20 +-
...nputColumnSingleReferenceIntermediateLayer.java | 20 +-
.../transformation/dag/util/TransformUtils.java | 8 +-
.../influxdb/meta/NewInfluxDBMetaManager.java | 2 +-
.../protocol/rest/filter/AuthorizationFilter.java | 8 +-
.../rest/handler/AuthorizationHandler.java | 4 +-
.../rest/handler/RequestValidationHandler.java | 14 +-
.../rest/handler/StatementConstructionHandler.java | 2 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 6 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 6 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 126 +-
.../db/qp/logical/sys/CreateTriggerOperator.java | 92 -
.../db/qp/logical/sys/DropTriggerOperator.java | 50 -
.../db/qp/logical/sys/StartTriggerOperator.java | 50 -
.../db/qp/logical/sys/StopTriggerOperator.java | 50 -
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 16 -
.../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 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 166 -
.../iotdb/db/qp/physical/sys/DropTriggerPlan.java | 102 -
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 3 +-
.../iotdb/db/qp/physical/sys/StartTriggerPlan.java | 102 -
.../iotdb/db/qp/physical/sys/StopTriggerPlan.java | 102 -
.../db/qp/physical/sys/UnsetTemplatePlan.java | 3 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 3467 ----------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 51 +-
.../db/query/control/QueryResourceManager.java | 38 +-
.../iotdb/db/query/control/SessionManager.java | 4 +-
.../control/clientsession/IClientSession.java | 2 +-
.../db/query/dataset/ShowTimeSeriesResult.java | 17 +-
.../groupby/GroupByWithValueFilterDataSet.java | 88 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 106 +-
.../db/query/executor/AggregationExecutor.java | 124 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 69 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 115 +-
.../db/query/executor/RawDataQueryExecutor.java | 138 +-
.../pool/RawQueryReadTaskPoolManagerMetrics.java | 8 +-
.../query/timegenerator/ServerTimeGenerator.java | 28 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 18 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 62 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 6 +-
.../db/service/DataNodeServerCommandLine.java | 12 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 19 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 5 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 24 +-
.../org/apache/iotdb/db/service/RPCService.java | 8 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 6 +-
.../iotdb/db/service/RegionMigrateService.java | 384 +-
.../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 | 49 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 41 +-
.../metrics/recorder/CacheMetricsRecorder.java | 2 +-
.../recorder/CompactionMetricsRecorder.java | 8 +-
.../InternalServiceThriftHandlerMetrics.java | 9 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 6 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 37 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 139 +-
.../service/thrift/impl/DataNodeRegionManager.java | 6 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 2 +-
.../db/service/thrift/impl/TSServiceImpl.java | 142 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 31 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 12 +-
.../apache/iotdb/db/sync/common/LocalSyncInfo.java | 2 +-
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 2 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 6 +-
.../apache/iotdb/db/sync/pipedata/PipeData.java | 33 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 6 +-
.../db/sync/pipedata/load/DeletionLoader.java | 88 +
.../iotdb/db/sync/pipedata/load/ILoader.java | 49 +
.../iotdb/db/sync/pipedata/load/TsFileLoader.java | 85 +
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 3 +-
.../db/sync/receiver/load/DeletionLoader.java | 88 -
.../iotdb/db/sync/receiver/load/ILoader.java | 49 -
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 85 -
.../db/sync/sender/pipe/ExternalPipeSink.java | 20 -
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 23 +-
.../db/sync/transport/client/ISyncClient.java | 7 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 45 +-
.../db/sync/transport/client/SenderManager.java | 168 +-
.../sync/transport/client/SyncClientFactory.java | 41 +-
.../db/sync/transport/server/ReceiverManager.java | 109 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 10 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 10 +-
.../apache/iotdb/db/tools/schema/MLogParser.java | 2 +-
.../db/tools/schema/SchemaFileSketchTool.java | 12 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 6 +-
.../db/tools/validate/TsFileValidationTool.java | 7 +-
.../iotdb/db/tools/vis/TsFileExtractVisdata.java | 170 -
.../main/java/org/apache/iotdb/db/tools/vis/vis.m | 290 -
.../trigger/service/TriggerManagementService.java | 15 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 12 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 24 -
.../org/apache/iotdb/db/utils/ThreadUtils.java | 3 +-
.../apache/iotdb/db/utils/TimePartitionUtils.java | 16 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 20 +-
.../db/wal/allocation/FirstCreateStrategy.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 4 +-
.../iotdb/db/wal/exception/WALException.java | 6 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 26 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 +-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 2 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 4 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 4 +-
.../apache/iotdb/db/engine/StorageEngineTest.java | 71 +
.../iotdb/db/engine/StorageEngineV2Test.java | 71 -
.../engine/compaction/AbstractCompactionTest.java | 208 +-
.../engine/compaction/CompactionSchedulerTest.java | 1 -
.../compaction/CompactionTaskComparatorTest.java | 4 +-
.../compaction/CompactionTaskManagerTest.java | 74 +-
.../compaction/FastAlignedCrossCompactionTest.java | 6689 ++++++++++++++++++++
.../FastCrossCompactionPerformerTest.java | 3802 +++++++++++
.../FastInnerCompactionPerformerTest.java | 1824 ++++++
.../FastNonAlignedCrossCompactionTest.java | 6655 +++++++++++++++++++
.../ReadPointCompactionPerformerTest.java | 929 ++-
.../cross/CrossSpaceCompactionValidationTest.java | 143 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 10 +-
.../inner/FastCompactionPerformerAlignedTest.java | 652 ++
.../FastCompactionPerformerNoAlignedTest.java | 946 +++
.../compaction/inner/InnerSeqCompactionTest.java | 1061 ----
.../InnerSeqCompactionWithFastPerformerTest.java | 1088 ++++
...nerSeqCompactionWithReadChunkPerformerTest.java | 1055 +++
.../inner/InnerSpaceCompactionExceptionTest.java | 26 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 810 ---
.../InnerUnseqCompactionWithFastPerformerTest.java | 805 +++
...rUnseqCompactionWithReadPointPerformerTest.java | 807 +++
.../ReadChunkCompactionPerformerAlignedTest.java | 36 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 48 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 7 +-
.../SizeTieredCompactionRecoverTest.java | 48 +-
.../SizeTieredCompactionSelectorTest.java | 4 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 33 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 26 +-
.../recover/SizeTieredCompactionRecoverTest.java | 38 +-
.../compaction/utils/TsFileGeneratorUtils.java | 257 +
.../db/engine/snapshot/IoTDBSnapshotTest.java | 8 +-
.../db/engine/storagegroup/DataRegionTest.java | 122 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 19 +-
.../engine/storagegroup/TsFileProcessorTest.java | 482 ++
.../engine/storagegroup/TsFileProcessorV2Test.java | 482 --
.../iotdb/db/metadata/SchemaAdvancedTest.java | 25 -
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 1287 +---
.../org/apache/iotdb/db/metadata/TemplateTest.java | 307 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 7 +-
.../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 | 81 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 86 +-
.../plan/SchemaRegionPlanCompatibilityTest.java | 57 +-
.../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 | 20 +-
.../operator/RawDataAggregationOperatorTest.java | 41 +-
.../execution/operator/SeriesScanOperatorTest.java | 29 +-
.../execution/operator/TimeJoinOperatorTest.java | 115 +-
.../operator/VerticallyConcatOperatorTest.java | 197 +
.../operator/schema/CountMergeOperatorTest.java | 8 +-
.../operator/schema/SchemaCountOperatorTest.java | 10 +-
.../schema/SchemaQueryScanOperatorTest.java | 23 +-
.../schedule/DefaultDriverSchedulerTest.java | 3 +-
.../schedule/queue/L2PriorityQueueTest.java | 20 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 6 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 2 +-
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 6 +
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 2 +-
.../mpp/plan/analyze/QueryTimePartitionTest.java | 565 ++
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 3 +
.../distribution/AggregationDistributionTest.java | 288 +-
.../distribution/DistributionPlannerBasicTest.java | 126 +-
.../distribution/NoDataRegionPlanningTest.java | 37 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 498 +-
.../plan/node/write/WritePlanNodeSplitTest.java | 34 +-
.../plan/scheduler/StandaloneSchedulerTest.java | 6 +-
.../db/protocol/rest/IoTDBRestServiceTest.java | 4 +
.../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 +
.../db/query/dataset/ShowTimeSeriesResultTest.java | 4 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 475 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 41 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 14 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 380 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 12 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 45 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 18 +-
.../db/utils/datastructure/PrecisionTest.java | 143 -
.../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
service-rpc/pom.xml | 2 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 10 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 8 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 307 +-
session/pom.xml | 2 +-
.../java/org/apache/iotdb/session/Session.java | 15 +-
.../org/apache/iotdb/session/SessionDataSet.java | 2 +-
...tdb-rest.properties => iotdb-common.properties} | 0
site/pom.xml | 66 +-
site/src/main/.vuepress/config.js | 710 ++-
site/src/main/.vuepress/redirects | 3 +-
site/src/main/.vuepress/theme/components/Page.vue | 36 +-
site/src/main/package.json | 9 +-
spark-iotdb-connector/pom.xml | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 7 +-
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 7 +-
thrift-commons/pom.xml | 2 +-
thrift-commons/src/main/thrift/common.thrift | 1 +
thrift-confignode/pom.xml | 2 +-
.../src/main/thrift/confignode.thrift | 38 +-
thrift-influxdb/pom.xml | 2 +-
thrift-iot-consensus/pom.xml | 67 +
.../src/main/thrift/iotconsensus.thrift | 126 +
thrift-multi-leader-consensus/pom.xml | 67 -
.../src/main/thrift/mutlileader.thrift | 126 -
thrift/pom.xml | 2 +-
thrift/src/main/thrift/client.thrift | 11 +-
thrift/src/main/thrift/datanode.thrift | 11 +-
trigger-api/pom.xml | 2 +-
tsfile/README.md | 2 +-
tsfile/pom.xml | 2 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../tsfile/common/constant/TsFileConstant.java | 3 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 15 +-
.../file/metadata/enums/CompressionType.java | 21 +-
.../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 +-
udf-api/pom.xml | 2 +-
.../org/apache/iotdb/udf/api/access/RowWindow.java | 3 +-
.../iotdb/udf/api/collector/PointCollector.java | 2 +
.../strategy/SessionTimeWindowAccessStrategy.java | 10 +-
zeppelin-interpreter/pom.xml | 2 +-
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 14 +-
1433 files changed, 93050 insertions(+), 74144 deletions(-)
delete mode 100644 .github/ISSUE_TEMPLATE/bug_report.md
create mode 100644 .github/ISSUE_TEMPLATE/bug_report.yml
delete mode 100644 .github/ISSUE_TEMPLATE/feature_request.md
create mode 100644 .github/ISSUE_TEMPLATE/feature_request.yml
create mode 100644 .github/workflows/site-build.yml
create mode 100644 cli/src/assembly/resources/tools/load-tsfile.bat
create mode 100644 cli/src/assembly/resources/tools/load-tsfile.sh
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/AdjustMaxRegionGroupCountPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/AdjustMaxRegionGroupNumPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/RecordPipeMessagePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/exception/NoAvailableRegionGroupException.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/exception/NotAvailableRegionGroupException.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/CopySetRegionAllocator.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/CopySetRegionGroupAllocator.java
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
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/IRegionAllocator.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/IRegionGroupAllocator.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/IRouter.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LeaderRouter.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/LoadScoreGreedyRouter.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/GreedyLeaderBalancer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/ILeaderBalancer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/MinCostFlowLeaderBalancer.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFEdge.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFLeaderBalancer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/GreedyPriorityBalancer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/IPriorityBalancer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/LeaderPriorityBalancer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/RegionGroupExtensionPolicy.java
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
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/LeaderRouterTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/LoadScoreGreedyRouterTest.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
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/leader/MinCostFlowLeaderBalancerTest.java
delete mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFLeaderBalancerTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/GreedyPriorityTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/LeaderPriorityBalancerTest.java
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
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/request/IoTConsensusRequest.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/request/MultiLeaderConsensusRequest.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/config/IoTConsensusConfig.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/config/MultiLeaderConfig.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensus.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerImpl.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/IoTConsensusServerMetrics.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/client/AsyncIoTConsensusServiceClient.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/client/DispatchLogHandler.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/client/IoTConsensusClientPool.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/client/SyncIoTConsensusServiceClient.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/IndexController.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/IoTConsensusMemoryManager.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/IoTConsensusMemoryManagerMetrics.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcher.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/LogDispatcherThreadMetrics.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/PendingBatch.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/SyncStatus.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCService.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCServiceHandler.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCServiceMBean.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCServiceProcessor.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/snapshot/SnapshotFragment.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/snapshot/SnapshotFragmentReader.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/wal/ConsensusReqReader.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/iot/wal/GetConsensusReqReaderPlan.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensus.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerMetrics.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/AsyncMultiLeaderServiceClient.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/MultiLeaderConsensusClientPool.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/SyncMultiLeaderServiceClient.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/IndexController.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcherThreadMetrics.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/MultiLeaderMemoryManager.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/MultiLeaderMemoryManagerMetrics.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/PendingBatch.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/SyncStatus.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCService.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceHandler.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceMBean.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/snapshot/SnapshotFragment.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/snapshot/SnapshotFragmentReader.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/wal/ConsensusReqReader.java
delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/wal/GetConsensusReqReaderPlan.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/iot/IoTConsensusTest.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/iot/RecoveryTest.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/IndexControllerTest.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/iot/logdispatcher/SyncStatusTest.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/iot/util/FakeConsensusReqReader.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/iot/util/RequestSets.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/iot/util/TestEntry.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/iot/util/TestStateMachine.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensusTest.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/RecoveryTest.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/logdispatcher/IndexControllerTest.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/logdispatcher/SyncStatusTest.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/FakeConsensusReqReader.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/RequestSets.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestEntry.java
delete mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/multileader/util/TestStateMachine.java
delete mode 100644 docker/src/main/DockerCompose/GrafanaPlugin/iotdb/conf/iotdb-rest.properties
delete mode 100644 docs/UserGuide/API/Status-Codes.md
create mode 100644 docs/UserGuide/Cluster/Cluster-Maintenance.md
create mode 100644 docs/UserGuide/Cluster/Deployment-Recommendation.md
create mode 100644 docs/UserGuide/Data-Concept/Deadband-Process.md
rename docs/UserGuide/{Write-Data => Maintenance-Tools}/CSV-Tool.md (100%)
create mode 100644 docs/UserGuide/Maintenance-Tools/IoTDB-Data-Dir-Overview-Tool.md
create mode 100644 docs/UserGuide/Maintenance-Tools/Load-Tsfile.md
delete mode 100644 docs/UserGuide/Maintenance-Tools/NodeTool.md
delete mode 100644 docs/UserGuide/Maintenance-Tools/Rewrite-TsFile-Tool.md
create mode 100644 docs/UserGuide/Maintenance-Tools/TsFile-Load-Export-Tool.md
create mode 100644 docs/UserGuide/Maintenance-Tools/TsFile-Resource-Sketch-Tool.md
create mode 100644 docs/UserGuide/Maintenance-Tools/TsFile-Sketch-Tool.md
create mode 100644 docs/UserGuide/Operate-Metadata/Database.md
delete mode 100644 docs/UserGuide/Operate-Metadata/Storage-Group.md
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
create mode 100644 docs/UserGuide/Operators-Functions/Overview.md
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%)
create mode 100644 docs/UserGuide/Operators-Functions/String.md
create mode 100644 docs/UserGuide/Operators-Functions/Time-Series.md
create mode 100644 docs/UserGuide/Operators-Functions/User-Defined-Function.md
create mode 100644 docs/UserGuide/Operators-Functions/Variation-Trend.md
delete mode 100644 docs/UserGuide/Process-Data/Select-Into.md
delete mode 100644 docs/UserGuide/Process-Data/Triggers.md
delete mode 100644 docs/UserGuide/Process-Data/UDF-User-Defined-Function.md
delete mode 100644 docs/UserGuide/Query-Data/Aggregate-Query.md
create mode 100644 docs/UserGuide/Query-Data/Align-By.md
rename docs/UserGuide/{Process-Data => Query-Data}/Continuous-Query.md (100%)
delete mode 100644 docs/UserGuide/Query-Data/Fill-Null-Value.md
create mode 100644 docs/UserGuide/Query-Data/Fill.md
create mode 100644 docs/UserGuide/Query-Data/Group-By.md
create mode 100644 docs/UserGuide/Query-Data/Having-Condition.md
create mode 100644 docs/UserGuide/Query-Data/Order-By.md
delete mode 100644 docs/UserGuide/Query-Data/Performance-Tracing-Tool.md
delete mode 100644 docs/UserGuide/Query-Data/Query-Filter.md
delete mode 100644 docs/UserGuide/Query-Data/Result-Format.md
create mode 100644 docs/UserGuide/Query-Data/Select-Into.md
delete mode 100644 docs/UserGuide/Query-Data/Tracing-Tool.md
create mode 100644 docs/UserGuide/Query-Data/Where-Condition.md
delete mode 100644 docs/UserGuide/Query-Data/Without-Null.md
create mode 100644 docs/UserGuide/Reference/Common-Config-Manual.md
create mode 100644 docs/UserGuide/Reference/Status-Codes.md
delete mode 100644 docs/UserGuide/Reference/Syntax-Conventions.md
create mode 100644 docs/UserGuide/Syntax-Conventions/Detailed-Grammar.md
create mode 100644 docs/UserGuide/Syntax-Conventions/Identifier.md
create mode 100644 docs/UserGuide/Syntax-Conventions/KeyValue-Pair.md
create mode 100644 docs/UserGuide/Syntax-Conventions/Keywords-And-Reserved-Words.md
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
create mode 100644 docs/UserGuide/Trigger/Configuration-Parameters.md
create mode 100644 docs/UserGuide/Trigger/Implement-Trigger.md
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
delete mode 100644 docs/UserGuide/UDF-Library/Quick-Start.md
delete mode 100644 docs/UserGuide/UDF-Library/Series-Processing.md
delete mode 100644 docs/UserGuide/UDF-Library/String-Processing.md
create mode 100644 docs/UserGuide/Write-Data/Batch-Load-Tool.md
delete mode 100644 docs/UserGuide/Write-Data/Load-External-Tsfile.md
delete mode 100644 docs/UserGuide/Write-Data/TsFile-Tool.md
delete mode 100644 docs/zh/UserGuide/API/Status-Codes.md
create mode 100644 docs/zh/UserGuide/Cluster/Cluster-Maintenance.md
create mode 100644 docs/zh/UserGuide/Cluster/Deployment-Recommendation.md
create mode 100644 docs/zh/UserGuide/Data-Concept/Deadband-Process.md
create mode 100644 docs/zh/UserGuide/Maintenance-Tools/CSV-Tool.md
create mode 100644 docs/zh/UserGuide/Maintenance-Tools/IoTDB-Data-Dir-Overview-Tool.md
create mode 100644 docs/zh/UserGuide/Maintenance-Tools/Load-Tsfile.md
delete mode 100644 docs/zh/UserGuide/Maintenance-Tools/NodeTool.md
delete mode 100644 docs/zh/UserGuide/Maintenance-Tools/Rewrite-TsFile-Tool.md
create mode 100644 docs/zh/UserGuide/Maintenance-Tools/TsFile-Load-Export-Tool.md
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
create mode 100644 docs/zh/UserGuide/Operate-Metadata/Database.md
delete mode 100644 docs/zh/UserGuide/Operate-Metadata/Storage-Group.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Aggregation.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Anomaly-Detection.md
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
create mode 100644 docs/zh/UserGuide/Operators-Functions/Data-Matching.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Data-Profiling.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Data-Quality.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Data-Repairing.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Frequency-Domain.md
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
create mode 100644 docs/zh/UserGuide/Operators-Functions/Series-Discovery.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/String.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Time-Series.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/User-Defined-Function.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Variation-Trend.md
delete mode 100644 docs/zh/UserGuide/Process-Data/Select-Into.md
delete mode 100644 docs/zh/UserGuide/Process-Data/Triggers.md
delete mode 100644 docs/zh/UserGuide/Process-Data/UDF-User-Defined-Function.md
delete mode 100644 docs/zh/UserGuide/Query-Data/Aggregate-Query.md
create mode 100644 docs/zh/UserGuide/Query-Data/Align-By.md
rename docs/zh/UserGuide/{Process-Data => Query-Data}/Continuous-Query.md (100%)
delete mode 100644 docs/zh/UserGuide/Query-Data/Fill-Null-Value.md
create mode 100644 docs/zh/UserGuide/Query-Data/Fill.md
create mode 100644 docs/zh/UserGuide/Query-Data/Group-By.md
create mode 100644 docs/zh/UserGuide/Query-Data/Having-Condition.md
create mode 100644 docs/zh/UserGuide/Query-Data/Order-By.md
delete mode 100644 docs/zh/UserGuide/Query-Data/Performance-Tracing-Tool.md
delete mode 100644 docs/zh/UserGuide/Query-Data/Query-Filter.md
delete mode 100644 docs/zh/UserGuide/Query-Data/Result-Format.md
create mode 100644 docs/zh/UserGuide/Query-Data/Select-Into.md
delete mode 100644 docs/zh/UserGuide/Query-Data/Tracing-Tool.md
create mode 100644 docs/zh/UserGuide/Query-Data/Where-Condition.md
delete mode 100644 docs/zh/UserGuide/Query-Data/Without-Null.md
create mode 100644 docs/zh/UserGuide/Reference/Common-Config-Manual.md
create mode 100644 docs/zh/UserGuide/Reference/Status-Codes.md
delete mode 100644 docs/zh/UserGuide/Reference/Syntax-Conventions.md
create mode 100644 docs/zh/UserGuide/Syntax-Conventions/Detailed-Grammar.md
create mode 100644 docs/zh/UserGuide/Syntax-Conventions/Identifier.md
create mode 100644 docs/zh/UserGuide/Syntax-Conventions/KeyValue-Pair.md
create mode 100644 docs/zh/UserGuide/Syntax-Conventions/Keywords-And-Reserved-Words.md
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
create mode 100644 docs/zh/UserGuide/Trigger/Configuration-Parameters.md
create mode 100644 docs/zh/UserGuide/Trigger/Implement-Trigger.md
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/Anomaly-Detection.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/Data-Matching.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/Data-Profiling.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/Data-Quality.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/Data-Repairing.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/Frequency-Domain.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/M4.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/Quick-Start.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/Series-Discovery.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/Series-Processing.md
delete mode 100644 docs/zh/UserGuide/UDF-Library/String-Processing.md
create mode 100644 docs/zh/UserGuide/Write-Data/Batch-Load-Tool.md
delete mode 100644 docs/zh/UserGuide/Write-Data/CSV-Tool.md
delete mode 100644 docs/zh/UserGuide/Write-Data/Load-External-Tsfile.md
delete mode 100644 docs/zh/UserGuide/Write-Data/TsFile-Tool.md
create mode 100644 example/udf/src/main/java/org/apache/iotdb/udf/SlidingTimeWindowAccessStrategyExample.java
create mode 100644 grafana-metrics-example/Apache IoTDB ConfigNode Dashboard.json
create mode 100644 grafana-metrics-example/Apache IoTDB DataNode Dashboard.json
delete mode 100644 grafana-metrics-example/cluster/Apache IoTDB ConfigNode Dashboard v0.14.0.json
delete mode 100644 grafana-metrics-example/cluster/Apache IoTDB DataNode Dashboard v0.14.0.json
delete mode 100644 grafana-metrics-example/standalone/Apache IoTDB Dashboard v0.14.0.json
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterPartitionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBAutoRegionGroupExtensionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBCustomRegionGroupExtensionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionDurableIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionGetterIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionInheritPolicyIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationOptimizeIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastWithTTLIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLoadExternalTsfileIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLoadExternalTsfileWithVirtualSGIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSnapshotIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTriggerExecutionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTriggerForwardIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTriggerManagementIT.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
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/PrometheusTextWriter.java
create mode 100644 metrics/dropwizard-metrics/src/main/resources/META-INF/services/org.apache.iotdb.metrics.reporter.JmxReporter
delete mode 100644 metrics/dropwizard-metrics/src/main/resources/META-INF/services/org.apache.iotdb.metrics.reporter.Reporter
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
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/CompositeReporter.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/config/MetricConstant.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingAutoGauge.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingMetric.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/CompositeReporter.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/JmxReporter.java
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
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/MemoryInternalIoTDBReporter.java
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
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/prometheus/PrometheusTextWriter.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/type/AutoGauge.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/InternalReporterType.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MetricFrameType.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MonitorType.java
delete mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/OutPutFormat.java
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
create mode 100644 metrics/micrometer-metrics/src/main/resources/META-INF/services/org.apache.iotdb.metrics.reporter.JmxReporter
delete mode 100644 metrics/micrometer-metrics/src/main/resources/META-INF/services/org.apache.iotdb.metrics.reporter.Reporter
create mode 100644 node-commons/src/assembly/resources/sbin/start-standalone.bat
create mode 100644 node-commons/src/assembly/resources/sbin/start-standalone.sh
create mode 100644 node-commons/src/assembly/resources/sbin/stop-standalone.bat
create mode 100644 node-commons/src/assembly/resources/sbin/stop-standalone.sh
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/SyncConnectionException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/sync/SyncHandshakeException.java
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/detect-watermark.sh
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
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/StorageEngineV2.java
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
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/ChunkMetadataElement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/FileElement.java
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
mode change 100755 => 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/DataRegion.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/executor/TriggerEngine.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/executor/TriggerEvent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/executor/TriggerExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/service/TriggerClassLoaderManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/service/TriggerLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/service/TriggerLogWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/service/TriggerRegistrationInformation.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/service/TriggerRegistrationService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/ContinuousQueryException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/QueryIdNotExsitException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/SyncConnectionException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/SystemCheckException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/TriggerExecutionException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/TriggerManagementException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/index/UnsupportedIndexTypeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/DeleteFailedException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/query/PathException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/lastCache/container/ILastCacheContainer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/lastCache/container/LastCacheContainer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/lastCache/container/value/ILastCacheValue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/lastCache/container/value/LastCacheValue.java
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/lastCache/container/ILastCacheContainer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/lastCache/container/LastCacheContainer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/lastCache/container/value/ILastCacheValue.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/lastCache/container/value/LastCacheValue.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/ActivateTemplatePlanImpl.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/mpp/common/SchemaRegion.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/VerticallyConcatOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/last/AbstractUpdateLastCacheOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/last/AlignedUpdateLastCacheOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/VerticallyConcatNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/adapter/EmptyRowIterator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreateTriggerOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropTriggerOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StartTriggerOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StopTriggerOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTriggerPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropTriggerPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/StartTriggerPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/StopTriggerPlan.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
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/load/DeletionLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/load/ILoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/load/TsFileLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/DeletionLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/ILoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/TsFileLoader.java
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/StorageEngineTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/StorageEngineV2Test.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/FastAlignedCrossCompactionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/FastCrossCompactionPerformerTest.java
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
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/FastCompactionPerformerAlignedTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/FastCompactionPerformerNoAlignedTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSeqCompactionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSeqCompactionWithFastPerformerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSeqCompactionWithReadChunkPerformerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerUnseqCompactionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerUnseqCompactionWithFastPerformerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerUnseqCompactionWithReadPointPerformerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/utils/TsFileGeneratorUtils.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorV2Test.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/execution/operator/VerticallyConcatOperatorTest.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/java/org/apache/iotdb/db/utils/datastructure/PrecisionTest.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%)
create mode 100644 thrift-iot-consensus/pom.xml
create mode 100644 thrift-iot-consensus/src/main/thrift/iotconsensus.thrift
delete mode 100644 thrift-multi-leader-consensus/pom.xml
delete mode 100644 thrift-multi-leader-consensus/src/main/thrift/mutlileader.thrift
[iotdb] 01/01: Merge branch 'master' into kubernetes_version
Posted by xi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch kubernetes_version
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c5e8a2988441242751ddb0e096d967c5cddf3454
Merge: 1961020186 1384d892e3
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Tue Dec 6 11:54:01 2022 +0800
Merge branch 'master' into kubernetes_version
.github/ISSUE_TEMPLATE/bug_report.md | 31 -
.github/ISSUE_TEMPLATE/bug_report.yml | 85 +
.github/ISSUE_TEMPLATE/feature_request.md | 17 -
.github/ISSUE_TEMPLATE/feature_request.yml | 66 +
.github/workflows/client-cpp.yml | 11 +-
.github/workflows/client-go.yml | 12 +-
.github/workflows/client-python.yml | 12 +-
.github/workflows/cluster-it-1c1d.yml | 4 +
.github/workflows/cluster-it-1c3d.yml | 4 +
.github/workflows/e2e.yml | 2 +
.github/workflows/grafana-plugin.yml | 6 +
.github/workflows/influxdb-protocol.yml | 8 +-
.github/workflows/main-unix.yml | 4 +-
.github/workflows/main-win.yml | 2 +
.github/workflows/site-build.yml | 61 +
.github/workflows/sonar-coveralls.yml | 7 +-
.github/workflows/sync.yml | 2 +
Jenkinsfile | 8 +-
README.md | 16 +-
README_ZH.md | 14 +-
RELEASE_NOTES.md | 354 +-
antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 233 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 14 +-
cli/pom.xml | 2 +-
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 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 3 -
client-cpp/pom.xml | 6 +-
client-go | 2 +-
client-py/pom.xml | 2 +-
client-py/requirements_dev.txt | 2 +-
client-py/setup.py | 2 +-
client-py/tests/test_dataframe.py | 4 +
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 8 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 2 +-
confignode/src/assembly/confignode.xml | 4 -
.../src/assembly/resources/conf/confignode-env.bat | 2 +
.../src/assembly/resources/conf/confignode-env.sh | 2 +-
.../resources/conf/iotdb-confignode.properties | 60 +-
.../confignode/client/ConfigNodeRequestType.java | 2 +-
.../client/async/AsyncDataNodeClientPool.java | 13 +-
.../client/sync/SyncConfigNodeClientPool.java | 10 +-
.../client/sync/SyncDataNodeClientPool.java | 40 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 229 +-
.../confignode/conf/ConfigNodeDescriptor.java | 164 +-
.../confignode/conf/ConfigNodeRemoveCheck.java | 2 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 28 +-
.../confignode/conf/SystemPropertiesUtils.java | 6 +-
.../consensus/request/ConfigPhysicalPlan.java | 10 +-
.../consensus/request/ConfigPhysicalPlanType.java | 3 +-
.../read/partition/GetDataPartitionPlan.java | 34 +-
.../partition/GetOrCreateDataPartitionPlan.java | 5 +-
.../request/read/region/GetRegionIdPlan.java | 2 +-
.../write/region/CreateRegionGroupsPlan.java | 19 +
.../AdjustMaxRegionGroupCountPlan.java | 89 -
.../storagegroup/AdjustMaxRegionGroupNumPlan.java | 89 +
.../request/write/sync/RecordPipeMessagePlan.java | 65 +
.../consensus/response/DataNodeRegisterResp.java | 20 +
.../statemachine/ConfigNodeRegionStateMachine.java | 2 +-
.../exception/NoAvailableRegionGroupException.java | 36 +
.../NotAvailableRegionGroupException.java | 27 -
.../confignode/manager/ClusterSchemaManager.java | 179 +-
.../iotdb/confignode/manager/ConfigManager.java | 100 +-
.../iotdb/confignode/manager/ConsensusManager.java | 85 +-
.../apache/iotdb/confignode/manager/IManager.java | 12 +-
.../iotdb/confignode/manager/ProcedureManager.java | 4 +-
.../iotdb/confignode/manager/SyncManager.java | 20 +-
.../iotdb/confignode/manager/TriggerManager.java | 2 +-
.../iotdb/confignode/manager/load/LoadManager.java | 18 +-
.../manager/load/LoadManagerMetrics.java | 112 +-
.../manager/load/balancer/PartitionBalancer.java | 11 +-
.../manager/load/balancer/RegionBalancer.java | 84 +-
.../manager/load/balancer/RouteBalancer.java | 164 +-
.../partition/GreedyPartitionAllocator.java | 89 +-
.../balancer/partition/IPartitionAllocator.java | 11 +-
.../balancer/region/CopySetRegionAllocator.java | 159 -
.../region/CopySetRegionGroupAllocator.java | 160 +
.../balancer/region/GreedyRegionAllocator.java | 68 -
.../region/GreedyRegionGroupAllocator.java | 101 +
.../load/balancer/region/IRegionAllocator.java | 48 -
.../balancer/region/IRegionGroupAllocator.java | 46 +
.../manager/load/balancer/router/IRouter.java | 45 -
.../manager/load/balancer/router/LeaderRouter.java | 90 -
.../balancer/router/LoadScoreGreedyRouter.java | 78 -
.../load/balancer/router/RegionRouteMap.java | 5 +
.../router/leader/GreedyLeaderBalancer.java | 186 +
.../balancer/router/leader/ILeaderBalancer.java | 45 +
.../router/leader/MinCostFlowLeaderBalancer.java | 357 ++
.../manager/load/balancer/router/mcf/MCFEdge.java | 34 -
.../balancer/router/mcf/MCFLeaderBalancer.java | 305 -
.../router/priority/GreedyPriorityBalancer.java | 85 +
.../router/priority/IPriorityBalancer.java | 45 +
.../router/priority/LeaderPriorityBalancer.java | 67 +
.../iotdb/confignode/manager/node/NodeManager.java | 82 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 13 +
.../node/heartbeat/NodeHeartbeatSample.java | 21 +-
.../manager/partition/PartitionManager.java | 269 +-
.../partition/RegionGroupExtensionPolicy.java | 47 +
.../iotdb/confignode/persistence/AuthorInfo.java | 28 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 2 +-
.../persistence/executor/ConfigPlanExecutor.java | 23 +-
.../persistence/metric/NodeInfoMetrics.java | 95 -
.../persistence/metric/PartitionInfoMetrics.java | 30 +-
.../confignode/persistence/node/NodeInfo.java | 4 +-
.../persistence/partition/PartitionInfo.java | 24 +-
.../partition/StorageGroupPartitionTable.java | 10 +-
.../persistence/schema/ClusterSchemaInfo.java | 44 +-
.../persistence/sync/ClusterSyncInfo.java | 23 +-
.../confignode/procedure/ProcedureExecutor.java | 7 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 130 +-
.../procedure/env/DataNodeRemoveHandler.java | 78 +-
.../impl/node/AddConfigNodeProcedure.java | 38 +-
.../impl/node/RemoveDataNodeProcedure.java | 122 +-
.../impl/schema/DeactivateTemplateProcedure.java | 12 +-
.../impl/schema/DeleteStorageGroupProcedure.java | 5 +
.../impl/schema/DeleteTimeSeriesProcedure.java | 9 +-
.../impl/schema/UnsetTemplateProcedure.java | 4 +-
.../statemachine/CreateRegionGroupsProcedure.java | 13 +-
.../impl/statemachine/RegionMigrateProcedure.java | 7 +-
.../procedure/impl/sync/DropPipeProcedure.java | 10 +-
.../procedure/state/AddConfigNodeState.java | 3 +-
.../procedure/state/CreateRegionGroupsState.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 17 +-
.../confignode/service/ConfigNodeCommandLine.java | 3 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 6 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 6 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 33 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 35 +-
.../balancer/region/GreedyRegionAllocatorTest.java | 92 -
.../region/GreedyRegionGroupAllocatorTest.java | 140 +
.../load/balancer/router/LeaderRouterTest.java | 117 -
.../balancer/router/LoadScoreGreedyRouterTest.java | 110 -
.../router/leader/GreedyLeaderBalancerTest.java | 146 +
.../leader/LeaderBalancerComparisonTest.java | 369 ++
.../leader/MinCostFlowLeaderBalancerTest.java | 215 +
.../balancer/router/mcf/MCFLeaderBalancerTest.java | 216 -
.../router/priority/GreedyPriorityTest.java | 110 +
.../priority/LeaderPriorityBalancerTest.java | 167 +
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../persistence/ClusterSyncInfoTest.java | 40 +-
.../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 | 6 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 3 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 13 +-
.../org/apache/iotdb/consensus/common/Utils.java | 33 +
.../common/request/IndexedConsensusRequest.java | 29 +-
.../common/request/IoTConsensusRequest.java | 42 +
.../request/MultiLeaderConsensusRequest.java | 42 -
.../iotdb/consensus/config/ConsensusConfig.java | 20 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 375 ++
.../iotdb/consensus/config/MultiLeaderConfig.java | 338 -
.../apache/iotdb/consensus/config/RatisConfig.java | 36 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 396 ++
.../consensus/iot/IoTConsensusServerImpl.java | 745 +++
.../consensus/iot/IoTConsensusServerMetrics.java | 88 +
.../iot/client/AsyncIoTConsensusServiceClient.java | 147 +
.../consensus/iot/client/DispatchLogHandler.java | 124 +
.../iot/client/IoTConsensusClientPool.java | 86 +
.../iot/client/SyncIoTConsensusServiceClient.java | 144 +
.../iot/logdispatcher/IndexController.java | 177 +
.../logdispatcher/IoTConsensusMemoryManager.java | 90 +
.../IoTConsensusMemoryManagerMetrics.java | 52 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 512 ++
.../logdispatcher/LogDispatcherThreadMetrics.java | 95 +
.../consensus/iot/logdispatcher/PendingBatch.java | 109 +
.../consensus/iot/logdispatcher/SyncStatus.java | 104 +
.../iot/service/IoTConsensusRPCService.java | 104 +
.../iot/service/IoTConsensusRPCServiceHandler.java | 51 +
.../iot/service/IoTConsensusRPCServiceMBean.java | 22 +
.../service/IoTConsensusRPCServiceProcessor.java | 320 +
.../consensus/iot/snapshot/SnapshotFragment.java | 81 +
.../iot/snapshot/SnapshotFragmentReader.java | 69 +
.../consensus/iot/wal/ConsensusReqReader.java | 85 +
.../iot/wal/GetConsensusReqReaderPlan.java | 33 +
.../multileader/MultiLeaderConsensus.java | 394 --
.../multileader/MultiLeaderServerImpl.java | 742 ---
.../multileader/MultiLeaderServerMetrics.java | 88 -
.../client/AsyncMultiLeaderServiceClient.java | 146 -
.../multileader/client/DispatchLogHandler.java | 124 -
.../client/MultiLeaderConsensusClientPool.java | 87 -
.../client/SyncMultiLeaderServiceClient.java | 144 -
.../multileader/logdispatcher/IndexController.java | 172 -
.../multileader/logdispatcher/LogDispatcher.java | 509 --
.../logdispatcher/LogDispatcherThreadMetrics.java | 95 -
.../logdispatcher/MultiLeaderMemoryManager.java | 86 -
.../MultiLeaderMemoryManagerMetrics.java | 52 -
.../multileader/logdispatcher/PendingBatch.java | 81 -
.../multileader/logdispatcher/SyncStatus.java | 91 -
.../multileader/service/MultiLeaderRPCService.java | 104 -
.../service/MultiLeaderRPCServiceHandler.java | 51 -
.../service/MultiLeaderRPCServiceMBean.java | 22 -
.../service/MultiLeaderRPCServiceProcessor.java | 336 -
.../multileader/snapshot/SnapshotFragment.java | 81 -
.../snapshot/SnapshotFragmentReader.java | 69 -
.../multileader/wal/ConsensusReqReader.java | 85 -
.../multileader/wal/GetConsensusReqReaderPlan.java | 33 -
.../ratis/ApplicationStateMachineProxy.java | 7 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 21 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 116 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 44 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 16 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 2 +-
.../iotdb/consensus/iot/IoTConsensusTest.java | 247 +
.../apache/iotdb/consensus/iot/RecoveryTest.java | 97 +
.../iot/logdispatcher/IndexControllerTest.java | 85 +
.../iot/logdispatcher/SyncStatusTest.java | 235 +
.../consensus/iot/util/FakeConsensusReqReader.java | 100 +
.../iotdb/consensus/iot/util/RequestSets.java | 55 +
.../apache/iotdb/consensus/iot/util/TestEntry.java | 78 +
.../iotdb/consensus/iot/util/TestStateMachine.java | 121 +
.../multileader/MultiLeaderConsensusTest.java | 247 -
.../iotdb/consensus/multileader/RecoveryTest.java | 97 -
.../logdispatcher/IndexControllerTest.java | 85 -
.../multileader/logdispatcher/SyncStatusTest.java | 226 -
.../multileader/util/FakeConsensusReqReader.java | 100 -
.../consensus/multileader/util/RequestSets.java | 55 -
.../consensus/multileader/util/TestEntry.java | 78 -
.../multileader/util/TestStateMachine.java | 121 -
.../iotdb/consensus/ratis/RatisConsensusTest.java | 39 +-
cross-tests/pom.xml | 2 +-
distribution/pom.xml | 4 +-
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/Download/README.md | 46 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 2 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 4 +-
docs/UserGuide/API/Programming-TsFile-API.md | 4 +-
docs/UserGuide/API/RestService.md | 60 +-
docs/UserGuide/API/Status-Codes.md | 109 -
.../Administration-Management/Administration.md | 12 +-
docs/UserGuide/Cluster/Cluster-Concept.md | 56 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 416 ++
docs/UserGuide/Cluster/Cluster-Setup.md | 302 +-
.../UserGuide/Cluster/Deployment-Recommendation.md | 181 +
docs/UserGuide/Data-Concept/Compression.md | 93 +-
.../Data-Concept/Data-Model-and-Terminology.md | 2 +
docs/UserGuide/Data-Concept/Deadband-Process.md | 113 +
docs/UserGuide/Data-Concept/Schema-Template.md | 15 +
docs/UserGuide/Data-Concept/Time-Partition.md | 15 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 4 +-
.../UserGuide/Ecosystem-Integration/Hive-TsFile.md | 8 +-
.../Ecosystem-Integration/MapReduce-TsFile.md | 2 +-
.../Ecosystem-Integration/Spark-TsFile.md | 2 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 56 +-
docs/UserGuide/FAQ/Frequently-asked-questions.md | 6 +-
.../{Write-Data => Maintenance-Tools}/CSV-Tool.md | 0
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
docs/UserGuide/Maintenance-Tools/Load-Tsfile.md | 111 +
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 6 +-
.../Maintenance-Tools/Maintenance-Command.md | 424 +-
docs/UserGuide/Maintenance-Tools/NodeTool.md | 297 -
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 6 +-
.../Maintenance-Tools/TsFile-Load-Export-Tool.md | 83 +
.../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 | 767 ++-
docs/UserGuide/Operate-Metadata/Database.md | 137 +
docs/UserGuide/Operate-Metadata/Storage-Group.md | 137 -
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 +
docs/UserGuide/Operators-Functions/Overview.md | 65 +
docs/UserGuide/Operators-Functions/Sample.md | 389 ++
docs/UserGuide/Operators-Functions/Selection.md | 51 +
.../Series-Discovery.md | 0
docs/UserGuide/Operators-Functions/String.md | 863 +++
docs/UserGuide/Operators-Functions/Time-Series.md | 70 +
.../Operators-Functions/User-Defined-Function.md | 606 ++
.../Operators-Functions/Variation-Trend.md | 54 +
docs/UserGuide/Process-Data/Select-Into.md | 338 -
docs/UserGuide/Process-Data/Triggers.md | 469 --
.../Process-Data/UDF-User-Defined-Function.md | 603 --
docs/UserGuide/Query-Data/Aggregate-Query.md | 723 ---
docs/UserGuide/Query-Data/Align-By.md | 57 +
.../Continuous-Query.md | 0
docs/UserGuide/Query-Data/Fill-Null-Value.md | 199 -
docs/UserGuide/Query-Data/Fill.md | 209 +
docs/UserGuide/Query-Data/Group-By.md | 585 ++
docs/UserGuide/Query-Data/Having-Condition.md | 115 +
docs/UserGuide/Query-Data/Last-Query.md | 16 +-
docs/UserGuide/Query-Data/Order-By.md | 24 +
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/Query-Filter.md | 194 -
docs/UserGuide/Query-Data/Result-Format.md | 82 -
docs/UserGuide/Query-Data/Select-Expression.md | 1080 +---
docs/UserGuide/Query-Data/Select-Into.md | 340 +
docs/UserGuide/Query-Data/Tracing-Tool.md | 48 -
docs/UserGuide/Query-Data/Where-Condition.md | 191 +
docs/UserGuide/Query-Data/Without-Null.md | 172 -
.../UserGuide/QuickStart/Command-Line-Interface.md | 54 +-
docs/UserGuide/QuickStart/Files.md | 92 +-
docs/UserGuide/QuickStart/QuickStart.md | 62 +-
docs/UserGuide/QuickStart/ServerFileList.md | 49 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 8 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 1988 ++++++
.../Reference/ConfigNode-Config-Manual.md | 257 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 1212 +---
docs/UserGuide/Reference/Keywords.md | 406 +-
docs/UserGuide/Reference/SQL-Reference.md | 14 +-
docs/UserGuide/Reference/Status-Codes.md | 164 +
docs/UserGuide/Reference/Syntax-Conventions.md | 591 --
.../Syntax-Conventions/Detailed-Grammar.md | 28 +
docs/UserGuide/Syntax-Conventions/Identifier.md | 141 +
docs/UserGuide/Syntax-Conventions/KeyValue-Pair.md | 119 +
.../Keywords-And-Reserved-Words.md | 26 +
.../UserGuide/Syntax-Conventions/Literal-Values.md | 157 +
.../Syntax-Conventions/NodeName-In-Path.md | 119 +
.../Syntax-Conventions/Session-And-TsFile-API.md | 119 +
docs/UserGuide/Trigger/Configuration-Parameters.md | 29 +
docs/UserGuide/Trigger/Implement-Trigger.md | 294 +
docs/UserGuide/Trigger/Instructions.md | 51 +
docs/UserGuide/Trigger/Notes.md | 30 +
docs/UserGuide/Trigger/Trigger-Management.md | 152 +
docs/UserGuide/UDF-Library/M4.md | 3 +-
docs/UserGuide/UDF-Library/Quick-Start.md | 41 -
docs/UserGuide/UDF-Library/Series-Processing.md | 70 -
docs/UserGuide/UDF-Library/String-Processing.md | 797 ---
docs/UserGuide/Write-Data/Batch-Load-Tool.md | 32 +
docs/UserGuide/Write-Data/Load-External-Tsfile.md | 94 -
docs/UserGuide/Write-Data/REST-API.md | 6 +-
docs/UserGuide/Write-Data/TsFile-Tool.md | 80 -
docs/zh/Download/README.md | 54 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 2 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 2 +-
.../UserGuide/API/Programming-Java-Native-API.md | 4 +-
docs/zh/UserGuide/API/Programming-TsFile-API.md | 4 +-
docs/zh/UserGuide/API/RestService.md | 78 +-
docs/zh/UserGuide/API/Status-Codes.md | 108 -
.../Administration-Management/Administration.md | 12 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 52 +-
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 415 ++
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 280 +-
.../UserGuide/Cluster/Deployment-Recommendation.md | 179 +
docs/zh/UserGuide/Data-Concept/Compression.md | 88 +-
.../Data-Concept/Data-Model-and-Terminology.md | 2 +
docs/zh/UserGuide/Data-Concept/Deadband-Process.md | 108 +
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 15 +
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 25 +-
.../Ecosystem-Integration/Grafana-Plugin.md | 4 +-
.../UserGuide/Ecosystem-Integration/Hive-TsFile.md | 8 +-
.../Ecosystem-Integration/MapReduce-TsFile.md | 2 +-
.../Ecosystem-Integration/Spark-TsFile.md | 2 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 47 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 7 +-
docs/zh/UserGuide/Maintenance-Tools/CSV-Tool.md | 255 +
.../IoTDB-Data-Dir-Overview-Tool.md | 82 +
docs/zh/UserGuide/Maintenance-Tools/Load-Tsfile.md | 110 +
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 6 +-
.../Maintenance-Tools/Maintenance-Command.md | 403 +-
docs/zh/UserGuide/Maintenance-Tools/NodeTool.md | 293 -
.../Maintenance-Tools/Rewrite-TsFile-Tool.md | 62 -
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 8 +-
.../Maintenance-Tools/TsFile-Load-Export-Tool.md | 85 +
.../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 | 748 ++-
docs/zh/UserGuide/Operate-Metadata/Database.md | 136 +
.../zh/UserGuide/Operate-Metadata/Storage-Group.md | 136 -
docs/zh/UserGuide/Operate-Metadata/Template.md | 4 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 14 +-
.../UserGuide/Operators-Functions/Aggregation.md | 41 +
.../Operators-Functions/Anomaly-Detection.md | 531 ++
.../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 +
.../UserGuide/Operators-Functions/Data-Matching.md | 333 +
.../Operators-Functions/Data-Profiling.md | 1879 ++++++
.../UserGuide/Operators-Functions/Data-Quality.md | 579 ++
.../Operators-Functions/Data-Repairing.md | 408 ++
.../Operators-Functions/Frequency-Domain.md | 598 ++
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 +
.../Operators-Functions/Series-Discovery.md | 173 +
docs/zh/UserGuide/Operators-Functions/String.md | 856 +++
.../UserGuide/Operators-Functions/Time-Series.md | 69 +
.../Operators-Functions/User-Defined-Function.md | 540 ++
.../Operators-Functions/Variation-Trend.md | 54 +
docs/zh/UserGuide/Process-Data/Select-Into.md | 348 -
docs/zh/UserGuide/Process-Data/Triggers.md | 457 --
.../Process-Data/UDF-User-Defined-Function.md | 536 --
docs/zh/UserGuide/Query-Data/Aggregate-Query.md | 708 ---
docs/zh/UserGuide/Query-Data/Align-By.md | 61 +
.../Continuous-Query.md | 0
docs/zh/UserGuide/Query-Data/Fill-Null-Value.md | 193 -
docs/zh/UserGuide/Query-Data/Fill.md | 207 +
docs/zh/UserGuide/Query-Data/Group-By.md | 572 ++
docs/zh/UserGuide/Query-Data/Having-Condition.md | 115 +
docs/zh/UserGuide/Query-Data/Last-Query.md | 24 +-
docs/zh/UserGuide/Query-Data/Order-By.md | 24 +
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/Query-Filter.md | 188 -
docs/zh/UserGuide/Query-Data/Result-Format.md | 89 -
docs/zh/UserGuide/Query-Data/Select-Expression.md | 1166 +---
docs/zh/UserGuide/Query-Data/Select-Into.md | 350 +
docs/zh/UserGuide/Query-Data/Tracing-Tool.md | 48 -
docs/zh/UserGuide/Query-Data/Where-Condition.md | 185 +
docs/zh/UserGuide/Query-Data/Without-Null.md | 172 -
.../UserGuide/QuickStart/Command-Line-Interface.md | 39 +-
docs/zh/UserGuide/QuickStart/Files.md | 88 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 51 +-
docs/zh/UserGuide/QuickStart/ServerFileList.md | 46 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 2030 ++++++
.../Reference/ConfigNode-Config-Manual.md | 326 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 1800 +-----
docs/zh/UserGuide/Reference/Keywords.md | 406 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 14 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 164 +
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 590 --
.../Syntax-Conventions/Detailed-Grammar.md | 28 +
docs/zh/UserGuide/Syntax-Conventions/Identifier.md | 142 +
.../UserGuide/Syntax-Conventions/KeyValue-Pair.md | 119 +
.../Keywords-And-Reserved-Words.md | 26 +
.../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 | 29 +
docs/zh/UserGuide/Trigger/Implement-Trigger.md | 297 +
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/Anomaly-Detection.md | 531 --
docs/zh/UserGuide/UDF-Library/Data-Matching.md | 333 -
docs/zh/UserGuide/UDF-Library/Data-Profiling.md | 1879 ------
docs/zh/UserGuide/UDF-Library/Data-Quality.md | 579 --
docs/zh/UserGuide/UDF-Library/Data-Repairing.md | 408 --
docs/zh/UserGuide/UDF-Library/Frequency-Domain.md | 598 --
docs/zh/UserGuide/UDF-Library/M4.md | 26 -
docs/zh/UserGuide/UDF-Library/Quick-Start.md | 40 -
docs/zh/UserGuide/UDF-Library/Series-Discovery.md | 173 -
docs/zh/UserGuide/UDF-Library/Series-Processing.md | 69 -
docs/zh/UserGuide/UDF-Library/String-Processing.md | 786 ---
docs/zh/UserGuide/Write-Data/Batch-Load-Tool.md | 32 +
docs/zh/UserGuide/Write-Data/CSV-Tool.md | 255 -
.../UserGuide/Write-Data/Load-External-Tsfile.md | 93 -
docs/zh/UserGuide/Write-Data/REST-API.md | 6 +-
docs/zh/UserGuide/Write-Data/TsFile-Tool.md | 81 -
example/client-cpp-example/pom.xml | 4 +-
example/ext-pipe-plugin-example/README.md | 2 +-
example/ext-pipe-plugin-example/pom.xml | 4 +-
example/flink/pom.xml | 2 +-
.../org/apache/iotdb/flink/FlinkIoTDBSource.java | 2 +-
example/hadoop/pom.xml | 2 +-
example/influxdb-protocol-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 4 +-
example/kafka/readme.md | 4 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pom.xml | 2 +-
example/pulsar/pom.xml | 2 +-
example/rabbitmq/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/rocketmq/readme.md | 4 +-
example/session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 2 +-
.../iotdb/SyntaxConventionRelatedExample.java | 2 +-
example/trigger/pom.xml | 4 +-
example/tsfile/pom.xml | 2 +-
example/tsfile/readme.md | 2 +-
example/udf/pom.xml | 4 +-
.../SlidingTimeWindowAccessStrategyExample.java | 105 +
.../java/org/apache/iotdb/udf/UDTFExample.java | 4 +-
external-api/pom.xml | 2 +-
external-pipe-api/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana-connector/pom.xml | 4 +-
.../Apache IoTDB ConfigNode Dashboard.json | 2495 ++++++++
.../Apache IoTDB DataNode Dashboard.json | 4617 ++++++++++++++
.../Apache IoTDB ConfigNode Dashboard v0.14.0.json | 1634 -----
.../Apache IoTDB DataNode Dashboard v0.14.0.json | 3247 ----------
.../standalone/Apache IoTDB Dashboard v0.14.0.json | 1519 -----
grafana-plugin/go.sum | 2 +-
grafana-plugin/pkg/plugin/plugin.go | 8 +-
grafana-plugin/pom.xml | 10 +-
hadoop/README.md | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
influxdb-protocol/pom.xml | 2 +-
integration-test/import-control.xml | 2 -
integration-test/pom.xml | 6 +-
.../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 | 97 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 18 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 92 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 10 +
.../confignode/it/IoTDBClusterAuthorityIT.java | 2 +-
.../confignode/it/IoTDBClusterPartitionIT.java | 781 ---
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 105 +-
.../iotdb/confignode/it/IoTDBClusterRestartIT.java | 12 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 12 +-
.../it/IoTDBConfigNodeSwitchLeaderIT.java | 21 +-
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 3 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 199 +
.../IoTDBCustomRegionGroupExtensionIT.java | 193 +
.../it/partition/IoTDBPartitionDurableIT.java | 625 ++
.../it/partition/IoTDBPartitionGetterIT.java | 555 ++
.../partition/IoTDBPartitionInheritPolicyIT.java | 188 +
.../confignode/it/utils/ConfigNodeTestUtils.java | 72 +
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 12 +-
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 14 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 32 +-
.../org/apache/iotdb/db/it/IoTDBEncodingIT.java | 91 +-
.../apache/iotdb/db/it/IoTDBFilterBetweenIT.java | 3 +-
.../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 8 +-
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 98 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 7 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 23 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 262 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 48 +-
.../java/org/apache/iotdb/db/it/IoTDBTtlIT.java | 11 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 2 -
.../db/it/aggregation/IoTDBAggregationIT.java | 62 +-
.../it/aggregation/IoTDBAggregationOptimizeIT.java | 181 +
.../aggregation/IoTDBAggregationSmallDataIT.java | 21 -
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 75 +-
.../aligned/IoTDBAggregationWithDeletion2IT.java | 4 +-
.../it/aligned/IoTDBAggregationWithDeletionIT.java | 7 +-
.../db/it/aligned/IoTDBAlignedDataDeletionIT.java | 32 +-
.../db/it/aligned/IoTDBAlignedLastQuery2IT.java | 4 +-
.../db/it/aligned/IoTDBAlignedLastQuery3IT.java | 4 +-
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 4 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 89 -
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 39 +-
...GroupByQueryWithValueFilterWithDeletion2IT.java | 4 +-
...BGroupByQueryWithValueFilterWithDeletionIT.java | 4 +-
...upByQueryWithoutValueFilterWithDeletion2IT.java | 4 +-
...oupByQueryWithoutValueFilterWithDeletionIT.java | 4 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 6 +-
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 6 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 26 +-
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 8 +-
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 8 +-
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 4 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 4 +-
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 8 +-
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 8 +-
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 3 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 18 +-
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 3 +-
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 53 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 18 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 29 +-
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 6 +-
.../apache/iotdb/db/it/groupby/IoTDBHavingIT.java | 16 +-
.../iotdb/db/it/last/IoTDBLastWithTTLIT.java | 106 +
.../org/apache/iotdb/db/it/query/IoTDBInIT.java | 33 +-
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 3 +-
.../iotdb/db/it/query/IoTDBNullValueFillIT.java | 3 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 4 +
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 11 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 2 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 33 +-
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 13 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 78 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 30 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 7 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto3IT.java | 7 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 21 +-
.../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 7 +-
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 4 +-
.../db/it/trigger/IoTDBTriggerManagementIT.java | 50 +-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 28 +
.../db/it/udf/IoTDBUDFOtherWindowQueryIT.java | 84 +-
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 31 +
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 20 +
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 7 +-
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 1 -
.../apache/iotdb/db/it/utils/AlignedWriteUtil.java | 4 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 4 +-
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 15 +-
.../db/it/withoutNull/IoTDBWithoutAnyNullIT.java | 3 +-
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 3 +-
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 3 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 76 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 12 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 57 +-
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 1324 -> 1397 bytes
integration/pom.xml | 8 +-
.../iotdb/integration/env/ClusterEnvConfig.java | 8 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 4 -
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 19 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 3 +-
.../integration/IoTDBCompactionWithIDTableIT.java | 3 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 102 -
.../db/integration/IoTDBLoadExternalTsfileIT.java | 1032 ---
.../IoTDBLoadExternalTsfileWithVirtualSGIT.java | 137 -
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 3 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 36 +-
.../db/integration/IoTDBRemovePartitionIT.java | 2 -
.../db/integration/IoTDBRewriteTsFileToolIT.java | 59 +-
.../db/integration/IoTDBSchemaTemplateIT.java | 21 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 9 +-
.../iotdb/db/integration/IoTDBSnapshotIT.java | 285 -
.../iotdb/db/integration/IoTDBTimePartitionIT.java | 5 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 678 --
.../db/integration/IoTDBTriggerForwardIT.java | 305 -
.../db/integration/IoTDBTriggerManagementIT.java | 539 --
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 20 +-
.../aggregation/IoTDBUDFNestAggregationIT.java | 3 +-
.../IoTDBUserDefinedAggregationFunctionIT.java | 8 +-
.../aligned/IoTDBGroupByFillQueryBigDataIT.java | 3 +-
.../aligned/IoTDBGroupByFillQueryIT.java | 3 +-
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 2027 +++---
.../db/integration/env/StandaloneEnvConfig.java | 7 +-
.../db/integration/groupby/IoTDBGroupByFillIT.java | 2 +-
.../groupby/IoTDBGroupByFillMixPathsIT.java | 2 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../sync/IoTDBSyncReceiverLoaderIT.java | 6 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 2 +-
.../iotdb/db/integration/sync/MockSyncClient.java | 4 +-
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 30 +-
.../IoTDBDeletionVersionAdaptionIT.java | 3 +-
jdbc/README.md | 4 +-
jdbc/pom.xml | 4 +-
jdbc/src/main/feature/feature.xml | 4 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 4 +-
library-udf/pom.xml | 2 +-
metrics/ReadMe.md | 29 +-
metrics/dropwizard-metrics/pom.xml | 7 +-
.../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/reporter/PrometheusTextWriter.java | 79 -
.../dropwizard/type/DropwizardAutoGauge.java | 19 +-
.../type/DropwizardHistogramSnapshot.java | 7 -
.../org.apache.iotdb.metrics.reporter.JmxReporter | 18 +
.../org.apache.iotdb.metrics.reporter.Reporter | 20 -
metrics/interface/pom.xml | 13 +-
.../resources/conf/iotdb-confignode-metric.yml | 51 -
.../resources/conf/iotdb-datanode-metric.yml | 51 -
.../iotdb/metrics/AbstractMetricManager.java | 201 +-
.../iotdb/metrics/AbstractMetricService.java | 231 +-
.../apache/iotdb/metrics/CompositeReporter.java | 91 +
.../iotdb/metrics/DoNothingMetricService.java | 8 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 255 +-
.../metrics/config/MetricConfigDescriptor.java | 221 +-
.../iotdb/metrics/config/MetricConstant.java | 37 -
.../apache/iotdb/metrics/config/ReloadLevel.java | 6 +-
.../iotdb/metrics/impl/DoNothingAutoGauge.java | 29 +
.../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 | 22 +
.../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 +-
.../iotdb/metrics/reporter/CompositeReporter.java | 96 -
.../apache/iotdb/metrics/reporter/JmxReporter.java | 27 +
.../apache/iotdb/metrics/reporter/Reporter.java | 10 +-
.../reporter/iotdb/InternalIoTDBReporter.java | 67 +
.../metrics/reporter/iotdb/IoTDBReporter.java | 103 +
.../iotdb/MemoryInternalIoTDBReporter.java | 57 +
.../reporter/iotdb/SessionIoTDBReporter.java | 175 +
.../reporter/prometheus/PrometheusReporter.java | 222 +
.../reporter/prometheus/PrometheusTextWriter.java | 81 +
.../org/apache/iotdb/metrics/type/AutoGauge.java | 32 +
.../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 +-
.../iotdb/metrics/utils/InternalReporterType.java | 30 +
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 74 +-
.../iotdb/metrics/utils/MetricFrameType.java | 30 +
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 18 +-
.../org/apache/iotdb/metrics/utils/MetricType.java | 1 +
.../apache/iotdb/metrics/utils/MonitorType.java | 30 -
.../apache/iotdb/metrics/utils/OutPutFormat.java | 30 -
.../iotdb/metrics/config/MetricConfigTest.java | 86 +-
.../interface/src/test/resources/iotdb-metric.yml | 52 -
metrics/micrometer-metrics/pom.xml | 4 +-
.../micrometer/MicrometerMetricManager.java | 6 +-
.../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 | 18 +
.../org.apache.iotdb.metrics.reporter.Reporter | 20 -
metrics/pom.xml | 2 +-
node-commons/pom.xml | 2 +-
.../resources/conf/iotdb-common.properties | 394 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 2 +-
.../assembly/resources/sbin/start-standalone.bat | 45 +
.../assembly/resources/sbin/start-standalone.sh | 43 +
.../assembly/resources/sbin/stop-standalone.bat | 43 +
.../src/assembly/resources/sbin/stop-standalone.sh | 40 +
.../commons/auth/authorizer/OpenIdAuthorizer.java | 41 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 4 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 13 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 23 +-
.../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 | 28 +-
.../commons/exception/ConfigurationException.java | 6 +-
.../commons/exception/IllegalPathException.java | 4 +-
.../commons/exception/sync/PipeSinkException.java | 4 +-
.../exception/sync/SyncConnectionException.java | 39 +
.../exception/sync/SyncHandshakeException.java | 26 +
.../iotdb/commons/partition/DataPartition.java | 21 +-
.../commons/partition/DataPartitionQueryParam.java | 41 +
.../commons/partition/DataPartitionTable.java | 29 +-
.../iotdb/commons/partition/SchemaPartition.java | 3 +-
.../commons/partition/SchemaPartitionTable.java | 6 +-
.../commons/partition/SeriesPartitionTable.java | 46 +-
.../org/apache/iotdb/commons/path/AlignedPath.java | 18 +
.../org/apache/iotdb/commons/path/PartialPath.java | 3 +
.../apache/iotdb/commons/service/ServiceType.java | 2 +-
.../iotdb/commons/service/StartupChecks.java | 44 +-
.../commons/service/metric/MetricService.java | 105 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +-
.../iotdb/commons/sync/metadata/SyncMetadata.java | 5 +-
.../iotdb/commons/sync/pipe/PipeMessage.java | 54 +-
.../iotdb/commons/sync/pipe/TsFilePipeInfo.java | 3 +-
.../iotdb/commons/sync/pipesink/IoTDBPipeSink.java | 29 +-
.../iotdb/commons/sync/pipesink/PipeSink.java | 5 -
.../commons/sync/transport/SyncIdentityInfo.java | 57 +
.../iotdb/commons/sync/utils/SyncConstant.java | 7 +-
.../iotdb/commons/sync/utils/SyncPathUtil.java | 17 +-
.../apache/iotdb/commons/trigger/TriggerTable.java | 4 +-
.../org/apache/iotdb/commons/udf/UDFTable.java | 2 +-
.../commons/udf/service/UDFManagementService.java | 27 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 17 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 39 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 155 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 20 +
.../commons/sync/metedata/SyncMetadataTest.java | 4 +-
openapi/pom.xml | 2 +-
openapi/src/main/openapi3/iotdb-rest.yaml | 17 +-
pom.xml | 21 +-
rewrite-tsfile-tool/pom.xml | 2 +-
schema-engine-rocksdb/pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 157 +-
.../schemaregion/rocksdb/mnode/REntityMNode.java | 16 -
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 32 -
.../schemaregion/rocksdb/mnode/RMNode.java | 20 -
.../rocksdb/mnode/RMeasurementMNode.java | 43 -
.../rocksdb/mnode/RStorageGroupMNode.java | 8 -
schema-engine-tag/README.md | 4 +-
schema-engine-tag/pom.xml | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 87 +-
.../utils/ShowTimeSeriesResultUtils.java | 12 +-
server/pom.xml | 2 +-
.../src/assembly/resources/conf/datanode-env.bat | 4 +-
server/src/assembly/resources/conf/datanode-env.sh | 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 | 13 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 56 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 5 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 181 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 6 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 169 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 111 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 32 +-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 16 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 2 +
.../consensus/statemachine/BaseStateMachine.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 32 +-
.../statemachine/visitor/DataExecutionVisitor.java | 42 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 777 ++-
.../apache/iotdb/db/engine/StorageEngineV2.java | 816 ---
.../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 | 129 +-
.../constant/CrossCompactionPerformer.java | 11 +-
.../constant/InnerSeqCompactionPerformer.java | 11 +-
.../constant/InnerUnseqCompactionPerformer.java | 12 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 58 +-
.../rewrite/CrossSpaceCompactionResource.java | 13 +-
.../RewriteCrossSpaceCompactionSelector.java | 18 +-
.../task/FastCompactionPerformerSubTask.java | 146 +
.../utils/AlignedSeriesCompactionExecutor.java | 339 +
.../cross/utils/ChunkMetadataElement.java | 56 +
.../engine/compaction/cross/utils/FileElement.java | 31 +
.../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 | 43 +-
.../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/load/AlignedChunkData.java | 6 +-
.../iotdb/db/engine/load/NonAlignedChunkData.java | 4 +-
.../iotdb/db/engine/load/TsFileSplitter.java | 22 +-
.../db/engine/querycontext/QueryDataSource.java | 5 +
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 14 +-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 21 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 153 +-
.../db/engine/storagegroup/DataRegionMetrics.java | 8 +-
.../engine/storagegroup/HashLastFlushTimeMap.java | 3 +-
.../storagegroup/IDTableLastFlushTimeMap.java | 3 +-
.../db/engine/storagegroup/ILastFlushTimeMap.java | 2 +-
.../engine/storagegroup/TimePartitionManager.java | 4 +-
.../db/engine/storagegroup/TsFileManager.java | 12 +-
.../db/engine/storagegroup/TsFileProcessor.java | 224 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 4 +-
.../db/engine/storagegroup/TsFileResource.java | 4 +-
.../db/engine/storagegroup/TsFileResourceList.java | 4 +-
.../engine/storagegroup/TsFileResourceStatus.java | 3 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 9 +-
.../storagegroup/timeindex/FileTimeIndex.java | 6 +-
.../db/engine/trigger/builtin/ForwardTrigger.java | 2 +-
.../db/engine/trigger/executor/TriggerEngine.java | 64 -
.../db/engine/trigger/executor/TriggerEvent.java | 53 -
.../engine/trigger/executor/TriggerExecutor.java | 250 -
.../trigger/service/TriggerClassLoaderManager.java | 95 -
.../engine/trigger/service/TriggerLogReader.java | 48 -
.../engine/trigger/service/TriggerLogWriter.java | 68 -
.../service/TriggerRegistrationInformation.java | 82 -
.../service/TriggerRegistrationService.java | 505 --
.../db/exception/ContinuousQueryException.java | 36 -
.../iotdb/db/exception/DataRegionException.java | 4 +-
.../exception/DiskSpaceInsufficientException.java | 2 +-
.../apache/iotdb/db/exception/MergeException.java | 2 +-
.../db/exception/QueryIdNotExsitException.java | 29 -
.../exception/StorageEngineReadonlyException.java | 2 +-
.../db/exception/SyncConnectionException.java | 39 -
.../iotdb/db/exception/SystemCheckException.java | 34 -
.../db/exception/TriggerExecutionException.java | 32 -
.../db/exception/TriggerManagementException.java | 32 -
.../index/UnsupportedIndexTypeException.java | 32 -
.../metadata/AliasAlreadyExistException.java | 2 +-
.../exception/metadata/DeleteFailedException.java | 40 -
.../metadata/MeasurementAlreadyExistException.java | 2 +-
.../metadata/MeasurementInBlackListException.java | 2 +-
.../metadata/PathAlreadyExistException.java | 2 +-
.../exception/metadata/PathNotExistException.java | 24 +-
.../metadata/StorageGroupAlreadySetException.java | 4 +-
.../metadata/StorageGroupNotSetException.java | 4 +-
.../schemafile/ColossalRecordException.java | 6 +-
.../SchemaFileLogCorruptedException.java | 2 +-
.../template/NoTemplateOnMNodeException.java | 2 +-
.../template/TemplateImcompatibeException.java | 4 +-
.../db/exception/query/OutOfTTLException.java | 8 +-
.../iotdb/db/exception/query/PathException.java | 38 -
.../query/UnSupportedFillTypeException.java | 2 +-
.../apache/iotdb/db/index/common/IndexType.java | 10 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 258 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 550 +-
.../metadata/cache/DataNodeLastCacheManager.java | 2 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 47 +-
.../metadata/cache/DataNodeSchemaCacheMetrics.java | 4 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 16 +-
.../lastCache/container/ILastCacheContainer.java | 45 +
.../lastCache/container/LastCacheContainer.java | 70 +
.../lastCache/container/value/ILastCacheValue.java | 35 +
.../lastCache/container/value/LastCacheValue.java | 55 +
.../apache/iotdb/db/metadata/idtable/IDTable.java | 45 -
.../db/metadata/idtable/IDTableHashmapImpl.java | 65 -
.../iotdb/db/metadata/idtable/IDTableManager.java | 2 +-
.../idtable/entry/InsertMeasurementMNode.java | 68 -
.../db/metadata/idtable/entry/SchemaEntry.java | 82 +-
.../db/metadata/lastCache/LastCacheManager.java | 255 -
.../lastCache/container/ILastCacheContainer.java | 45 -
.../lastCache/container/LastCacheContainer.java | 70 -
.../lastCache/container/value/ILastCacheValue.java | 35 -
.../lastCache/container/value/LastCacheValue.java | 55 -
.../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 | 19 -
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 10 -
.../iotdb/db/metadata/mnode/InternalMNode.java | 56 -
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 29 -
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 67 -
.../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 | 697 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 638 +-
.../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 +-
.../metadata/schemaregion/RSchemaRegionLoader.java | 14 +-
.../db/metadata/schemaregion/SchemaEngine.java | 48 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 342 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 346 +-
.../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 --
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 22 +
.../metadata/visitor/SchemaExecutionVisitor.java | 4 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 20 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 28 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 27 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 21 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 1 +
.../db/mpp/aggregation/MinValueAccumulator.java | 21 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 1 +
.../apache/iotdb/db/mpp/common/SchemaRegion.java | 29 -
.../db/mpp/common/header/ColumnHeaderConstant.java | 32 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 23 +-
.../common/schematree/DeviceGroupSchemaTree.java | 7 +-
.../db/mpp/common/schematree/ISchemaTree.java | 7 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 9 +
.../iotdb/db/mpp/execution/driver/DataDriver.java | 6 +-
.../db/mpp/execution/exchange/ISourceHandle.java | 8 +
.../db/mpp/execution/exchange/LocalSinkHandle.java | 9 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 21 +
.../execution/exchange/MPPDataExchangeManager.java | 20 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 6 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 6 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 23 +-
.../db/mpp/execution/exchange/SinkHandle.java | 6 +-
.../db/mpp/execution/exchange/SourceHandle.java | 9 +-
.../execution/executor/RegionWriteExecutor.java | 57 +-
.../fragment/FragmentInstanceContext.java | 30 +-
.../fragment/FragmentInstanceManager.java | 21 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 84 +-
.../operator/process/AbstractIntoOperator.java | 199 +-
.../operator/process/DeviceViewIntoOperator.java | 105 +-
.../operator/process/DeviceViewOperator.java | 22 +-
.../execution/operator/process/IntoOperator.java | 48 +-
.../operator/process/TagAggregationOperator.java | 41 +-
.../process/join/VerticallyConcatOperator.java | 207 +
.../process/join/merge/MultiColumnMerger.java | 18 +-
.../last/AbstractUpdateLastCacheOperator.java | 112 +
.../last/AlignedUpdateLastCacheOperator.java | 89 +
.../operator/process/last/LastQueryOperator.java | 12 +-
.../process/last/LastQuerySortOperator.java | 11 +-
.../operator/process/last/LastQueryUtil.java | 18 +
.../process/last/UpdateLastCacheOperator.java | 73 +-
.../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 +-
.../schema/TimeSeriesSchemaScanOperator.java | 2 +
.../operator/source/AlignedSeriesScanOperator.java | 121 +-
.../operator/source/SeriesScanOperator.java | 118 +-
.../execution/schedule/AbstractDriverThread.java | 4 +-
.../schedule/FragmentInstanceAbortedException.java | 2 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 26 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 252 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 93 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 170 +-
.../db/mpp/plan/analyze/IPartitionFetcher.java | 9 +
.../plan/analyze/StandalonePartitionFetcher.java | 13 +-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 2 +-
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 7 -
.../db/mpp/plan/analyze/cache/PartitionCache.java | 2 +-
.../db/mpp/plan/execution/QueryExecution.java | 65 +-
.../mpp/plan/execution/config/ConfigExecution.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 212 +-
.../executor/StandaloneConfigTaskExecutor.java | 2 +-
.../config/metadata/GetTimeSlotListTask.java | 7 +-
.../config/metadata/ShowFunctionsTask.java | 15 +-
.../plan/execution/memory/MemorySourceHandle.java | 5 +
.../memory/StatementMemorySourceVisitor.java | 27 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 689 +-
.../db/mpp/plan/parser/StatementGenerator.java | 45 +-
.../plan/planner/LocalExecutionPlanContext.java | 18 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 5 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 20 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 191 +-
.../db/mpp/plan/planner/SubPlanTypeExtractor.java | 29 +
.../planner/distribution/DistributionPlanner.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 118 +
.../plan/planner/distribution/SourceRewriter.java | 293 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 57 +
.../db/mpp/plan/planner/plan/node/PlanNode.java | 16 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadSingleTsFileNode.java | 4 +-
.../write/CreateAlignedTimeSeriesNode.java | 6 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 5 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 6 +-
.../plan/node/metedata/write/MeasurementGroup.java | 60 +-
.../plan/node/process/VerticallyConcatNode.java | 103 +
.../plan/node/write/InsertMultiTabletsNode.java | 2 +-
.../plan/planner/plan/node/write/InsertNode.java | 45 +-
.../planner/plan/node/write/InsertRowNode.java | 6 +-
.../planner/plan/node/write/InsertRowsNode.java | 2 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 2 +-
.../planner/plan/node/write/InsertTabletNode.java | 28 +-
.../planner/plan/parameter/AggregationStep.java | 45 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 2 +-
.../scheduler/FixedRateFragInsStateTracker.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 26 +-
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 9 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 33 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 89 +-
.../crud/InsertMultiTabletsStatement.java | 2 +-
.../plan/statement/crud/InsertRowStatement.java | 4 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 3 +-
.../plan/statement/crud/InsertRowsStatement.java | 2 +-
.../mpp/plan/statement/crud/InsertStatement.java | 1 -
.../plan/statement/crud/InsertTabletStatement.java | 17 +-
.../plan/statement/crud/LoadTsFileStatement.java | 12 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +
.../metadata/DeleteStorageGroupStatement.java | 18 +-
.../statement/metadata/GetRegionIdStatement.java | 30 +-
.../statement/metadata/ShowTriggersStatement.java | 6 -
...izableRowRecordListBackedMultiColumnWindow.java | 12 +
...SerializableTVListBackedSingleColumnWindow.java | 12 +
.../dag/adapter/EmptyRowIterator.java | 40 +
.../dag/column/unary/InColumnTransformer.java | 40 +-
.../intermediate/ConstantIntermediateLayer.java | 3 +-
.../MultiInputColumnIntermediateLayer.java | 21 +-
...InputColumnMultiReferenceIntermediateLayer.java | 20 +-
...nputColumnSingleReferenceIntermediateLayer.java | 20 +-
.../transformation/dag/util/TransformUtils.java | 8 +-
.../influxdb/meta/NewInfluxDBMetaManager.java | 2 +-
.../protocol/rest/filter/AuthorizationFilter.java | 8 +-
.../rest/handler/AuthorizationHandler.java | 4 +-
.../rest/handler/RequestValidationHandler.java | 14 +-
.../rest/handler/StatementConstructionHandler.java | 2 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 6 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 6 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 126 +-
.../db/qp/logical/sys/CreateTriggerOperator.java | 92 -
.../db/qp/logical/sys/DropTriggerOperator.java | 50 -
.../db/qp/logical/sys/StartTriggerOperator.java | 50 -
.../db/qp/logical/sys/StopTriggerOperator.java | 50 -
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 16 -
.../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 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 166 -
.../iotdb/db/qp/physical/sys/DropTriggerPlan.java | 102 -
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 3 +-
.../iotdb/db/qp/physical/sys/StartTriggerPlan.java | 102 -
.../iotdb/db/qp/physical/sys/StopTriggerPlan.java | 102 -
.../db/qp/physical/sys/UnsetTemplatePlan.java | 3 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 3467 ----------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 51 +-
.../db/query/control/QueryResourceManager.java | 38 +-
.../iotdb/db/query/control/SessionManager.java | 4 +-
.../control/clientsession/IClientSession.java | 2 +-
.../db/query/dataset/ShowTimeSeriesResult.java | 17 +-
.../groupby/GroupByWithValueFilterDataSet.java | 88 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 106 +-
.../db/query/executor/AggregationExecutor.java | 124 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 69 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 115 +-
.../db/query/executor/RawDataQueryExecutor.java | 138 +-
.../pool/RawQueryReadTaskPoolManagerMetrics.java | 8 +-
.../query/timegenerator/ServerTimeGenerator.java | 28 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 18 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 62 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 6 +-
.../db/service/DataNodeServerCommandLine.java | 12 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 19 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 5 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 24 +-
.../org/apache/iotdb/db/service/RPCService.java | 8 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 6 +-
.../iotdb/db/service/RegionMigrateService.java | 384 +-
.../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 | 49 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 41 +-
.../metrics/recorder/CacheMetricsRecorder.java | 2 +-
.../recorder/CompactionMetricsRecorder.java | 8 +-
.../InternalServiceThriftHandlerMetrics.java | 9 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 6 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 37 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 139 +-
.../service/thrift/impl/DataNodeRegionManager.java | 6 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 2 +-
.../db/service/thrift/impl/TSServiceImpl.java | 142 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 31 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 12 +-
.../apache/iotdb/db/sync/common/LocalSyncInfo.java | 2 +-
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 2 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 6 +-
.../apache/iotdb/db/sync/pipedata/PipeData.java | 33 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 6 +-
.../db/sync/pipedata/load/DeletionLoader.java | 88 +
.../iotdb/db/sync/pipedata/load/ILoader.java | 49 +
.../iotdb/db/sync/pipedata/load/TsFileLoader.java | 85 +
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 3 +-
.../db/sync/receiver/load/DeletionLoader.java | 88 -
.../iotdb/db/sync/receiver/load/ILoader.java | 49 -
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 85 -
.../db/sync/sender/pipe/ExternalPipeSink.java | 20 -
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 23 +-
.../db/sync/transport/client/ISyncClient.java | 7 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 45 +-
.../db/sync/transport/client/SenderManager.java | 168 +-
.../sync/transport/client/SyncClientFactory.java | 41 +-
.../db/sync/transport/server/ReceiverManager.java | 109 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 10 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 10 +-
.../apache/iotdb/db/tools/schema/MLogParser.java | 2 +-
.../db/tools/schema/SchemaFileSketchTool.java | 12 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 6 +-
.../db/tools/validate/TsFileValidationTool.java | 7 +-
.../iotdb/db/tools/vis/TsFileExtractVisdata.java | 170 -
.../main/java/org/apache/iotdb/db/tools/vis/vis.m | 290 -
.../trigger/service/TriggerManagementService.java | 15 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 12 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 24 -
.../org/apache/iotdb/db/utils/ThreadUtils.java | 3 +-
.../apache/iotdb/db/utils/TimePartitionUtils.java | 16 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 20 +-
.../db/wal/allocation/FirstCreateStrategy.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 4 +-
.../iotdb/db/wal/exception/WALException.java | 6 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 26 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 +-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 2 +-
.../iotdb/db/auth/AuthorizerManagerTest.java | 4 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 4 +-
.../apache/iotdb/db/engine/StorageEngineTest.java | 71 +
.../iotdb/db/engine/StorageEngineV2Test.java | 71 -
.../engine/compaction/AbstractCompactionTest.java | 208 +-
.../engine/compaction/CompactionSchedulerTest.java | 1 -
.../compaction/CompactionTaskComparatorTest.java | 4 +-
.../compaction/CompactionTaskManagerTest.java | 74 +-
.../compaction/FastAlignedCrossCompactionTest.java | 6689 ++++++++++++++++++++
.../FastCrossCompactionPerformerTest.java | 3802 +++++++++++
.../FastInnerCompactionPerformerTest.java | 1824 ++++++
.../FastNonAlignedCrossCompactionTest.java | 6655 +++++++++++++++++++
.../ReadPointCompactionPerformerTest.java | 929 ++-
.../cross/CrossSpaceCompactionValidationTest.java | 143 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 10 +-
.../inner/FastCompactionPerformerAlignedTest.java | 652 ++
.../FastCompactionPerformerNoAlignedTest.java | 946 +++
.../compaction/inner/InnerSeqCompactionTest.java | 1061 ----
.../InnerSeqCompactionWithFastPerformerTest.java | 1088 ++++
...nerSeqCompactionWithReadChunkPerformerTest.java | 1055 +++
.../inner/InnerSpaceCompactionExceptionTest.java | 26 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 810 ---
.../InnerUnseqCompactionWithFastPerformerTest.java | 805 +++
...rUnseqCompactionWithReadPointPerformerTest.java | 807 +++
.../ReadChunkCompactionPerformerAlignedTest.java | 36 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 48 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 7 +-
.../SizeTieredCompactionRecoverTest.java | 48 +-
.../SizeTieredCompactionSelectorTest.java | 4 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 33 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 26 +-
.../recover/SizeTieredCompactionRecoverTest.java | 38 +-
.../compaction/utils/TsFileGeneratorUtils.java | 257 +
.../db/engine/snapshot/IoTDBSnapshotTest.java | 8 +-
.../db/engine/storagegroup/DataRegionTest.java | 122 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 19 +-
.../engine/storagegroup/TsFileProcessorTest.java | 482 ++
.../engine/storagegroup/TsFileProcessorV2Test.java | 482 --
.../iotdb/db/metadata/SchemaAdvancedTest.java | 25 -
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 1287 +---
.../org/apache/iotdb/db/metadata/TemplateTest.java | 307 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 7 +-
.../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 | 81 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 86 +-
.../plan/SchemaRegionPlanCompatibilityTest.java | 57 +-
.../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 | 20 +-
.../operator/RawDataAggregationOperatorTest.java | 41 +-
.../execution/operator/SeriesScanOperatorTest.java | 29 +-
.../execution/operator/TimeJoinOperatorTest.java | 115 +-
.../operator/VerticallyConcatOperatorTest.java | 197 +
.../operator/schema/CountMergeOperatorTest.java | 8 +-
.../operator/schema/SchemaCountOperatorTest.java | 10 +-
.../schema/SchemaQueryScanOperatorTest.java | 23 +-
.../schedule/DefaultDriverSchedulerTest.java | 3 +-
.../schedule/queue/L2PriorityQueueTest.java | 20 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 6 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 2 +-
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 6 +
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 2 +-
.../mpp/plan/analyze/QueryTimePartitionTest.java | 565 ++
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 3 +
.../distribution/AggregationDistributionTest.java | 288 +-
.../distribution/DistributionPlannerBasicTest.java | 126 +-
.../distribution/NoDataRegionPlanningTest.java | 37 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 498 +-
.../plan/node/write/WritePlanNodeSplitTest.java | 34 +-
.../plan/scheduler/StandaloneSchedulerTest.java | 6 +-
.../db/protocol/rest/IoTDBRestServiceTest.java | 4 +
.../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 +
.../db/query/dataset/ShowTimeSeriesResultTest.java | 4 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 475 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 41 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 14 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 380 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 12 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 45 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 18 +-
.../db/utils/datastructure/PrecisionTest.java | 143 -
.../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
service-rpc/pom.xml | 2 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 10 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 8 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 307 +-
session/pom.xml | 2 +-
.../java/org/apache/iotdb/session/Session.java | 15 +-
.../org/apache/iotdb/session/SessionDataSet.java | 2 +-
...tdb-rest.properties => iotdb-common.properties} | 0
site/pom.xml | 66 +-
site/src/main/.vuepress/config.js | 710 ++-
site/src/main/.vuepress/redirects | 3 +-
site/src/main/.vuepress/theme/components/Page.vue | 36 +-
site/src/main/package.json | 9 +-
spark-iotdb-connector/pom.xml | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 7 +-
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 7 +-
thrift-commons/pom.xml | 2 +-
thrift-commons/src/main/thrift/common.thrift | 1 +
thrift-confignode/pom.xml | 2 +-
.../src/main/thrift/confignode.thrift | 38 +-
thrift-influxdb/pom.xml | 2 +-
thrift-iot-consensus/pom.xml | 67 +
.../src/main/thrift/iotconsensus.thrift | 126 +
thrift-multi-leader-consensus/pom.xml | 67 -
.../src/main/thrift/mutlileader.thrift | 126 -
thrift/pom.xml | 2 +-
thrift/src/main/thrift/client.thrift | 11 +-
thrift/src/main/thrift/datanode.thrift | 11 +-
trigger-api/pom.xml | 2 +-
tsfile/README.md | 2 +-
tsfile/pom.xml | 2 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../tsfile/common/constant/TsFileConstant.java | 3 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 15 +-
.../file/metadata/enums/CompressionType.java | 21 +-
.../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 +-
udf-api/pom.xml | 2 +-
.../org/apache/iotdb/udf/api/access/RowWindow.java | 3 +-
.../iotdb/udf/api/collector/PointCollector.java | 2 +
.../strategy/SessionTimeWindowAccessStrategy.java | 10 +-
zeppelin-interpreter/pom.xml | 2 +-
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 14 +-
1433 files changed, 93050 insertions(+), 74144 deletions(-)
diff --cc consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/IndexController.java
index 0000000000,e5242c6611..54325cd2e1
mode 000000,100644..100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/IndexController.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/IndexController.java
@@@ -1,0 -1,176 +1,177 @@@
+ /*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+ package org.apache.iotdb.consensus.iot.logdispatcher;
+
+ import org.apache.iotdb.commons.utils.TestOnly;
+
+ import org.apache.commons.io.FileUtils;
+ import org.slf4j.Logger;
+ import org.slf4j.LoggerFactory;
+
+ import javax.annotation.concurrent.ThreadSafe;
+
+ import java.io.File;
+ import java.io.IOException;
+ import java.nio.file.Files;
+ import java.util.concurrent.locks.ReentrantReadWriteLock;
+
+ /** An index controller class to balance the performance degradation of frequent disk I/O. */
+ @ThreadSafe
+ public class IndexController {
+
+ private final Logger logger = LoggerFactory.getLogger(IndexController.class);
-
++ private static final String FILE_NAME_INDEX_SPLITTER = "-";
+ private long lastFlushedIndex;
+ private long currentIndex;
+
+ private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
+
+ private final String storageDir;
+ private final String prefix;
+ private final long initialIndex;
+
+ private final long checkpointGap;
+
+ public IndexController(String storageDir, String prefix, long initialIndex, long checkpointGap) {
+ this.storageDir = storageDir;
- this.prefix = prefix + '-';
++ this.prefix = prefix + FILE_NAME_INDEX_SPLITTER;
+ this.checkpointGap = checkpointGap;
+ this.initialIndex = initialIndex;
+ restore();
+ }
+
+ public long updateAndGet(long index) {
+ try {
+ lock.writeLock().lock();
+ long newCurrentIndex = Math.max(currentIndex, index);
+ logger.debug(
+ "update index from currentIndex {} to {} for file prefix {} in {}",
+ currentIndex,
+ newCurrentIndex,
+ prefix,
+ storageDir);
+ currentIndex = newCurrentIndex;
+ checkPersist();
+ return currentIndex;
+ } finally {
+ lock.writeLock().unlock();
+ }
+ }
+
+ public long getCurrentIndex() {
+ try {
+ lock.readLock().lock();
+ return currentIndex;
+ } finally {
+ lock.readLock().unlock();
+ }
+ }
+
+ @TestOnly
+ public long getLastFlushedIndex() {
+ return lastFlushedIndex;
+ }
+
+ private void checkPersist() {
+ if (currentIndex - lastFlushedIndex >= checkpointGap) {
+ persist();
+ }
+ }
+
+ private void persist() {
+ long flushIndex = currentIndex - currentIndex % checkpointGap;
+ File oldFile = new File(storageDir, prefix + lastFlushedIndex);
+ File newFile = new File(storageDir, prefix + flushIndex);
+ try {
+ if (oldFile.exists()) {
+ FileUtils.moveFile(oldFile, newFile);
+ logger.info(
+ "version file updated, previous: {}, current: {}",
+ oldFile.getAbsolutePath(),
+ newFile.getAbsolutePath());
+ } else {
+ // In the normal state, this branch should not be triggered.
+ // During the DataNode removing stage, the version file towards removing peer may be deleted
+ // before all the async operations returns. We needn't add some sync operation here
+ // because it won't infect the correctness
+ logger.info(
+ "failed to flush sync index because previous version file {} does not exists. "
+ + "It may be caused by the target Peer is removed from current group. target file is {}",
+ oldFile.getAbsolutePath(),
+ newFile.getAbsolutePath());
+ }
+
+ lastFlushedIndex = flushIndex;
+ } catch (IOException e) {
+ logger.error("Error occurred when flushing next version", e);
+ }
+ }
+
+ private void restore() {
+ File directory = new File(storageDir);
+ File[] versionFiles = directory.listFiles((dir, name) -> name.startsWith(prefix));
+ File versionFile;
+ if (versionFiles != null && versionFiles.length > 0) {
+ long maxVersion = 0;
+ int maxVersionIndex = 0;
+ for (int i = 0; i < versionFiles.length; i++) {
- long fileVersion = Long.parseLong(versionFiles[i].getName().split("-")[1]);
++ String[] splits = versionFiles[i].getName().split(FILE_NAME_INDEX_SPLITTER);
++ long fileVersion = Long.parseLong(splits[splits.length - 1]);
+ if (fileVersion > maxVersion) {
+ maxVersion = fileVersion;
+ maxVersionIndex = i;
+ }
+ }
+ lastFlushedIndex = maxVersion;
+ for (int i = 0; i < versionFiles.length; i++) {
+ if (i != maxVersionIndex) {
+ try {
+ Files.delete(versionFiles[i].toPath());
+ } catch (IOException e) {
+ logger.error(
+ "Delete outdated version file {} failed", versionFiles[i].getAbsolutePath(), e);
+ }
+ }
+ }
+ currentIndex = lastFlushedIndex;
+ } else {
+ currentIndex = initialIndex;
+ versionFile = new File(directory, prefix + initialIndex);
+ try {
+ Files.createFile(versionFile.toPath());
+ lastFlushedIndex = initialIndex;
+ } catch (IOException e) {
+ // TODO: (xingtanzjr) we need to handle the situation that file creation failed.
+ // Or the dispatcher won't run correctly
+ logger.error("Error occurred when creating new file {}", versionFile.getAbsolutePath(), e);
+ }
+ }
+ }
+
+ public void cleanupVersionFiles() throws IOException {
+ File directory = new File(storageDir);
+ File[] versionFiles = directory.listFiles((dir, name) -> name.startsWith(prefix));
+ if (versionFiles != null && versionFiles.length > 0) {
+ for (File versionFile : versionFiles) {
+ Files.delete(versionFile.toPath());
+ }
+ }
+ }
+ }