You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2022/03/22 09:41:34 UTC
[iotdb] branch rocksdb/dev updated (1589801 -> 4bd3450)
This is an automated email from the ASF dual-hosted git repository.
jianyun pushed a change to branch rocksdb/dev
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
discard 1589801 fix bug where storage groups were displayed incorrectly by show devices
discard 83da91c fix bug of the incorrect number by counting nodes
discard 1599164 print exception info
discard 3cbf605 Merge branch 'rocksdb/dev' of v.src.corp.qihoo.net:xt_hadoop/iotdb into rocksdb/dev
discard 4a39a9e support show child
discard ccd5604 Fix the bug that path in PathNotExistException is incomplete when do insert
discard 95d746c delete unused method
discard 2b12d68 update
discard 25421c3 fix npe when query aligned timeseries
discard a068a41 fix bug of creating aligned timeseries
discard 16ec277 fix npe when init sgMNode
discard a76b5f1 [rocksdb] fix build break
discard e1fb08f [RocksDB] code refine
discard 7f181c0 use max value replace magic number
discard c9e84b8 fix the bug of deleting storage groups
discard 01736f1 update exception info
discard 1995926 fix a bug where storage groups could not be created automatically
discard 115c5a5 modify data transfer task
discard 126a31a remove test info
discard 9ae48a2 fix a bug in wildcard processing
discard 399452f Fix a bug where the result is invalid
discard a543966 fix npe when getBelongedToSG
discard a54d080 fix some bugs
discard 61d9edd spotless apply
discard 40d09a4 [rocksdb] fix the bug that upsert alias fail, refine delete timeseries logic
discard c1d4303 [RcoksDB] refine delete timeseries logic
discard 311ad36 fix incorrect storagegroup name in show timeseries
discard 0f326e9 implement show devices
discard 535dd2c update the exception information in the log
discard 769ce5a incorrect response to set storage group
discard 9640cf1 fix timeout issue when obtaining lock
discard 4fa0f53 change the parameter type in function
discard a809ae3 update the way of getting measurementPath
discard bfb0124 support showTimeseries
discard aeb546b update the method of getting the schema
discard c2d9d58 [rocksdb] refine key exist check logic
discard f15a6d1 spotless apply
discard 06fe60e1 [rocksdb] complete data transfer
discard e6e7bc0 [rocksdb] complete metadata transfer from mmanage to mrockdb
discard 4821372 fix bug of full path query
discard 68f9c0d fix a bug where the number of nodes is incorrect
discard a63cc7d traverser changed to concurrency
discard 4468993 updated the matched interface
discard abc659c Merge branch 'rocksdb/dev' of v.src.corp.qihoo.net:xt_hadoop/iotdb into rocksdb/dev
discard 5d015a1 use wildcard to query
omit 3fc653a [rocksdb] refine some query interfaces
omit 482930a fix issue with calculating length
omit 4ade7de replace multi wildcard to single
omit 7349893 Support * path pattern match
omit caa4b5e [RocksDB] fix the bug that update ttl does't work correctly
omit 8e6d64f [RocksDB] improve insert data process
omit 32c69ca fix the bug that StorageGroup won't create automactically when do insert
omit cf56223 [RocksDB] update method call as some method signature changed
omit 6a9f8b8 update
omit 2257a85 [RocksDB] Change MManager in IoTDB to IMetaManager interface
omit 13b88d1 implement and update RMNode interfaces
omit a6ef1f4 [RocksDB] support metadata transfer
omit 1954213 implements RMNode
omit 14fa741 add unit test and fix bug of matching path
omit 29858a0 add belongedTo
omit b9c3e9b change MNode to RMNode
omit 6fcb62e fix bug of getting path,and add the method of belonged to specified node type
omit 0dcd959 Lock whole write of timeseries while delete by storage group
omit 34a8a02 [RocksDB] add delete timeseries and delete storage group support
omit 0db489b implement prefix matching related interface
omit 24415ce implements getMeasurementPaths
omit 3557e89 fix prefixed match
omit e810fb2 change the node type to char and fix bugs of using getLevelName
omit 52d3aa7 [rocksdb] optimize lock
omit 349c093 [rocksdb] implement tags and attributes update
omit 16c6847 [rcoskdb] add mnode classes for rocksdb
omit a2fad19 update
omit e33e6dd add comment and implements some interface
omit a7c3a56 apply spotless
omit 27133e8 merge forQuery to manager
omit 0a2a0a6 merge codes
omit a3bf27e [rocksdb] add UT and fix write bugs
omit bd1996a add some unit tests for rocksdb write
omit 67edffb [RocksDB] add integration test
omit b7f6c8d change the way of parsing key
omit 9950b36 remove some useless code
omit 68a5924 Support aligned timeseries create
omit f40d530 create aligned timeseries
omit d954808 complete write normal timeseries node logic
omit 5f99e75 implement write - 1
omit 1ef7940 get nodeType by key
omit 8079a44 add name parser and query utils
omit 933ba8c update
omit 7e3f7ed Rewrite part of the query interface
omit eb98fa1 Apply new value definition
omit 3271a75 Fix build error
omit 8664541 add common constants
omit 79e05b3 extract IMetaManager for MManager and init rocksdb module
add e763438 [IOTDB-2585]Fix Cross space compaction selector of not closed file (#5102)
add d0389ce [IOTDB-2594][Metric] fix implement of histogram of dropwizard to UniformReservoir(#5109)
add 762cd4d [IOTDB-2593] Fix cannot insert data using JDK17 (#5106)
add 44b76ae [IOTDB-2591] fix doc of using OIDC as the authority authentication service (#5108)
add 9c68af9 [IOTDB-2600] Ban inserting duplicated columns in one row (#5111)
add 7f2978f fix default max_thrift_frame_size to 512M (#5112)
add 2ac29f5 [IOTDB-2599] Fix example of insertAlignedTablet is incorrect (#5114)
add 45c679b Fix invalid URL in README (#5117)
add efa14ec [IOTDB-2607] Fix session example error (#5119)
add 84bc8de stop scheduler pool when deleting storage group (#5120)
add 238f230 [IOTDB-2581] Fix compaction recover in 0.13.0 is not compatible with 0.12.5 (#5099)
add 95bb194 [IOTDB-2604] batch size is invalid in import-csv tool (#5115)
add cb7e382 Rearranged UDF Library docs (#5079)
add b954d0f [IOTDB-2592] An exception occurred when using TsFile read API (#5105)
add 6e983ee fix UserGuide.EcosystemIntegration.FAQ.2.A (#5126)
add 3f915d0 [IOTDB-2578]Fix cross space compaction recover and log read compatible with 0.12 (#5122)
add 92ad9f2 [IOTDB-2620] Unrecognizable operator type (SHOW) for AuthorityChecker (#5129)
add e44835f [IOTDB-2625] Fix election deadlock when updating partition table (#5131)
add 20df9c8 [IOTDB-2578]Fix cross space compaction recover and log read compatible with 0.12 (#5133)
add 2bd7eb7 fix not set compactionCandidate to false when start compacting(#5127)
add 2ab97b4 [IOTDB-2595] add buildin UDTF ON_OFF (#5124)
add 9d33535 [IOTDB-2632] Set compaction_write_throughput_mb_per_sec to 16 by default (#5138)
add ebd7ae1 Bump jjwt-impl from 0.10.7 to 0.10.8 (#5143)
add 2bb33ae Bump jaxb-impl from 2.3.0 to 2.3.6 (#5141)
add 091c14a [IOTDB-2625] Optimize RaftMember initialization (#5144)
add 6fe4b91 Fix website compile error (#5149)
add 2bddbf0 [IOTDB-2647] UDF Library in Apache Way (#5153)
add 07fb542 [IOTDB-1807] Compatibility of Apache IoTDB with InfluxDB - Parse InfluxQL (#4535)
add 9f9dc19 [IOTDB-2634] Fix batch script exit directly from cmd.exe (#5158)
add e8462e4 [IOTDB-2638][Metric] add features into metric module (#5147)
add 479c8d7 [IOTDB-2653] Fix "overlapped data should be consumed first" occurs when executing query (#5161)
add 1cfbd48 [IOTDB-2597] Add four functions to find suitable intervals (#5136)
add edd4d5c [IOTDB-2520] list user privilege root returns empty (#5167)
add a1627f3 [IOTDB-2579] fixed mvn clean can not clean folder "grafana-plugin" (#5103)
add 107cdc6 [IOTDB-2668] Fix align by device with aligned path bug (#5169)
add d2c21e3 [IOTDB-2633]Unification of compaction log formats (#5157)
add 6d15dd0 [IOTDB-2657] Fix "NumberFormatException occurs when type infer for value with whitespace" (#5171)
add f9b16cd [IOTDB-2693] Fix compaction recover bug (#5178)
add c788726 [IOTDB-2691][Metric] update metric doc (#5172)
add e4af0c0 [IOTDB-2654] Alias doesn't show when using group by level (#5163)
add a5f1a16 [Doc] Update download links for release v0.12.5 (#5180)
add 48ad032 [IOTDB-2694] fix without null any bug in raw query with value filter (#5179)
add c388dfb [IOTDB-2596] Add buildin UDTF in_range (#5146)
add b98d25f [IOTDB-2692] Fix compaction exception caused by deleted timeseries (#5173)
add 7664600 [IOTDB-2357] Support create timeseries interface with tags in python client (#5181)
add b2d060c [IOTDB-2651] Fix write performance deteriorates severely (#5170)
add 5286d42 [IOTDB-2697] Add metadata modification validation before accelerating query by statistics (#5182)
add 1584871 [IOTDB-2680] Fix too many open files exception (#5177)
add 6c0f35e [IOTDB-2705] Separate CQ persistence from MLog (#5187)
add 270fcc3 [IOTDB-2703] Support insert ndarray Tablet in Python API (#5185)
add 064010c [IOTDB-2707] Update Python API userguide (#5189)
add 196d6a9 [IOTDB-2712]Remove reading merge.mods in inner compaction recover (#5186)
add f133c92 [IOTDB-2598] Enable append operation on template after setting and using (#5110)
add d16cea4 [IOTDB-2711] Fix memory allocation deadlock by concurrent snapshot requests (#5195)
add eff3479 Update release note
add 9358c92 update docker and jdbc info
add 3cb08ef update 0.12.5 release note
add b87ea56 [IOTDB-2735] Remove the redundant code in Tablet (#5212)
add 9496027 [IOTDB-2728] fix influxdb-protocol yaml (#5206)
add 64fa140 [IOTDB-2732] Reject inserting an invalid infinity float value (#5210) (#5217)
add fbbc115 Rel/0.13-update UserGuide about Administration (#5218)
add 2fddb64 [IOTDB-2734] Correct result type name in ResultMetadata (#5213) (#5221)
add 31dc01c [IOTDB-2742] Hide IDTable configurations (#5236)
add 2662204 Modify cross priority param to upper case in doc (#5243)
add 963b754 [To rel/0.13][IOTDB-2614]Fix inserting tablet with null value in TsFileWriter (#5245)
add b0d0af3 [IOTDB-2723] Fix sequence inner space compaction loses data (#5249)
add 8ce9a7e Enhance check statement before writing mlog (#5252)
add a90f490 [IOTDB-1593] Fix generated files in client-py have unapproved license (#5257)
add fbd7963 [To rel/0.13][IOTDB-2749]Fix isPathExist check on MTree (#5259)
add 14c0bf7 add 0.13.0 dockerfile
add 0d8e3fb Fix flink-tsfile-connector error
add a923380 extract IMetaManager for MManager and init rocksdb module
add e5b8fda add common constants
add cd55bd5 Fix build error
add 49544c2 Apply new value definition
add 07229c9 Rewrite part of the query interface
add df6cfc9 update
add 57f6004 add name parser and query utils
add fd88f5d get nodeType by key
add 9593763 implement write - 1
add bac1af6 complete write normal timeseries node logic
add f2512b4 create aligned timeseries
add 9bb3e3a Support aligned timeseries create
add 0a4d64c remove some useless code
add e3e1889 change the way of parsing key
add 570e082 [RocksDB] add integration test
add e877f0b add some unit tests for rocksdb write
add 70c6fef [rocksdb] add UT and fix write bugs
add da827eb merge codes
add 7c67ee4 merge forQuery to manager
add a7cc525 apply spotless
add 4c5b3c9 add comment and implements some interface
add 264f212 update
add 102322c [rcoskdb] add mnode classes for rocksdb
add e6d4afa [rocksdb] implement tags and attributes update
add d98e532 [rocksdb] optimize lock
add d2f26b1 change the node type to char and fix bugs of using getLevelName
add aff6b46 fix prefixed match
add 8f1d765 implements getMeasurementPaths
add c7add69 implement prefix matching related interface
add 51c5f0f [RocksDB] add delete timeseries and delete storage group support
add 0266fce Lock whole write of timeseries while delete by storage group
add 236c31a fix bug of getting path,and add the method of belonged to specified node type
add 020ba8f change MNode to RMNode
add f270715 add belongedTo
add f0aae29 add unit test and fix bug of matching path
add ea41226 implements RMNode
add b19ea49 [RocksDB] support metadata transfer
add 8247a2a implement and update RMNode interfaces
add 5714360 [RocksDB] Change MManager in IoTDB to IMetaManager interface
add 4fc7621 update
add c39ba7b [RocksDB] update method call as some method signature changed
add 36f33bb fix the bug that StorageGroup won't create automactically when do insert
add 50ba5e3 [RocksDB] improve insert data process
add 9917269 [RocksDB] fix the bug that update ttl does't work correctly
add 1397077 Support * path pattern match
add defddc5 replace multi wildcard to single
add 137bd56 fix issue with calculating length
add 5bd8d72 use wildcard to query
add 5bc2983 [rocksdb] refine some query interfaces
add 0d0ea99 updated the matched interface
add 39acb47 traverser changed to concurrency
add 5bd78e7 fix a bug where the number of nodes is incorrect
add 8de94d0 fix bug of full path query
add d21ba8c [rocksdb] complete metadata transfer from mmanage to mrockdb
add 8b07856 [rocksdb] complete data transfer
add 7f295bf spotless apply
add 8c4fe12 [rocksdb] refine key exist check logic
add 4b54e2c update the method of getting the schema
add b037f43 support showTimeseries
add 4596420 update the way of getting measurementPath
add a290872 change the parameter type in function
add c0125cf fix timeout issue when obtaining lock
add bd7b7fa incorrect response to set storage group
add e36a52b update the exception information in the log
add 23854f8 implement show devices
add efc1d8f fix incorrect storagegroup name in show timeseries
add 9fd80db [RcoksDB] refine delete timeseries logic
add 90217e6 [rocksdb] fix the bug that upsert alias fail, refine delete timeseries logic
add 6b9fc11 spotless apply
add a0ee06e fix some bugs
add 60aa088 fix npe when getBelongedToSG
add fc14440 Fix a bug where the result is invalid
add f81925a fix a bug in wildcard processing
add 186a1d9 remove test info
add 97e7b5e modify data transfer task
add 6a27c7e apply string intern for device String
add 30c5287 Fix the bug that some crashed tsfile cause storage group processor recover fail
add aa769a5 [Test][Temp] enhance memtable flush task performance log
add 19beb7f [360] turn off thrift connection reset log
add 5209612 fix code caused by rebasing latest 0.13
add d913fb6 enhance ut
add ecd46f3 fix a bug where storage groups could not be created automatically
add 762d91c update exception info
add 136ced9 fix the bug of deleting storage groups
add c6153f5 use max value replace magic number
add f86af8e [RocksDB] code refine
add b988bf1 fix npe when init sgMNode
add 7d8d57b Fix the bug that path in PathNotExistException is incomplete when do insert
add d818290 fix bug of creating aligned timeseries
add 8ad3882 fix npe when query aligned timeseries
add 862c00b update
add bf5b716 [ToMaster] Add RamUsageEstimatorV2 class to optimize performance
add 664086c delete unused method
add e62edec [To-Mater] optimize restart performance
add 1fc712e [To-Master] fix the bug that recover tsfile may throw ArithmeticException
add b3ba428 [To-Master] use weakhashmap replace string intern
add 7df4225 [To-Master][Draft] refine startup process
add d8d2db3 support show child
add 209dea5 print exception info
add ee215d4 fix bug of the incorrect number by counting nodes
add b88c4e6 [To-Master] remove synchronize block for synchronized map
add 76d85e6 Revert "[To-Master] remove synchronize block for synchronized map"
add 2c62388 Revert "[To-Master] use weakhashmap replace string intern"
add 332e46e Optimize rocksdb
add c0f0d8a [To-Master] remove useless string intern for better performance
add 2232ff6 [IOTDB-2543] Support all time filters in last query (#5063)
add fd38193 [IOTDB-2582]Enable reading chunk by timestamp (#5100)
add 0248c3c Bump hive-storage-api from 2.6.0 to 2.6.1 (#5193)
add e31f129 [IOTDB-2721]Fix ChunkReaderTest CI (#5201)
add 4a078dc [IOTDB-2602] Add the new feature of the null value filter to support filtering based on partial columns (#5184)
add f75243c [IOTDB-2728] fix influxdb-protocol yaml (#5206)
add 5aa3f53 [IOTDB-2461] Zigzag Encoding for INT 32 and INT 64 (#4939)
add 32cd145 [IOTDB-2461] Add cpp and sql support for ZIGZAG encoding (#5207)
add 49bd401 Construct basic framework of ConfigNode (#5199)
add a95558e [IOTDB-2673] Implement the consensus layer basic framework (#5204)
add 08e9d34 change master version to 0.14.0-SNAPSHOT (#5209)
add c3e49a8 [IOTDB-2735] Remove the redundant code in Tablet (#5211)
add b05a81f [IOTDB-2732] Reject inserting an invalid infinity float value (#5210)
add 10b15ea [IOTDB-2734] Correct result type name in ResultMetadata (#5213)
add 2a5d371 Update dependabot to check rel/0.13 (#5203)
add 83ab2f6 Fix .github/dependabot.yml (#5222)
add 272d5db Update UserGuide descriptions (#5219)
add 1460bb7 [IOTDB-2739] Update v0.13 upgrade user guide (#5234)
add 0d2cad6 Bump org.slf4j.version from 1.7.32 to 1.7.36 (#5225)
add 7ce67a1 [IOTDB-2742] Hide IDTable configurations (#5238)
add b3147de fix write with null value in tsFileWriter (#5237)
add 30cd1c0 Revert "fix write with null value in tsFileWriter (#5237)" (#5246)
add a88b6b5 Modify cross priority param to upper case in doc (#5242)
add c3d34b6 [IOTDB-2590] Group by time query: support time sliding step less than the time interval (#5196)
add c2a2acd [IOTDB-2736] DELETE_STORAGE_GROUP can not be granted to user (reporting 401) (#5233)
add 9f04de9 [IOTDB-2723] Fix sequence inner space compaction lose data
add 2f78450 [IOTDB-2614]Fix inserting tablet with null value in TsFileWriter (#5244)
add 919532a Bump jacoco-maven-plugin from 0.8.5 to 0.8.7 (#5194)
add 74189ee Bump maven-bundle-plugin from 5.1.1 to 5.1.4 (#5192)
add 6347db7 [IOTDB-2725] MPP query engine interface definition (#5250)
add 1ff6db9 [IOTDB-2524] Aligned Timeseries support tags and attributes (#5191)
add 5a88650 [IOTDB-2685] Create and start config node (#5247)
add 5edf9e9 [IOTDB-2750] Enhance check statement before writing mlog (#5253)
add 34b480d [IOTDB-2737] Fix ID Table compaction bug (#5214)
add 0426e72 [IOTDB-1593] Fix generated files in client-py have unapproved license (#5258)
add 37dae90 add setNoMoreTsBlocks(), close() and abort() methods in SinkHandle interface (#5256)
add d29ef70 [IOTDB-2749]Fix isPathExist check on MTree (#5260)
add 3c22c12 [IOTDB-2675][IOTDB-2524] Manage Metadata by Storage Group && Support alias, tag and attributes on aligned timeseries (#5205)
add 3deadae [IOTDB-2752] reconstructing the start and stop command (#5261)
add 60dc2d4 Open idtable configuration (#5269)
add 2058744 [IOTDB-2675] Rename MManager to SchemaEngine and SGMManager to SchemaRegion (#5265)
add 31108de [IOTDB-2755] Fix tests of flink-tsfile-connector not executed in CI (#5268)
add 842b868 Add Concurrency Control On CI (#5262)
add d29bc89 [IOTDB-2754] SessionPool auto redirect IoTDB instance (#5267)
add dc38c7a [IOTDB-2609] A new lossy encoding method based on frequency domain (#5118)
add e06b9e1 [IOTDB-2733] Supplement the doc of compiling source code (#5276)
add b3fff9f [IOTDB-2764] Refine the consensus layer framework and add examples (#5277)
add 95164c1 [IOTDB-2765] Fix grafana plugin compile error on lastest arm macos (#5282)
add 5a699d0 Fix sonar-coveralls aways be cancelled (#5283)
add d8fd5b3 [IOTDB-2730] Config node server (#5284)
add 00f1005 [IOTDB-2713] Generate statement from AST for MPP query - Part 1 (#5288)
add c83ccfa [IOTDB-2767] Add Operators and PlanVisitor definitions for mpp (#5286)
add a389890 Update 0.13.0 download links (#5290)
add fb08f7b [IOTDB-1808] Compatibility of Apache IoTDB with InfluxDB - Query Func (#5104)
add 4e7687b [IOTDB-2730] start config service (#5287)
add 49938f4 [IOTDB-2772] Fix influxdb build error (#5292)
add 537069e [IoTDB-2660] Implement the basic functionalities for DistributionPlanner (#5291)
add 684c75d add write node and metadata node (#5296)
add d47a2e3 Fix windows CI failed (#5293)
add a477034 Merge remote-tracking branch 'upstream/master' into rel/rocksdb
add de15780 fix conflicts
add f76e9b5 [To-Master] ignore not exist device when do query
add 1881ee0 Merge remote-tracking branch 'origin/rel/rocksdb' into rel/rocksdb
add dc10333 add tags info when show timeseries
add 6d6e7a1 use metaManager
add 44c3b38 resolve an issue where schemaEngine is empty in test scenarios
add 8bdd7dc [RocksDB] rename classes name
add 4bd3450 [RocksDB] fix unit tests
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (1589801)
\
N -- N -- N refs/heads/rocksdb/dev (4bd3450)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/dependabot.yml | 26 +
.github/workflows/client-go.yml | 4 +
.github/workflows/client.yml | 4 +
.github/workflows/cluster.yml | 4 +
.github/workflows/e2e.yml | 4 +
.github/workflows/grafana-plugin.yml | 7 +-
.github/workflows/influxdb-protocol.yml | 10 +-
.github/workflows/main-unix.yml | 4 +
.github/workflows/main-win.yml | 4 +
.github/workflows/sonar-coveralls.yml | 11 +-
Jenkinsfile | 2 +-
README.md | 10 +-
README_ZH.md | 10 +-
RELEASE_NOTES.md | 63 +-
antlr/pom.xml | 2 +-
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 131 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlLexer.g4 | 1009 --
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 20 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 1018 ++
cli/pom.xml | 2 +-
cli/src/assembly/resources/sbin/start-cli.bat | 2 +-
cli/src/assembly/resources/tools/export-csv.bat | 2 +-
cli/src/assembly/resources/tools/import-csv.bat | 2 +-
.../apache/iotdb/cli/IoTDBSyntaxHighlighter.java | 4 +-
.../org/apache/iotdb/cli/utils/JlineUtils.java | 6 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 31 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 15 +-
.../iotdb/tool/integration/ExportCsvTestIT.java | 5 +-
.../iotdb/tool/integration/ImportCsvTestIT.java | 5 +-
client-cpp/pom.xml | 2 +-
client-cpp/src/main/Session.h | 4 +-
client-py/SessionExample.py | 66 +
client-py/SessionTest.py | 62 +
client-py/iotdb/Session.py | 20 +-
client-py/iotdb/utils/IoTDBConstants.py | 2 +
client-py/iotdb/utils/NumpyTablet.py | 107 +
client-py/iotdb/utils/Tablet.py | 244 +-
client-py/pom.xml | 2 +-
client-py/requirements.txt | 5 +-
client-py/setup.py | 3 +-
client-py/tests/tablet_performance_comparison.py | 13 +-
cluster/pom.xml | 2 +-
cluster/src/assembly/resources/sbin/add-node.bat | 2 +-
cluster/src/assembly/resources/sbin/add-node.sh | 2 +-
cluster/src/assembly/resources/sbin/start-node.bat | 2 +-
cluster/src/assembly/resources/sbin/start-node.sh | 2 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 2 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 81 +-
.../cluster/ClusterIoTDBServerCommandLine.java | 94 +
.../cluster/client/async/AsyncDataClient.java | 2 +-
.../cluster/client/async/AsyncMetaClient.java | 2 +-
.../iotdb/cluster/client/sync/SyncDataClient.java | 2 +-
.../iotdb/cluster/client/sync/SyncMetaClient.java | 2 +-
.../iotdb/cluster/config/ClusterConstant.java | 2 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 2 +-
.../iotdb/cluster/coordinator/Coordinator.java | 14 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 6 +-
.../org/apache/iotdb/cluster/log/Snapshot.java | 5 +
.../cluster/log/applier/AsyncDataLogApplier.java | 8 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 2 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 6 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 2 +-
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 4 +-
.../cluster/log/manage/CommittedEntryManager.java | 2 +-
.../log/manage/MetaSingleSnapshotLogManager.java | 2 +-
.../log/manage/PartitionedSnapshotLogManager.java | 6 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 4 +-
.../log/manage/UnCommittedEntryManager.java | 2 +-
.../serializable/SyncLogDequeSerializer.java | 4 +-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 89 +-
.../cluster/log/snapshot/PartitionedSnapshot.java | 39 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 1780 ----
.../iotdb/cluster/metadata/CSchemaEngine.java | 1787 ++++
.../apache/iotdb/cluster/metadata/MetaPuller.java | 10 +-
.../iotdb/cluster/partition/PartitionTable.java | 4 +-
.../cluster/query/ClusterPhysicalGenerator.java | 8 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 26 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 18 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 41 +-
.../iotdb/cluster/query/filter/SlotSgFilter.java | 2 +-
.../groupby/ClusterGroupByNoVFilterDataSet.java | 4 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 2 +-
.../query/groupby/MergeGroupByExecutor.java | 2 +-
.../query/groupby/RemoteGroupByExecutor.java | 2 +-
.../query/last/ClusterLastQueryExecutor.java | 42 +-
.../cluster/query/manage/ClusterQueryManager.java | 2 +-
.../cluster/query/reader/ClusterReaderFactory.java | 2 +-
.../cluster/query/reader/ClusterTimeGenerator.java | 6 +-
.../iotdb/cluster/query/reader/EmptyReader.java | 2 +-
.../iotdb/cluster/server/ClusterRPCService.java | 10 +-
.../cluster/server/ClusterRPCServiceMBean.java | 2 +-
.../cluster/server/PullSnapshotHintService.java | 2 +-
.../server/clusterinfo/ClusterInfoServer.java | 10 +-
.../server/handlers/caller/ElectionHandler.java | 2 +
.../server/handlers/caller/HeartbeatHandler.java | 6 +-
.../cluster/server/member/DataGroupMember.java | 14 +-
.../cluster/server/member/MetaGroupMember.java | 10 +-
.../iotdb/cluster/server/member/RaftMember.java | 31 +-
.../cluster/server/monitor/NodeStatusManager.java | 2 +-
.../cluster/server/raft/AbstractRaftService.java | 6 +-
.../server/raft/DataRaftHeartBeatService.java | 8 +-
.../iotdb/cluster/server/raft/DataRaftService.java | 8 +-
.../server/raft/MetaRaftHeartBeatService.java | 8 +-
.../iotdb/cluster/server/raft/MetaRaftService.java | 8 +-
.../cluster/server/service/DataAsyncService.java | 14 +-
.../cluster/server/service/DataGroupEngine.java | 8 +-
.../cluster/server/service/DataSyncService.java | 12 +-
.../iotdb/cluster/utils/ClusterQueryUtils.java | 17 +
.../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 -
.../apache/iotdb/cluster/utils/PlanSerializer.java | 4 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 19 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 4 +-
.../iotdb/cluster/integration/SingleNodeTest.java | 2 +-
.../iotdb/cluster/log/LogDispatcherTest.java | 2 +-
.../log/applier/AsyncDataLogApplierTest.java | 6 +-
.../cluster/log/applier/DataLogApplierTest.java | 20 +-
.../cluster/log/applier/MetaLogApplierTest.java | 16 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 4 +-
.../cluster/log/catchup/LogCatchUpTaskTest.java | 2 +-
.../manage/MetaSingleSnapshotLogManagerTest.java | 2 +-
.../serializable/SyncLogDequeSerializerTest.java | 2 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 4 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 8 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 125 +-
.../log/snapshot/PartitionedSnapshotTest.java | 83 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 4 +-
.../iotdb/cluster/partition/MManagerWhiteBox.java | 54 -
.../cluster/partition/SchemaEngineWhiteBox.java | 54 +
.../cluster/partition/SlotPartitionTableTest.java | 28 +-
.../cluster/query/ClusterPlanExecutorTest.java | 2 +-
.../query/ClusterUDTFQueryExecutorTest.java | 2 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 2 +-
.../clusterinfo/ClusterInfoServiceImplTest.java | 4 +-
.../handlers/caller/HeartbeatHandlerTest.java | 17 +
.../server/heartbeat/HeartbeatThreadTest.java | 1 +
.../iotdb/cluster/server/member/BaseMember.java | 12 +-
.../cluster/server/member/DataGroupMemberTest.java | 4 +-
.../cluster/server/member/MetaGroupMemberTest.java | 22 +-
code-coverage/pom.xml | 4 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 107 +
confignode/src/assembly/confignode.xml | 40 +
.../src/assembly/resources/conf/confignode-env.bat | 146 +
.../src/assembly/resources/conf/confignode-env.sh | 264 +
.../resources/conf/iotdb-confignode.properties | 104 +
.../src/assembly/resources/conf/jmx.access | 0
.../src/assembly/resources/conf/jmx.password | 0
.../assembly/resources/sbin/start-confignode.bat | 121 +
.../assembly/resources/sbin/start-confignode.sh | 77 +
.../assembly/resources/sbin/stop-confignode.bat | 38 +
.../src/assembly/resources/sbin/stop-confignode.sh | 35 +
.../iotdb/confignode/conf/ConfigNodeConf.java | 188 +
.../iotdb/confignode/conf/ConfigNodeConfCheck.java | 135 +
.../iotdb/confignode/conf/ConfigNodeConstant.java | 50 +
.../confignode/conf/ConfigNodeDescriptor.java | 182 +
.../confignode/exception/ConfigNodeException.java | 26 +
.../iotdb/confignode/manager/ConfigManager.java | 91 +
.../confignode/partition/DataPartitionRule.java | 50 +
.../iotdb/confignode/partition/PartitionTable.java | 59 +
.../iotdb/confignode/service/ConfigNode.java | 117 +
.../confignode/service/ConfigNodeCommandLine.java | 81 +
.../iotdb/confignode/service/ConfigNodeMBean.java | 21 +
.../confignode/service/balancer/LoadBalancer.java | 49 +
.../service/basic/ConfigServiceProvider.java | 24 +
.../service/thrift/server/ConfigNodeRPCServer.java | 105 +
.../thrift/server/ConfigNodeRPCServerMBean.java | 22 +
.../server/ConfigNodeRPCServerProcessor.java | 83 +
.../thrift/server/ConfigNodeRPCServiceHandler.java | 52 +
.../manager/hash/DeviceGroupHashExecutorTest.java | 94 +
.../utils/ConfigNodeEnvironmentUtils.java | 134 +
consensus/pom.xml | 50 +
.../org/apache/iotdb/consensus/IConsensus.java | 58 +
.../iotdb/consensus/common/ConsensusGroup.java | 60 +
.../iotdb/consensus/common/ConsensusGroupId.java | 64 +
.../org/apache/iotdb/consensus/common/DataSet.java | 22 +
.../apache/iotdb/consensus/common/Endpoint.java | 59 +
.../apache/iotdb/consensus/common/GroupType.java | 27 +
.../org/apache/iotdb/consensus/common/Peer.java | 59 +
.../common/request/ByteBufferConsensusRequest.java | 44 +
.../common/request/IConsensusRequest.java | 27 +
.../common/response/ConsensusGenericResponse.java | 64 +
.../common/response/ConsensusReadResponse.java | 65 +
.../common/response/ConsensusResponse.java | 39 +
.../common/response/ConsensusWriteResponse.java | 65 +
.../consensus/exception/ConsensusException.java | 27 +
.../ConsensusGroupAlreadyExistException.java | 36 +
.../exception/ConsensusGroupNotExistException.java | 36 +
.../exception/IllegalPeerNumException.java | 29 +
.../iotdb/consensus/ratis/RatisConsensus.java | 90 +
.../consensus/standalone/StandAloneConsensus.java | 170 +
.../consensus/standalone/StandAloneServerImpl.java | 65 +
.../consensus/statemachine/EmptyStateMachine.java | 43 +
.../consensus/statemachine/IStateMachine.java | 40 +
.../standalone/StandAloneConsensusTest.java | 262 +
cross-tests/pom.xml | 2 +-
distribution/pom.xml | 2 +-
docker/src/main/Dockerfile-0.12.3-cluster | 53 +
docker/src/main/Dockerfile-0.12.3-grafana | 41 +
docker/src/main/Dockerfile-0.12.3-node | 45 +
docker/src/main/Dockerfile-0.12.4-cluster | 53 +
docker/src/main/Dockerfile-0.12.4-grafana | 41 +
docker/src/main/Dockerfile-0.12.4-node | 45 +
docker/src/main/Dockerfile-0.12.5-cluster | 53 +
docker/src/main/Dockerfile-0.12.5-grafana | 41 +
docker/src/main/Dockerfile-0.12.5-node | 45 +
docker/src/main/Dockerfile-0.13.0-cluster | 53 +
docker/src/main/Dockerfile-0.13.0-grafana | 41 +
docker/src/main/Dockerfile-0.13.0-node | 45 +
docs/Download/README.md | 72 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 9 +-
.../UserGuide/API/Programming-Python-Native-API.md | 242 +-
docs/UserGuide/API/Programming-TsFile-API.md | 4 +-
.../Administration-Management/Administration.md | 6 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 10 +-
docs/UserGuide/Data-Concept/Encoding.md | 17 +-
docs/UserGuide/Data-Concept/Schema-Template.md | 2 +
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +-
.../Ecosystem Integration/MapReduce TsFile.md | 2 +-
.../Ecosystem Integration/Spark TsFile.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 8 -
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 189 +-
docs/UserGuide/Operate-Metadata/Template.md | 2 +
docs/UserGuide/Operate-Metadata/Timeseries.md | 41 +-
docs/UserGuide/Process-Data/Triggers.md | 6 +-
docs/UserGuide/Process-Data/UDF-Library.md | 4611 --------
.../Process-Data/UDF-User-Defined-Function.md | 10 +-
docs/UserGuide/Query-Data/Aggregate-Query.md | 28 +-
docs/UserGuide/Query-Data/Last-Query.md | 8 +-
docs/UserGuide/Query-Data/Overview.md | 27 +-
docs/UserGuide/Query-Data/Select-Expression.md | 116 +
docs/UserGuide/Query-Data/Without-Null.md | 162 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 25 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 19 +-
docs/UserGuide/Reference/Config-Manual.md | 44 +-
docs/UserGuide/Reference/SQL-Reference.md | 7 +-
docs/UserGuide/UDF-Library/Anomaly-Detection.md | 525 +
docs/UserGuide/UDF-Library/Data-Matching.md | 335 +
docs/UserGuide/UDF-Library/Data-Profiling.md | 1812 ++++
docs/UserGuide/UDF-Library/Data-Quality.md | 519 +
docs/UserGuide/UDF-Library/Data-Repairing.md | 355 +
docs/UserGuide/UDF-Library/Frequency-Domain.md | 605 ++
docs/UserGuide/UDF-Library/M4.md | 92 +
docs/UserGuide/UDF-Library/Quick-Start.md | 41 +
docs/UserGuide/UDF-Library/Series-Discovery.md | 173 +
docs/UserGuide/UDF-Library/String-Processing.md | 299 +
docs/UserGuide/Write-And-Delete-Data/CSV-Tool.md | 4 +
docs/zh/Download/README.md | 67 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 2 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 2 +-
.../UserGuide/API/Programming-Java-Native-API.md | 8 +-
.../UserGuide/API/Programming-Python-Native-API.md | 254 +-
docs/zh/UserGuide/API/Programming-TsFile-API.md | 4 +-
.../Administration-Management/Administration.md | 8 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 10 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 17 +-
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 2 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +-
.../Ecosystem Integration/MapReduce TsFile.md | 2 +-
.../Ecosystem Integration/Spark TsFile.md | 2 +-
.../Ecosystem Integration/Writing Data on HDFS.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 7 -
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 181 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 2 +
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 36 +-
docs/zh/UserGuide/Process-Data/Triggers.md | 6 +-
docs/zh/UserGuide/Process-Data/UDF-Library.md | 4520 --------
.../Process-Data/UDF-User-Defined-Function.md | 10 +-
docs/zh/UserGuide/Query-Data/Aggregate-Query.md | 37 +-
docs/zh/UserGuide/Query-Data/Last-Query.md | 4 +-
docs/zh/UserGuide/Query-Data/Overview.md | 27 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 113 +
docs/zh/UserGuide/Query-Data/Without-Null.md | 163 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 24 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 19 +-
docs/zh/UserGuide/Reference/Config-Manual.md | 42 +-
docs/zh/UserGuide/Reference/SQL-Reference.md | 8 +-
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 | 1805 ++++
docs/zh/UserGuide/UDF-Library/Data-Quality.md | 524 +
docs/zh/UserGuide/UDF-Library/Data-Repairing.md | 347 +
docs/zh/UserGuide/UDF-Library/Frequency-Domain.md | 598 ++
docs/zh/UserGuide/UDF-Library/M4.md | 93 +
docs/zh/UserGuide/UDF-Library/Quick-Start.md | 40 +
docs/zh/UserGuide/UDF-Library/Series-Discovery.md | 173 +
docs/zh/UserGuide/UDF-Library/String-Processing.md | 290 +
.../zh/UserGuide/Write-And-Delete-Data/CSV-Tool.md | 8 +-
example/client-cpp-example/pom.xml | 2 +-
example/flink/pom.xml | 2 +-
example/hadoop/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/rocketmq/pom.xml | 2 +-
example/rocketmq/readme.md | 4 +-
example/session/pom.xml | 2 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 47 +-
.../iotdb/HybridTimeseriesSessionExample.java | 14 +-
.../main/java/org/apache/iotdb/SessionExample.java | 5 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 42 +-
example/trigger/pom.xml | 4 +-
example/tsfile/pom.xml | 2 +-
example/tsfile/readme.md | 2 +-
.../java/org/apache/iotdb/tsfile/Constant.java | 2 +
.../iotdb/tsfile/TsFileForceAppendWrite.java | 1 +
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 18 +-
.../tsfile/TsFileWriteAlignedWithTSRecord.java | 16 +-
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 28 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 16 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 16 +-
example/udf/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
.../flink/tsfile/RowTSRecordOutputFormatIT.java | 54 -
.../RowTSRecordOutputFormatIntegrationTest.java | 54 +
.../iotdb/flink/tsfile/RowTsFileInputFormatIT.java | 108 -
.../RowTsFileInputFormatIntegrationTest.java | 108 +
.../util/TSFileConfigUtilCompletenessTest.java | 4 +-
grafana-connector/pom.xml | 2 +-
grafana-plugin/package.json | 4 +-
grafana-plugin/pom.xml | 22 +-
grafana-plugin/src/componments/ControlValue.tsx | 5 +-
grafana-plugin/src/componments/FromValue.tsx | 8 +-
grafana-plugin/src/componments/SelectValue.tsx | 8 +-
grafana-plugin/src/componments/WhereValue.tsx | 5 +-
grafana-plugin/src/datasource.ts | 16 +-
grafana-plugin/yarn.lock | 10529 +++++++++----------
hadoop/README.md | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 4 +-
influxdb-protocol/pom.xml | 2 +-
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 4 +-
.../iotdb/influxdb/example/InfluxDBExample.java | 38 +-
.../protocol/impl/IoTDBInfluxDBService.java | 22 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 29 +
.../influxdb/integration/IoTDBInfluxDBIT.java | 77 +-
integration/pom.xml | 2 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 996 --
.../integration/IOTDBGroupByInnerIntervalIT.java | 335 -
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 37 +
.../iotdb/db/integration/IoTDBArithmeticIT.java | 18 +-
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 49 +
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 6 +-
.../integration/IoTDBCompactionWithIDTableIT.java | 352 +
.../db/integration/IoTDBCreateSnapshotIT.java | 180 -
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 2 +-
.../iotdb/db/integration/IoTDBEncodingIT.java | 145 +-
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 2648 -----
.../db/integration/IoTDBGroupByFillMixPathsIT.java | 479 -
.../integration/IoTDBGroupByFillWithRangeIT.java | 179 -
.../db/integration/IoTDBGroupByMonthFillIT.java | 272 -
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 273 -
.../iotdb/db/integration/IoTDBGroupByUnseqIT.java | 185 -
.../iotdb/db/integration/IoTDBLargeDataIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 147 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 47 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 2 +-
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 12 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 6 +-
.../IoTDBQueryWithComplexValueFilterIT.java | 64 +-
.../IoTDBQueryWithRecreatedTimeseriesIT.java | 79 +
.../db/integration/IoTDBRecoverUnclosedIT.java | 2 +-
.../db/integration/IoTDBResultMetadataIT.java | 82 +
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 18 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 8 +-
.../integration/IoTDBSizeTieredCompactionIT.java | 6 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 26 +-
.../db/integration/IoTDBTriggerManagementIT.java | 8 +-
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 12 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 224 +
.../db/integration/IoTDBWithoutAnyNullIT.java | 33 +
.../aggregation/IoTDBAggregationByLevelIT.java | 160 +
.../aligned/IOTDBInsertAlignedValuesIT.java | 11 +
.../integration/aligned/IoTDBAlignByDeviceIT.java | 275 +
.../IoTDBGroupByQueryWithoutValueFilterIT.java | 14 -
...GroupBySlidingWindowQueryWithValueFilterIT.java | 951 ++
...upBySlidingWindowQueryWithoutValueFilterIT.java | 940 ++
.../db/integration/groupby/IOTDBGroupByIT.java | 996 ++
.../groupby/IOTDBGroupByInnerIntervalIT.java | 335 +
.../db/integration/groupby/IoTDBGroupByFillIT.java | 2648 +++++
.../groupby/IoTDBGroupByFillMixPathsIT.java | 479 +
.../groupby/IoTDBGroupByFillWithRangeIT.java | 179 +
.../groupby/IoTDBGroupByMonthFillIT.java | 272 +
.../integration/groupby/IoTDBGroupByMonthIT.java | 366 +
.../integration/groupby/IoTDBGroupByUnseqIT.java | 185 +
.../IoTDBWithoutNullAllFilterIT.java | 1973 ++++
.../IoTDBWithoutNullAnyFilterIT.java | 1866 ++++
.../iotdb/session/IoTDBSessionComplexIT.java | 2 +-
.../iotdb/session/IoTDBSessionIteratorIT.java | 2 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 13 +-
.../session/IoTDBSessionSyntaxConventionIT.java | 2 +-
integration/src/test/resources/logback.xml | 4 +-
jdbc/README.md | 4 +-
jdbc/pom.xml | 2 +-
jdbc/src/main/feature/feature.xml | 2 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 29 +-
library-udf/pom.xml | 2 +-
metrics/ReadMe.md | 28 +-
metrics/dropwizard-metrics/pom.xml | 9 +-
.../dropwizard/DropwizardMetricManager.java | 121 +-
.../iotdb/metrics/dropwizard/MetricName.java | 44 +-
.../dropwizard/reporter/DropwizardJmxReporter.java | 4 +-
.../reporter/DropwizardMetricsExporter.java | 216 +
.../reporter/DropwizardPrometheusReporter.java | 85 +-
.../metrics/dropwizard/reporter/MetricType.java | 38 +
.../dropwizard/reporter/PrometheusTextWriter.java | 79 +
.../prometheus/DropwizardMetricsExporter.java | 196 -
.../dropwizard/reporter/prometheus/MetricType.java | 38 -
.../reporter/prometheus/PrometheusReporter.java | 231 -
.../reporter/prometheus/PrometheusSender.java | 63 -
.../reporter/prometheus/PrometheusTextWriter.java | 79 -
.../reporter/prometheus/PushGateway.java | 151 -
.../dropwizard/reporter/prometheus/TextFormat.java | 27 -
... => org.apache.iotdb.metrics.reporter.Reporter} | 0
.../dropwizard/DropwizardMetricManagerTest.java | 139 +-
metrics/interface/pom.xml | 4 +-
.../main/assembly/resources/conf/iotdb-metric.yml | 33 +-
.../apache/iotdb/metrics/CompositeReporter.java | 89 -
.../org/apache/iotdb/metrics/MetricManager.java | 43 +-
.../org/apache/iotdb/metrics/MetricService.java | 25 +-
.../java/org/apache/iotdb/metrics/Reporter.java | 36 -
.../apache/iotdb/metrics/config/MetricConfig.java | 67 +-
.../metrics/config/MetricConfigDescriptor.java | 1 +
.../iotdb/metrics/impl/DoNothingMetricManager.java | 31 +-
.../iotdb/metrics/reporter/CompositeReporter.java | 89 +
.../apache/iotdb/metrics/reporter/Reporter.java | 37 +
.../org/apache/iotdb/metrics/type/IMetric.java | 9 +-
.../apache/iotdb/metrics/utils/MetricLevel.java | 43 +
.../apache/iotdb/metrics/utils/MonitorType.java | 31 +-
.../apache/iotdb/metrics/utils/OutPutFormat.java | 30 +
.../iotdb/metrics/utils/PredefinedMetric.java | 9 +-
.../apache/iotdb/metrics/utils/ReporterType.java | 8 +-
.../iotdb/metrics/config/MetricConfigTest.java | 5 +-
.../interface/src/test/resources/iotdb-metric.yml | 36 +-
metrics/micrometer-metrics/pom.xml | 4 +-
.../iotdb/metrics/micrometer/MeterIdUtils.java | 32 -
.../iotdb/metrics/micrometer/MetricName.java | 66 +
.../micrometer/MicrometerMetricManager.java | 185 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 4 +-
.../reporter/MicrometerPrometheusReporter.java | 11 +-
... => org.apache.iotdb.metrics.reporter.Reporter} | 0
.../micrometer/MicrometerMetricManagerTest.java | 10 +-
metrics/pom.xml | 2 +-
node-commons/pom.xml | 177 +
.../apache/iotdb/commons/ServerCommandLine.java | 67 +
.../apache/iotdb/commons/concurrent/HashLock.java | 62 +
.../concurrent/IoTDBDaemonThreadFactory.java | 37 +
.../IoTDBDefaultThreadExceptionHandler.java | 33 +
.../commons/concurrent/IoTDBThreadPoolFactory.java | 277 +
.../iotdb/commons/concurrent/IoTThreadFactory.java | 58 +
.../iotdb/commons/concurrent/ThreadName.java | 85 +
.../iotdb/commons/concurrent/WrappedRunnable.java | 46 +
.../concurrent/threadpool/IThreadPoolMBean.java | 45 +
.../WrappedScheduledExecutorService.java | 193 +
.../WrappedScheduledExecutorServiceMBean.java | 22 +
.../WrappedSingleThreadExecutorService.java | 119 +
.../WrappedSingleThreadExecutorServiceMBean.java | 22 +
.../WrappedSingleThreadScheduledExecutor.java | 141 +
.../WrappedSingleThreadScheduledExecutorMBean.java | 22 +
.../threadpool/WrappedThreadPoolExecutor.java | 82 +
.../threadpool/WrappedThreadPoolExecutorMBean.java | 22 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 195 +
.../commons/exception/ConfigurationException.java | 44 +
.../iotdb/commons/exception/IoTDBException.java | 67 +
.../iotdb/commons/exception/ShutdownException.java | 40 +
.../iotdb/commons/exception/StartupException.java | 40 +
.../exception/runtime/RPCServiceException.java | 32 +
.../apache/iotdb/commons/hash/APHashExecutor.java | 42 +
.../iotdb/commons/hash/BKDRHashExecutor.java | 40 +
.../commons/hash/DeviceGroupHashExecutor.java | 31 +
.../apache/iotdb/commons/hash/JSHashExecutor.java | 40 +
.../iotdb/commons/hash/SDBMHashExecutor.java | 38 +
.../service/AbstractThriftServiceThread.java | 322 +
.../org/apache/iotdb/commons/service/IService.java | 49 +
.../apache/iotdb/commons/service/JMXService.java | 101 +
.../iotdb/commons/service/RegisterManager.java | 85 +
.../apache/iotdb/commons/service/ServiceType.java | 89 +
.../apache/iotdb/commons/service/StartupCheck.java | 28 +
.../iotdb/commons/service/StartupChecks.java | 78 +
.../iotdb/commons/service/ThriftService.java | 171 +
.../iotdb/commons/service/ThriftServiceThread.java | 89 +
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 81 +
.../org/apache/iotdb/commons/utils/TestOnly.java | 34 +
.../IoTDBDefaultThreadExceptionHandlerTest.java | 80 +
.../iotdb/commons/IoTDBThreadPoolFactoryTest.java | 221 +
openapi/pom.xml | 2 +-
pom.xml | 24 +-
server/pom.xml | 18 +-
.../resources/conf/iotdb-engine.properties | 76 +-
server/src/assembly/resources/conf/iotdb-env.bat | 11 +
server/src/assembly/resources/conf/iotdb-env.sh | 8 +
server/src/assembly/resources/conf/logback.xml | 1 +
.../src/assembly/resources/sbin/start-server.bat | 2 +-
server/src/assembly/resources/sbin/start-server.sh | 2 +-
.../assembly/resources/tools/rocksdb-transfer.bat | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +-
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 8 +-
.../apache/iotdb/db/auth/entity/PrivilegeType.java | 38 +-
.../iotdb/db/auth/role/BasicRoleManager.java | 2 +-
.../iotdb/db/auth/role/LocalFileRoleAccessor.java | 2 +-
.../iotdb/db/auth/user/BasicUserManager.java | 2 +-
.../iotdb/db/auth/user/LocalFileUserAccessor.java | 2 +-
.../org/apache/iotdb/db/concurrent/HashLock.java | 62 -
.../db/concurrent/IoTDBDaemonThreadFactory.java | 37 -
.../IoTDBDefaultThreadExceptionHandler.java | 33 -
.../db/concurrent/IoTDBThreadPoolFactory.java | 277 -
.../iotdb/db/concurrent/IoTThreadFactory.java | 58 -
.../org/apache/iotdb/db/concurrent/ThreadName.java | 84 -
.../iotdb/db/concurrent/WrappedRunnable.java | 46 -
.../db/concurrent/threadpool/IThreadPoolMBean.java | 45 -
.../WrappedScheduledExecutorService.java | 193 -
.../WrappedScheduledExecutorServiceMBean.java | 22 -
.../WrappedSingleThreadExecutorService.java | 119 -
.../WrappedSingleThreadExecutorServiceMBean.java | 22 -
.../WrappedSingleThreadScheduledExecutor.java | 141 -
.../WrappedSingleThreadScheduledExecutorMBean.java | 22 -
.../threadpool/WrappedThreadPoolExecutor.java | 82 -
.../threadpool/WrappedThreadPoolExecutorMBean.java | 22 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 97 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 27 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 189 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 61 +-
.../db/conf/directories/DirectoryManager.java | 2 +-
.../directories/strategy/DirectoryStrategy.java | 4 +-
.../strategy/MaxDiskUsableSpaceFirstStrategy.java | 6 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 6 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +-
.../directories/strategy/SequenceStrategy.java | 6 +-
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 2 +-
.../iotdb/db/consensus/ConsensusExample.java | 113 +
.../consensus/statemachine/BaseStateMachine.java | 74 +
.../statemachine/DataRegionStateMachine.java | 51 +
.../statemachine/SchemaRegionStateMachine.java | 51 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 33 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 2 +-
.../db/engine/cache/CacheHitRatioMonitor.java | 10 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 4 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 9 +-
.../engine/compaction/CompactionTaskManager.java | 17 +-
.../db/engine/compaction/CompactionUtils.java | 63 +-
.../db/engine/compaction/TsFileIdentifier.java | 51 +-
.../cross/AbstractCrossSpaceCompactionTask.java | 16 +-
.../CrossSpaceCompactionExceptionHandler.java | 73 +-
.../RewriteCrossSpaceCompactionSelector.java | 17 +-
.../manage/CrossSpaceCompactionResource.java | 205 +
.../rewrite/manage/CrossSpaceMergeResource.java | 210 -
.../RewriteCrossSpaceCompactionLogAnalyzer.java | 118 -
.../recover/RewriteCrossSpaceCompactionLogger.java | 86 -
.../selector/RewriteCompactionFileSelector.java | 25 +-
.../task/RewriteCrossCompactionRecoverTask.java | 232 +-
.../task/RewriteCrossSpaceCompactionTask.java | 33 +-
.../inner/AbstractInnerSpaceCompactionTask.java | 8 +-
.../InnerSpaceCompactionExceptionHandler.java | 2 +-
.../SizeTieredCompactionRecoverTask.java | 82 +-
.../sizetiered/SizeTieredCompactionSelector.java | 5 +-
.../inner/sizetiered/SizeTieredCompactionTask.java | 31 +-
.../inner/utils/InnerSpaceCompactionUtils.java | 33 +-
.../inner/utils/MultiTsFileDeviceIterator.java | 31 +-
.../utils/SingleSeriesCompactionExecutor.java | 26 +-
.../utils/SizeTieredCompactionLogAnalyzer.java | 101 -
.../inner/utils/SizeTieredCompactionLogger.java | 87 -
.../compaction/task/AbstractCompactionTask.java | 6 +-
.../compaction/task/CompactionRecoverTask.java | 32 +-
.../utils/log/CompactionLogAnalyzer.java | 163 +
.../compaction/utils/log/CompactionLogger.java | 83 +
.../org/apache/iotdb/db/engine/cq/CQLogReader.java | 47 +
.../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 74 +
.../engine/cq/ContinuousQuerySchemaCheckTask.java | 2 +-
.../iotdb/db/engine/cq/ContinuousQueryService.java | 128 +-
.../iotdb/db/engine/cq/ContinuousQueryTask.java | 4 +-
.../engine/cq/ContinuousQueryTaskPoolManager.java | 4 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 13 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 40 +-
.../engine/flush/pool/FlushSubTaskPoolManager.java | 4 +-
.../db/engine/flush/pool/FlushTaskPoolManager.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 27 +-
.../apache/iotdb/db/engine/settle/SettleTask.java | 2 +-
.../db/engine/storagegroup/StorageGroupInfo.java | 2 +-
.../db/engine/storagegroup/TsFileManager.java | 27 +-
.../engine/storagegroup/TsFileNameGenerator.java | 6 +-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 4 +
.../db/engine/storagegroup/TsFileResource.java | 18 +-
.../db/engine/storagegroup/TsFileResourceList.java | 6 +-
.../storagegroup/VirtualStorageGroupProcessor.java | 171 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 8 +-
.../virtualSg/StorageGroupManager.java | 4 +-
.../engine/trigger/executor/TriggerExecutor.java | 2 +-
.../service/TriggerRegistrationService.java | 26 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 6 +-
.../iotdb/db/engine/upgrade/UpgradeTask.java | 2 +-
.../iotdb/db/exception/ConfigurationException.java | 44 -
.../apache/iotdb/db/exception/IoTDBException.java | 67 -
.../iotdb/db/exception/LoadFileException.java | 1 +
.../apache/iotdb/db/exception/MergeException.java | 1 +
.../db/exception/QueryIdNotExsitException.java | 1 +
.../exception/QueryInBatchStatementException.java | 1 +
.../iotdb/db/exception/ShutdownException.java | 40 -
.../iotdb/db/exception/StartupException.java | 40 -
.../iotdb/db/exception/StorageEngineException.java | 1 +
.../exception/StorageGroupProcessorException.java | 1 +
.../db/exception/SyncConnectionException.java | 1 +
.../SyncDeviceOwnerConflictException.java | 1 +
.../iotdb/db/exception/SystemCheckException.java | 1 +
.../db/exception/TsFileProcessorException.java | 1 +
.../iotdb/db/exception/WriteProcessException.java | 1 +
.../db/exception/index/IndexManagerException.java | 2 +-
.../db/exception/metadata/MetadataException.java | 2 +-
.../SchemaDirCreationFailureException.java | 26 +
.../exception/query/LogicalOperatorException.java | 2 +-
.../exception/query/LogicalOptimizeException.java | 2 +-
.../db/exception/query/QueryProcessException.java | 2 +-
.../db/exception/runtime/RPCServiceException.java | 32 -
.../db/exception/runtime/SQLParserException.java | 35 -
.../iotdb/db/exception/sql/SQLParserException.java | 35 +
.../exception/sql/StatementAnalyzeException.java | 39 +
.../org/apache/iotdb/db/metadata/IMetaManager.java | 383 -
.../apache/iotdb/db/metadata/ISchemaEngine.java | 363 +
.../db/metadata/IStorageGroupSchemaManager.java | 232 +
.../org/apache/iotdb/db/metadata/MManager.java | 2512 -----
.../apache/iotdb/db/metadata/MetadataConstant.java | 5 +-
.../org/apache/iotdb/db/metadata/SchemaEngine.java | 1736 +++
.../org/apache/iotdb/db/metadata/SchemaRegion.java | 1740 +++
.../db/metadata/StorageGroupSchemaManager.java | 251 +
.../idtable/AppendOnlyDiskSchemaManager.java | 41 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 12 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 41 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 23 +-
.../db/metadata/idtable/IDiskSchemaManager.java | 2 +-
.../db/metadata/idtable/entry/DeviceEntry.java | 2 +-
.../db/metadata/idtable/entry/DeviceIDFactory.java | 2 +-
.../idtable/entry/InsertMeasurementMNode.java | 9 +-
.../db/metadata/idtable/entry/SchemaEntry.java | 2 +-
.../db/metadata/lastCache/LastCacheManager.java | 6 +-
.../iotdb/db/metadata/logfile/MLogReader.java | 2 +-
.../iotdb/db/metadata/logfile/MLogTxtReader.java | 2 +-
.../iotdb/db/metadata/logfile/MLogUpgrader.java | 290 -
.../iotdb/db/metadata/logfile/MLogWriter.java | 12 -
.../iotdb/db/metadata/mnode/EntityMNode.java | 13 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 7 +-
.../db/metadata/mnode/IStorageGroupMNode.java | 6 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 38 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 16 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 3 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 23 +
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 23 +
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 1898 ----
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 559 +
.../iotdb/db/metadata/mtree/MTreeBelowSG.java | 1268 +++
.../db/metadata/mtree/traverser/Traverser.java | 107 +-
.../traverser/collector/MNodeAboveSGCollector.java | 58 +
.../mtree/traverser/collector/MNodeCollector.java | 2 +-
.../traverser/collector/MeasurementCollector.java | 20 +-
.../counter/MNodeAboveSGLevelCounter.java | 59 +
.../mtree/traverser/counter/MNodeLevelCounter.java | 10 +-
.../counter/MeasurementGroupByLevelCounter.java | 26 +
.../apache/iotdb/db/metadata/path/AlignedPath.java | 2 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 4 +-
.../apache/iotdb/db/metadata/path/PartialPath.java | 6 +-
.../db/metadata/rescon/TimeseriesStatistics.java | 104 +
.../iotdb/db/metadata/rocksdb/CheckKeyResult.java | 10 +-
.../rocksdb/GetBelongedToSpecifiedType.java | 18 +-
.../iotdb/db/metadata/rocksdb/MRocksDBManager.java | 2551 -----
.../db/metadata/rocksdb/MetaDataTransfer.java | 458 -
.../iotdb/db/metadata/rocksdb/RMNodeValueType.java | 18 -
.../db/metadata/rocksdb/RSchemaConstants.java | 75 +
.../iotdb/db/metadata/rocksdb/RSchemaEngine.java | 2456 +++++
.../iotdb/db/metadata/rocksdb/RSchemaLogger.java | 60 +
.../metadata/rocksdb/RSchemaReadWriteHandler.java | 582 +
.../iotdb/db/metadata/rocksdb/RSchemaUtils.java | 527 +
.../iotdb/db/metadata/rocksdb/RockDBConstants.java | 75 -
.../iotdb/db/metadata/rocksdb/RockDBLogger.java | 60 -
.../db/metadata/rocksdb/RocksDBMNodeType.java | 48 -
.../metadata/rocksdb/RocksDBReadWriteHandler.java | 570 -
.../iotdb/db/metadata/rocksdb/RocksDBUtils.java | 555 -
.../db/metadata/rocksdb/SchemaDataTransfer.java | 454 +
.../db/metadata/rocksdb/mnode/REntityMNode.java | 4 +-
.../db/metadata/rocksdb/mnode/RInternalMNode.java | 43 +-
.../iotdb/db/metadata/rocksdb/mnode/RMNode.java | 39 +-
.../db/metadata/rocksdb/mnode/RMNodeType.java | 44 +
.../db/metadata/rocksdb/mnode/RMNodeValueType.java | 28 +
.../metadata/rocksdb/mnode/RMeasurementMNode.java | 17 +-
.../metadata/rocksdb/mnode/RStorageGroupMNode.java | 16 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 27 +-
.../iotdb/db/metadata/template/Template.java | 39 +
.../db/metadata/template/TemplateLogReader.java | 46 +
.../db/metadata/template/TemplateLogWriter.java | 64 +
.../db/metadata/template/TemplateManager.java | 125 +-
.../db/metadata/upgrade/MetadataUpgrader.java | 429 +
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 10 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 4 +-
.../reporter/DropwizardIoTDBReporter.java | 4 +-
.../reporter/MicrometerIoTDBReporter.java | 4 +-
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 56 +
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 36 +
.../org/apache/iotdb/db/mpp/common/Analysis.java | 69 +
.../org/apache/iotdb/db/mpp/common/DataRegion.java | 58 +
.../iotdb/db/mpp/common/DataRegionTimeSlice.java | 24 +
.../org/apache/iotdb/db/mpp/common/FillPolicy.java | 23 +
.../iotdb/db/mpp/common/FilterNullPolicy.java | 25 +
.../org/apache/iotdb/db/mpp/common/FragmentId.java | 57 +
.../iotdb/db/mpp/common/FragmentInstanceId.java | 28 +
.../iotdb/db/mpp/common/GroupByTimeParameter.java | 27 +
.../iotdb/db/mpp/common/MPPQueryContext.java | 29 +
.../org/apache/iotdb/db/mpp/common/QueryId.java | 113 +
.../apache/iotdb/db/mpp/common/QuerySession.java | 21 +
.../apache/iotdb/db/mpp/common/SchemaRegion.java | 29 +
.../org/apache/iotdb/db/mpp/common/TsBlock.java | 73 +
.../iotdb/db/mpp/common/TsBlockMetadata.java | 41 +
.../apache/iotdb/db/mpp/execution/Coordinator.java | 45 +
.../db/mpp/execution/ExecFragmentInstance.java | 57 +
.../iotdb/db/mpp/execution/FragmentInfo.java | 44 +
.../db/mpp/execution/FragmentInstanceContext.java | 67 +
.../db/mpp/execution/FragmentInstanceState.java | 68 +
.../iotdb/db/mpp/execution/FragmentState.java | 71 +
.../iotdb/db/mpp/execution/QueryExecution.java | 98 +
.../iotdb/db/mpp/execution/QueryStateMachine.java | 25 +
.../mpp/execution/scheduler/ClusterScheduler.java | 77 +
.../db/mpp/execution/scheduler/IScheduler.java | 40 +
.../execution/scheduler/StandaloneScheduler.java | 56 +
.../org/apache/iotdb/db/mpp/operator/Operator.java | 49 +
.../iotdb/db/mpp/operator/OperatorContext.java | 43 +
.../iotdb/db/mpp/operator/SeriesScanOperator.java | 39 +
.../db/mpp/operator/process/AggregateOperator.java | 52 +
.../mpp/operator/process/DeviceMergeOperator.java | 51 +
.../db/mpp/operator/process/FillOperator.java | 51 +
.../mpp/operator/process/FilterNullOperator.java | 52 +
.../mpp/operator/process/GroupByLevelOperator.java | 52 +
.../db/mpp/operator/process/LimitOperator.java | 75 +
.../db/mpp/operator/process/OffsetOperator.java | 52 +
.../db/mpp/operator/process/ProcessOperator.java | 24 +
.../db/mpp/operator/process/SortOperator.java | 52 +
.../db/mpp/operator/process/TimeJoinOperator.java | 52 +
.../db/mpp/operator/sink/FragmentSinkOperator.java | 61 +
.../iotdb/db/mpp/operator/sink/SinkOperator.java | 43 +
.../source/SeriesAggregateScanOperator.java | 57 +
.../db/mpp/operator/source/SeriesScanOperator.java | 58 +
.../db/mpp/operator/source/SourceOperator.java | 27 +
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 132 +
.../sql/planner/optimization/PlanOptimizer.java | 26 +
.../mpp/sql/planner/plan/DistributedQueryPlan.java | 33 +
.../mpp/sql/planner/plan/DistributionPlanner.java | 254 +
.../db/mpp/sql/planner/plan/FragmentInstance.java | 31 +
.../db/mpp/sql/planner/plan/LogicalPlanner.java | 42 +
.../db/mpp/sql/planner/plan/LogicalQueryPlan.java | 44 +
.../db/mpp/sql/planner/plan/PlanFragment.java | 28 +
.../db/mpp/sql/planner/plan/PlanFragmentId.java | 27 +
.../db/mpp/sql/planner/plan/node/PlanNode.java | 51 +
.../db/mpp/sql/planner/plan/node/PlanNodeId.java | 47 +
.../sql/planner/plan/node/PlanNodeIdAllocator.java | 29 +
.../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 39 +
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 76 +
.../planner/plan/node/SimplePlanNodeRewriter.java | 44 +
.../plan/node/metedata/read/ShowDevicesNode.java | 51 +
.../planner/plan/node/metedata/read/ShowNode.java | 29 +
.../node/metedata/write/CreateTimeSeriesNode.java | 38 +
.../planner/plan/node/process/AggregateNode.java | 84 +
.../planner/plan/node/process/DeviceMergeNode.java | 96 +
.../planner/plan/node/process/ExchangeNode.java | 79 +
.../sql/planner/plan/node/process/FillNode.java | 71 +
.../sql/planner/plan/node/process/FilterNode.java | 76 +
.../planner/plan/node/process/FilterNullNode.java | 79 +
.../plan/node/process/GroupByLevelNode.java | 93 +
.../sql/planner/plan/node/process/LimitNode.java | 89 +
.../sql/planner/plan/node/process/OffsetNode.java | 75 +
.../sql/planner/plan/node/process/ProcessNode.java | 29 +
.../sql/planner/plan/node/process/SortNode.java | 73 +
.../planner/plan/node/process/TimeJoinNode.java | 116 +
.../sql/planner/plan/node/sink/CsvSinkNode.java | 56 +
.../planner/plan/node/sink/FragmentSinkNode.java | 56 +
.../mpp/sql/planner/plan/node/sink/SinkNode.java | 31 +
.../sql/planner/plan/node/sink/ThriftSinkNode.java | 58 +
.../planner/plan/node/source/CsvSourceNode.java | 58 +
.../plan/node/source/SeriesAggregateScanNode.java | 122 +
.../planner/plan/node/source/SeriesScanNode.java | 149 +
.../sql/planner/plan/node/source/SourceNode.java | 31 +
.../plan/node/write/InsertMultiTabletNode.java | 57 +
.../sql/planner/plan/node/write/InsertNode.java | 66 +
.../sql/planner/plan/node/write/InsertRowNode.java | 62 +
.../planner/plan/node/write/InsertRowsNode.java | 57 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 57 +
.../planner/plan/node/write/InsertTabletNode.java | 57 +
.../apache/iotdb/db/mpp/sql/tree/Expression.java | 21 +
.../protocol/influxdb/constant/InfluxConstant.java | 28 +
.../influxdb/constant/InfluxDBConstant.java | 24 -
.../influxdb/constant/InfluxSQLConstant.java | 64 +
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 10 +-
.../protocol/influxdb/function/InfluxFunction.java | 58 +
.../influxdb/function/InfluxFunctionFactory.java | 62 +
.../influxdb/function/InfluxFunctionValue.java | 46 +
.../function/aggregator/InfluxAggregator.java | 35 +
.../function/aggregator/InfluxCountFunction.java | 59 +
.../function/aggregator/InfluxMeanFunction.java | 72 +
.../function/aggregator/InfluxMedianFunction.java | 75 +
.../function/aggregator/InfluxModeFunction.java | 88 +
.../function/aggregator/InfluxSpreadFunction.java | 88 +
.../function/aggregator/InfluxStddevFunction.java | 68 +
.../function/aggregator/InfluxSumFunction.java | 68 +
.../function/selector/InfluxFirstFunction.java | 73 +
.../function/selector/InfluxLastFunction.java | 73 +
.../function/selector/InfluxMaxFunction.java | 102 +
.../function/selector/InfluxMinFunction.java | 102 +
.../influxdb/function/selector/InfluxSelector.java | 57 +
.../db/protocol/influxdb/handler/QueryHandler.java | 956 ++
.../influxdb/meta/InfluxDBMetaManager.java | 10 +-
.../influxdb/operator/InfluxQueryOperator.java | 38 +
.../influxdb/operator/InfluxSelectComponent.java | 98 +
.../influxdb/sql/InfluxDBLogicalGenerator.java | 66 +
.../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 297 +
.../db/protocol/influxdb/util/CommonUtils.java | 40 +
.../db/protocol/influxdb/util/FieldUtils.java | 51 +
.../db/protocol/influxdb/util/FilterUtils.java | 83 +
.../protocol/influxdb/util/QueryResultUtils.java | 291 +
.../db/protocol/influxdb/util/StringUtils.java | 97 +
.../apache/iotdb/db/protocol/rest/RestService.java | 6 +-
.../db/protocol/rest/handler/ExceptionHandler.java | 2 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 2 +-
.../db/protocol/rest/impl/PingApiServiceImpl.java | 2 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 2 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 2 +-
.../iotdb/db/qp/constant/FilterConstant.java | 20 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 3 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 200 +-
.../db/qp/logical/crud/BasicFunctionOperator.java | 2 +-
.../db/qp/logical/crud/BasicOperatorType.java | 4 +-
.../db/qp/logical/crud/DeleteDataOperator.java | 2 +-
.../db/qp/logical/crud/FillQueryOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/InsertOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 33 +-
.../iotdb/db/qp/logical/crud/SelectComponent.java | 4 +-
.../db/qp/logical/crud/SpecialClauseComponent.java | 22 +
.../sys/CreateAlignedTimeSeriesOperator.java | 59 +-
.../db/qp/logical/sys/CreateSnapshotOperator.java | 40 -
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 15 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 18 +-
.../db/qp/physical/crud/AlignByDevicePlan.java | 54 +-
.../db/qp/physical/crud/GroupByTimeFillPlan.java | 7 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 11 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 4 +-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 12 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 18 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 25 +
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 179 +-
.../db/qp/physical/sys/CreateSnapshotPlan.java | 56 -
.../db/qp/physical/sys/CreateTemplatePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 2 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 2 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 60 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 12 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 130 +-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 24 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 91 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 4 +-
.../db/query/aggregation/AggregateResult.java | 53 +-
.../aggregation/RemovableAggregateResult.java | 30 +
.../db/query/aggregation/impl/AvgAggrResult.java | 22 +-
.../db/query/aggregation/impl/CountAggrResult.java | 14 +-
.../query/aggregation/impl/ExtremeAggrResult.java | 8 +-
.../aggregation/impl/FirstValueAggrResult.java | 3 -
.../aggregation/impl/LastValueAggrResult.java | 3 -
.../query/aggregation/impl/MaxTimeAggrResult.java | 5 +
.../query/aggregation/impl/MaxValueAggrResult.java | 4 +
.../query/aggregation/impl/MinTimeAggrResult.java | 5 +
.../query/aggregation/impl/MinValueAggrResult.java | 4 +
.../db/query/aggregation/impl/SumAggrResult.java | 20 +-
.../iotdb/db/query/control/QueryTimeManager.java | 6 +-
.../iotdb/db/query/control/SessionManager.java | 2 +-
.../db/query/control/SessionTimeoutManager.java | 2 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 8 +-
.../db/query/dataset/NonAlignEngineDataSet.java | 2 +-
.../dataset/RawQueryDataSetWithValueFilter.java | 5 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 61 +-
.../iotdb/db/query/dataset/ShowDevicesDataSet.java | 8 +-
.../db/query/dataset/ShowTimeseriesDataSet.java | 18 +-
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 21 +-
.../dataset/groupby/AlignedGroupByExecutor.java | 37 -
.../dataset/groupby/GroupByEngineDataSet.java | 239 -
.../db/query/dataset/groupby/GroupByExecutor.java | 40 -
.../query/dataset/groupby/GroupByFillDataSet.java | 2 +-
.../query/dataset/groupby/GroupByLevelDataSet.java | 5 +-
.../query/dataset/groupby/GroupByTimeDataSet.java | 177 +
.../dataset/groupby/GroupByTimeEngineDataSet.java | 91 +
.../groupby/GroupByWithValueFilterDataSet.java | 87 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 104 +-
.../groupby/LocalAlignedGroupByExecutor.java | 364 -
.../dataset/groupby/LocalGroupByExecutor.java | 365 -
.../db/query/executor/AggregationExecutor.java | 2 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 239 +-
.../iotdb/db/query/executor/QueryRouter.java | 10 +-
.../apache/iotdb/db/query/executor/fill/IFill.java | 13 +-
.../executor/groupby/AlignedGroupByExecutor.java | 37 +
.../db/query/executor/groupby/GroupByExecutor.java | 40 +
.../groupby/SlidingWindowGroupByExecutor.java | 66 +
.../SlidingWindowGroupByExecutorFactory.java | 117 +
.../EmptyQueueSlidingWindowGroupByExecutor.java | 51 +
.../groupby/impl/LocalAlignedGroupByExecutor.java | 365 +
.../groupby/impl/LocalGroupByExecutor.java | 366 +
...MonotonicQueueSlidingWindowGroupByExecutor.java | 73 +
.../NormalQueueSlidingWindowGroupByExecutor.java | 61 +
.../SmoothQueueSlidingWindowGroupByExecutor.java | 55 +
.../iotdb/db/query/expression/ResultColumn.java | 20 +-
.../query/expression/unary/FunctionExpression.java | 2 +-
.../db/query/factory/AggregateResultFactory.java | 2 +
.../iotdb/db/query/pool/QueryTaskManager.java | 4 +-
.../db/query/pool/RawQueryReadTaskPoolManager.java | 7 +-
.../db/query/reader/chunk/ChunkReaderWrap.java | 3 +-
.../reader/chunk/DiskChunkReaderByTimestamp.java | 8 +-
.../query/reader/series/AlignedSeriesReader.java | 2 +-
.../query/reader/series/SeriesAggregateReader.java | 2 +-
.../reader/series/SeriesRawDataBatchReader.java | 2 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 4 +-
.../reader/series/SeriesReaderByTimestamp.java | 2 +-
.../db/query/udf/builtin/BuiltinFunction.java | 6 +
.../query/udf/builtin/UDTFContinuouslySatisfy.java | 239 +
.../iotdb/db/query/udf/builtin/UDTFInRange.java | 90 +
.../db/query/udf/builtin/UDTFNonZeroCount.java | 63 +
.../db/query/udf/builtin/UDTFNonZeroDuration.java | 63 +
.../iotdb/db/query/udf/builtin/UDTFOnOff.java | 86 +
.../iotdb/db/query/udf/builtin/UDTFZeroCount.java | 63 +
.../db/query/udf/builtin/UDTFZeroDuration.java | 63 +
.../row/SerializableRowRecordList.java | 2 +-
.../datastructure/tv/SerializableBinaryTVList.java | 2 +-
.../tv/SerializableBooleanTVList.java | 2 +-
.../datastructure/tv/SerializableDoubleTVList.java | 2 +-
.../datastructure/tv/SerializableFloatTVList.java | 2 +-
.../datastructure/tv/SerializableIntTVList.java | 2 +-
.../datastructure/tv/SerializableLongTVList.java | 2 +-
.../udf/service/TemporaryQueryDataFileService.java | 6 +-
.../query/udf/service/UDFClassLoaderManager.java | 6 +-
.../query/udf/service/UDFRegistrationService.java | 8 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 2 +-
.../iotdb/db/rescon/TsFileResourceManager.java | 2 +-
.../java/org/apache/iotdb/db/service/IService.java | 49 -
.../iotdb/db/service/InfluxDBRPCService.java | 9 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 57 +-
.../org/apache/iotdb/db/service/IoTDBMBean.java | 4 +-
.../org/apache/iotdb/db/service/JMXService.java | 101 -
.../org/apache/iotdb/db/service/MQTTService.java | 2 +
.../org/apache/iotdb/db/service/RPCService.java | 9 +-
.../apache/iotdb/db/service/RPCServiceMBean.java | 2 +-
.../apache/iotdb/db/service/RegisterManager.java | 85 -
.../org/apache/iotdb/db/service/ServiceType.java | 90 -
.../org/apache/iotdb/db/service/SettleService.java | 6 +-
.../org/apache/iotdb/db/service/StartupCheck.java | 28 -
.../org/apache/iotdb/db/service/StartupChecks.java | 78 -
.../org/apache/iotdb/db/service/StaticResps.java | 6 +-
.../org/apache/iotdb/db/service/UpgradeSevice.java | 4 +-
.../db/service/basic/QueryFrequencyRecorder.java | 2 +-
.../iotdb/db/service/basic/ServiceProvider.java | 2 +-
.../iotdb/db/service/metrics/MetricsService.java | 23 +-
.../db/service/metrics/MetricsServiceMBean.java | 2 +-
.../db/service/thrift/ProcessorWithMetrics.java | 9 +-
.../iotdb/db/service/thrift/ThriftService.java | 173 -
.../db/service/thrift/ThriftServiceThread.java | 321 -
.../service/thrift/impl/InfluxDBServiceImpl.java | 14 +
.../db/service/thrift/impl/TSServiceImpl.java | 40 +-
.../iotdb/db/sql/constant/FilterConstant.java | 102 +
.../iotdb/db/sql/constant/StatementType.java | 134 +
.../org/apache/iotdb/db/sql/parser/ASTVisitor.java | 1368 +++
.../iotdb/db/sql/parser/StatementGenerator.java | 184 +
.../sql/statement/AggregationQueryStatement.java | 49 +
.../iotdb/db/sql/statement/FillQueryStatement.java | 39 +
.../sql/statement/GroupByFillQueryStatement.java | 43 +
.../db/sql/statement/GroupByQueryStatement.java | 43 +
.../iotdb/db/sql/statement/LastQueryStatement.java | 31 +
.../iotdb/db/sql/statement/QueryStatement.java | 211 +
.../db/sql/statement/ShowDevicesStatement.java | 34 +
.../db/sql/statement/ShowTimeSeriesStatement.java | 34 +
.../apache/iotdb/db/sql/statement/Statement.java | 58 +
.../iotdb/db/sql/statement/UDAFQueryStatement.java | 27 +
.../iotdb/db/sql/statement/UDTFQueryStatement.java | 27 +
.../db/sql/statement/component/FillComponent.java | 50 +
.../db/sql/statement/component/FromComponent.java | 41 +
.../statement/component/GroupByLevelComponent.java | 45 +
.../statement/component/GroupByTimeComponent.java | 99 +
.../iotdb/db/sql/statement/component/OrderBy.java | 26 +
.../db/sql/statement/component/ResultColumn.java | 168 +
.../sql/statement/component/ResultSetFormat.java | 27 +
.../sql/statement/component/SelectComponent.java | 99 +
.../db/sql/statement/component/WhereCondition.java | 42 +
.../db/sql/statement/component/WithoutPolicy.java | 59 +
.../db/sql/statement/filter/BasicFilterType.java | 189 +
.../sql/statement/filter/BasicFunctionFilter.java | 171 +
.../db/sql/statement/filter/FunctionFilter.java | 48 +
.../iotdb/db/sql/statement/filter/InFilter.java | 201 +
.../iotdb/db/sql/statement/filter/LikeFilter.java | 134 +
.../iotdb/db/sql/statement/filter/QueryFilter.java | 295 +
.../db/sql/statement/filter/RegexpFilter.java | 134 +
.../iotdb/db/sync/conf/SyncSenderDescriptor.java | 2 +-
.../iotdb/db/sync/receiver/SyncServerManager.java | 10 +-
.../db/sync/receiver/SyncServerManagerMBean.java | 2 +-
.../db/sync/receiver/load/FileLoaderManager.java | 4 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 4 +-
.../db/sync/sender/manage/SyncFileManager.java | 4 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 4 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 2 +-
.../db/tools/virtualsg/DeviceMappingViewer.java | 12 +-
.../java/org/apache/iotdb/db/utils/AuthUtils.java | 4 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 75 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 51 +
.../java/org/apache/iotdb/db/utils/MemUtils.java | 2 +-
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 2 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 7 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 6 +-
.../java/org/apache/iotdb/db/utils/TestOnly.java | 34 -
.../org/apache/iotdb/db/utils/ThreadUtils.java | 2 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 4 +-
.../db/utils/datastructure/AlignedTVList.java | 2 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../iotdb/db/utils/datastructure/TimeSelector.java | 18 +
.../timerangeiterator/AggrWindowIterator.java | 149 +
.../timerangeiterator/ITimeRangeIterator.java | 37 +
.../timerangeiterator/PreAggrWindowIterator.java | 142 +
.../PreAggrWindowWithNaturalMonthIterator.java | 109 +
.../TimeRangeIteratorFactory.java | 69 +
.../windowing/runtime/WindowEvaluationTask.java | 2 +-
.../runtime/WindowEvaluationTaskPoolManager.java | 6 +-
.../utils/windowing/window/EvictableBatchList.java | 2 +-
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 2 +-
.../writelog/manager/MultiFileLogNodeManager.java | 8 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 4 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 6 +-
.../iotdb/db/writelog/recover/RecoverResult.java | 18 +
.../writelog/recover/TsFileRecoverPerformer.java | 84 +-
... => org.apache.iotdb.metrics.reporter.Reporter} | 0
.../IoTDBDefaultThreadExceptionHandlerTest.java | 80 -
.../db/concurrent/IoTDBThreadPoolFactoryTest.java | 218 -
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 2 +
.../strategy/DirectoryStrategyTest.java | 24 +-
.../iotdb/db/engine/MetadataManagerHelper.java | 50 +-
.../iotdb/db/engine/cache/ChunkCacheTest.java | 10 +-
.../engine/compaction/AbstractCompactionTest.java | 10 +-
.../engine/compaction/CompactionSchedulerTest.java | 154 +-
.../compaction/CompactionTaskManagerTest.java | 104 +-
.../db/engine/compaction/CompactionUtilsTest.java | 12 +-
.../compaction/TestUtilsForAlignedSeries.java | 6 +-
.../db/engine/compaction/TsFileIdentifierUT.java | 6 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 75 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 22 +-
.../db/engine/compaction/cross/MergeTest.java | 10 +-
.../engine/compaction/cross/MergeUpgradeTest.java | 7 +-
.../cross/RewriteCompactionFileSelectorTest.java | 606 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 281 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 4 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 12 +-
.../compaction/inner/InnerCompactionLogTest.java | 4 +-
.../inner/InnerCompactionMoreDataTest.java | 8 +-
.../inner/InnerCompactionSchedulerTest.java | 8 +-
.../compaction/inner/InnerCompactionTest.java | 12 +-
.../compaction/inner/InnerSeqCompactionTest.java | 8 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 101 +-
.../InnerSpaceCompactionUtilsAlignedTest.java | 4 +-
.../InnerSpaceCompactionUtilsNoAlignedTest.java | 98 +-
.../inner/InnerSpaceCompactionUtilsOldTest.java | 16 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 8 +-
.../SizeTieredCompactionRecoverTest.java | 395 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 12 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 414 +
.../SizeTieredCompactionRecoverCompatibleTest.java | 294 +
.../recover/SizeTieredCompactionRecoverTest.java | 97 +-
.../compaction/utils/CompactionCheckerUtils.java | 5 +
.../compaction/utils/CompactionClearUtils.java | 9 +-
.../compaction/utils/CompactionConfigRestorer.java | 6 +-
.../utils/CompactionFileGeneratorUtils.java | 2 +-
.../engine/modification/DeletionFileNodeTest.java | 4 +-
.../db/engine/modification/DeletionQueryTest.java | 4 +-
.../storagegroup/FileNodeManagerBenchmark.java | 8 +-
.../storagegroup/StorageGroupProcessorTest.java | 8 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 18 +-
.../db/engine/storagegroup/TsFileManagerTest.java | 2 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 228 -
.../iotdb/db/metadata/MManagerBasicTest.java | 2487 -----
.../iotdb/db/metadata/MManagerImproveTest.java | 191 -
.../org/apache/iotdb/db/metadata/MTreeTest.java | 1060 --
.../db/metadata/SchemaEngineAdvancedTest.java | 228 +
.../iotdb/db/metadata/SchemaEngineBasicTest.java | 2602 +++++
.../iotdb/db/metadata/SchemaEngineImproveTest.java | 186 +
.../org/apache/iotdb/db/metadata/TemplateTest.java | 110 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 61 +-
.../db/metadata/idtable/InsertWithIDTableTest.java | 18 +-
.../iotdb/db/metadata/mlog/MLogUpgraderTest.java | 176 -
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 292 +
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 796 ++
.../db/metadata/rocksdb/MRocksDBBenchmark.java | 43 +-
.../db/metadata/rocksdb/MRocksDBUnitTest.java | 125 +-
.../rocksdb/RSchemaReadWriteHandlerTest.java | 57 +
.../metadata/rocksdb/RocksDBBenchmarkEngine.java | 14 +-
.../rocksdb/RocksDBReadWriteHandlerTest.java | 57 -
.../db/metadata/upgrade/MetadataUpgradeTest.java | 304 +
.../db/mpp/sql/plan/DistributionPlannerTest.java | 127 +
.../influxdb/sql/InfluxDBLogicalGeneratorTest.java | 68 +
.../iotdb/db/protocol/rest/IoTDBRestServiceIT.java | 2 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 60 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 6 +-
.../iotdb/db/qp/physical/ConcatOptimizerTest.java | 18 +-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 12 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 10 +-
.../db/qp/physical/PhysicalPlanSerializeTest.java | 2 +
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 14 +-
.../iotdb/db/qp/physical/SerializationTest.java | 14 +-
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 43 +
.../iotdb/db/qp/sql/IoTDBsqlVisitorTest.java | 2 +-
.../dataset/EngineDataSetWithValueFilterTest.java | 2 +-
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 14 +-
.../query/dataset/groupby/GroupByDataSetTest.java | 226 +
.../dataset/groupby/GroupByEngineDataSetTest.java | 504 -
.../dataset/groupby/GroupByFillDataSetTest.java | 2 +-
.../dataset/groupby/GroupByLevelDataSetTest.java | 2 +-
.../dataset/groupby/GroupByTimeDataSetTest.java | 636 +-
.../query/reader/series/SeriesReaderTestUtil.java | 10 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 12 +-
.../iotdb/db/sql/StatementGeneratorTest.java | 75 +
.../db/sync/receiver/load/FileLoaderTest.java | 14 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 14 +-
.../db/sync/sender/manage/SyncFileManagerTest.java | 4 +-
.../sender/recover/SyncSenderLogAnalyzerTest.java | 6 +-
.../sync/sender/recover/SyncSenderLoggerTest.java | 2 +-
.../db/sync/sender/transfer/SyncClientTest.java | 2 +-
.../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 2 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 113 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 8 +-
.../iotdb/db/utils/TimeRangeIteratorTest.java | 220 +
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 23 +-
.../db/utils/datastructure/TimeSelectorTest.java | 22 +
.../iotdb/db/writelog/IoTDBLogFileSizeTest.java | 2 +-
.../apache/iotdb/db/writelog/PerformanceTest.java | 10 +-
.../db/writelog/recover/DeviceStringTest.java | 12 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 4 +-
.../recover/RecoverResourceFromReaderTest.java | 12 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 14 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 12 +-
server/src/test/resources/logback.xml | 4 +-
service-rpc/pom.xml | 2 +-
session/pom.xml | 2 +-
.../java/org/apache/iotdb/session/Session.java | 169 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 239 +-
.../session/IoTDBSessionDisableMemControlIT.java | 11 +-
.../session/IoTDBSessionVectorABDeviceIT.java | 2 +-
.../session/IoTDBSessionVectorAggregationIT.java | 3 +-
.../IoTDBSessionVectorAggregationWithUnSeqIT.java | 2 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 12 +-
.../java/org/apache/iotdb/session/SessionTest.java | 2 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 2 +-
.../apache/iotdb/session/template/TemplateUT.java | 149 +-
site/pom.xml | 2 +-
site/src/main/.vuepress/config.js | 71 +-
site/src/main/.vuepress/redirects | 4 +-
spark-iotdb-connector/pom.xml | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 6 +-
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 3 +-
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 3 +-
.../iotdb/spark/db/unit/DataFrameToolsTest.scala | 4 +-
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 2 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 8 +-
thrift-cluster/pom.xml | 2 +-
thrift-cluster/src/main/thrift/cluster.thrift | 1 +
thrift-confignode/pom.xml | 67 +
.../src/main/thrift/confignode.thrift | 89 +
thrift-influxdb/README.md | 2 +-
thrift-influxdb/pom.xml | 2 +-
thrift-influxdb/src/main/thrift/influxdb.thrift | 19 +
thrift-sync/pom.xml | 2 +-
thrift/pom.xml | 2 +-
thrift/src/main/thrift/rpc.thrift | 2 +
tsfile/README.md | 2 +-
tsfile/pom.xml | 16 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 20 +
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 6 +
.../iotdb/tsfile/encoding/decoder/Decoder.java | 11 +
.../iotdb/tsfile/encoding/decoder/FreqDecoder.java | 140 +
.../tsfile/encoding/decoder/IntZigzagDecoder.java | 94 +
.../tsfile/encoding/decoder/LongZigzagDecoder.java | 101 +
.../iotdb/tsfile/encoding/encoder/FreqEncoder.java | 313 +
.../tsfile/encoding/encoder/IntZigzagEncoder.java | 101 +
.../tsfile/encoding/encoder/LongZigzagEncoder.java | 111 +
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 87 +-
.../tsfile/file/metadata/enums/TSEncoding.java | 8 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 18 +
.../apache/iotdb/tsfile/read/common/RowRecord.java | 8 +
.../read/controller/CachedChunkLoaderImpl.java | 67 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 53 +-
.../read/reader/chunk/AlignedChunkReader.java | 30 +
.../chunk/AlignedChunkReaderByTimestamp.java | 47 -
.../tsfile/read/reader/chunk/ChunkReader.java | 24 +
.../read/reader/chunk/ChunkReaderByTimestamp.java | 44 -
.../reader/series/FileSeriesReaderByTimestamp.java | 13 +-
.../apache/iotdb/tsfile/utils/BitConstructor.java | 93 +
.../org/apache/iotdb/tsfile/utils/BitReader.java | 70 +
.../org/apache/iotdb/tsfile/utils/Constants.java | 93 +
.../iotdb/tsfile/utils/MeasurementGroup.java | 3 +-
.../iotdb/tsfile/utils/RamUsageEstimatorV2.java | 567 +
.../write/chunk/AlignedChunkGroupWriterImpl.java | 9 +-
.../chunk/NonAlignedChunkGroupWriterImpl.java | 6 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 12 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 25 +-
.../tsfile/encoding/decoder/FreqDecoderTest.java | 161 +
.../encoding/decoder/IntZigzagDecoderTest.java | 99 +
.../encoding/decoder/LongZigzagDecoderTest.java | 94 +
.../iotdb/tsfile/read/reader/ChunkReaderTest.java | 109 +
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 3 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 99 +
zeppelin-interpreter/pom.xml | 2 +-
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 2 +-
1214 files changed, 85701 insertions(+), 48068 deletions(-)
create mode 100644 antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4
delete mode 100644 antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/IoTDBSqlLexer.g4
create mode 100644 antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4
create mode 100644 client-py/iotdb/utils/NumpyTablet.py
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDBServerCommandLine.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/metadata/CMManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/metadata/CSchemaEngine.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/partition/MManagerWhiteBox.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/partition/SchemaEngineWhiteBox.java
create mode 100644 confignode/pom.xml
create mode 100644 confignode/src/assembly/confignode.xml
create mode 100644 confignode/src/assembly/resources/conf/confignode-env.bat
create mode 100644 confignode/src/assembly/resources/conf/confignode-env.sh
create mode 100644 confignode/src/assembly/resources/conf/iotdb-confignode.properties
copy {server => confignode}/src/assembly/resources/conf/jmx.access (100%)
copy {server => confignode}/src/assembly/resources/conf/jmx.password (100%)
create mode 100644 confignode/src/assembly/resources/sbin/start-confignode.bat
create mode 100644 confignode/src/assembly/resources/sbin/start-confignode.sh
create mode 100644 confignode/src/assembly/resources/sbin/stop-confignode.bat
create mode 100644 confignode/src/assembly/resources/sbin/stop-confignode.sh
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConf.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfCheck.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConstant.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/exception/ConfigNodeException.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/DataPartitionRule.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/PartitionTable.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNodeCommandLine.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNodeMBean.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/balancer/LoadBalancer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/basic/ConfigServiceProvider.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServer.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerMBean.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServerProcessor.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/server/ConfigNodeRPCServiceHandler.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/hash/DeviceGroupHashExecutorTest.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/utils/ConfigNodeEnvironmentUtils.java
create mode 100644 consensus/pom.xml
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/IConsensus.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusGroup.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusGroupId.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/DataSet.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/Endpoint.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/GroupType.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/Peer.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/request/ByteBufferConsensusRequest.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusGenericResponse.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusReadResponse.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusResponse.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusWriteResponse.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusException.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupAlreadyExistException.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupNotExistException.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/exception/IllegalPeerNumException.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneConsensus.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneServerImpl.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/statemachine/EmptyStateMachine.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/statemachine/IStateMachine.java
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/standalone/StandAloneConsensusTest.java
create mode 100644 docker/src/main/Dockerfile-0.12.3-cluster
create mode 100644 docker/src/main/Dockerfile-0.12.3-grafana
create mode 100644 docker/src/main/Dockerfile-0.12.3-node
create mode 100644 docker/src/main/Dockerfile-0.12.4-cluster
create mode 100644 docker/src/main/Dockerfile-0.12.4-grafana
create mode 100644 docker/src/main/Dockerfile-0.12.4-node
create mode 100644 docker/src/main/Dockerfile-0.12.5-cluster
create mode 100644 docker/src/main/Dockerfile-0.12.5-grafana
create mode 100644 docker/src/main/Dockerfile-0.12.5-node
create mode 100644 docker/src/main/Dockerfile-0.13.0-cluster
create mode 100644 docker/src/main/Dockerfile-0.13.0-grafana
create mode 100644 docker/src/main/Dockerfile-0.13.0-node
delete mode 100644 docs/UserGuide/Process-Data/UDF-Library.md
create mode 100644 docs/UserGuide/UDF-Library/Anomaly-Detection.md
create mode 100644 docs/UserGuide/UDF-Library/Data-Matching.md
create mode 100644 docs/UserGuide/UDF-Library/Data-Profiling.md
create mode 100644 docs/UserGuide/UDF-Library/Data-Quality.md
create mode 100644 docs/UserGuide/UDF-Library/Data-Repairing.md
create mode 100644 docs/UserGuide/UDF-Library/Frequency-Domain.md
create mode 100644 docs/UserGuide/UDF-Library/M4.md
create mode 100644 docs/UserGuide/UDF-Library/Quick-Start.md
create mode 100644 docs/UserGuide/UDF-Library/Series-Discovery.md
create mode 100644 docs/UserGuide/UDF-Library/String-Processing.md
delete mode 100644 docs/zh/UserGuide/Process-Data/UDF-Library.md
create mode 100644 docs/zh/UserGuide/UDF-Library/Anomaly-Detection.md
create mode 100644 docs/zh/UserGuide/UDF-Library/Data-Matching.md
create mode 100644 docs/zh/UserGuide/UDF-Library/Data-Profiling.md
create mode 100644 docs/zh/UserGuide/UDF-Library/Data-Quality.md
create mode 100644 docs/zh/UserGuide/UDF-Library/Data-Repairing.md
create mode 100644 docs/zh/UserGuide/UDF-Library/Frequency-Domain.md
create mode 100644 docs/zh/UserGuide/UDF-Library/M4.md
create mode 100644 docs/zh/UserGuide/UDF-Library/Quick-Start.md
create mode 100644 docs/zh/UserGuide/UDF-Library/Series-Discovery.md
create mode 100644 docs/zh/UserGuide/UDF-Library/String-Processing.md
delete mode 100644 flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatIT.java
create mode 100644 flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTSRecordOutputFormatIntegrationTest.java
delete mode 100644 flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatIT.java
create mode 100644 flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/RowTsFileInputFormatIntegrationTest.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IOTDBGroupByIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IOTDBGroupByInnerIntervalIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCompactionWithIDTableIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateSnapshotIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByFillIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByFillMixPathsIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByFillWithRangeIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByMonthFillIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByMonthIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByUnseqIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryWithRecreatedTimeseriesIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBResultMetadataIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupBySlidingWindowQueryWithValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupBySlidingWindowQueryWithoutValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IOTDBGroupByIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IOTDBGroupByInnerIntervalIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByFillIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByFillMixPathsIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByFillWithRangeIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByMonthFillIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByMonthIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByUnseqIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/withoutNullFilter/IoTDBWithoutNullAllFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/withoutNullFilter/IoTDBWithoutNullAnyFilterIT.java
create mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/DropwizardMetricsExporter.java
create mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/MetricType.java
create mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/PrometheusTextWriter.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/prometheus/DropwizardMetricsExporter.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/prometheus/MetricType.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/prometheus/PrometheusReporter.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/prometheus/PrometheusSender.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/prometheus/PrometheusTextWriter.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/prometheus/PushGateway.java
delete mode 100644 metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/reporter/prometheus/TextFormat.java
rename metrics/dropwizard-metrics/src/main/resources/META-INF/services/{org.apache.iotdb.metrics.Reporter => org.apache.iotdb.metrics.reporter.Reporter} (100%)
delete 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/Reporter.java
create 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/Reporter.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MetricLevel.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/OutPutFormat.java
delete mode 100644 metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/MeterIdUtils.java
create mode 100644 metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/MetricName.java
rename metrics/micrometer-metrics/src/main/resources/META-INF/services/{org.apache.iotdb.metrics.Reporter => org.apache.iotdb.metrics.reporter.Reporter} (100%)
create mode 100644 node-commons/pom.xml
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/ServerCommandLine.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/HashLock.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/IoTDBDaemonThreadFactory.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/IoTDBDefaultThreadExceptionHandler.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/IoTDBThreadPoolFactory.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/IoTThreadFactory.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/ThreadName.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/WrappedRunnable.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/IThreadPoolMBean.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/WrappedScheduledExecutorService.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/WrappedScheduledExecutorServiceMBean.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/WrappedSingleThreadExecutorService.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/WrappedSingleThreadExecutorServiceMBean.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/WrappedSingleThreadScheduledExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/WrappedSingleThreadScheduledExecutorMBean.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/WrappedThreadPoolExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/concurrent/threadpool/WrappedThreadPoolExecutorMBean.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/conf/IoTDBConstant.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/ConfigurationException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/IoTDBException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/ShutdownException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/StartupException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/exception/runtime/RPCServiceException.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/APHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/BKDRHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/DeviceGroupHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/JSHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/SDBMHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/AbstractThriftServiceThread.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/IService.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/JMXService.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/RegisterManager.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/ServiceType.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/StartupCheck.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/StartupChecks.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/ThriftService.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/ThriftServiceThread.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/JVMCommonUtils.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/TestOnly.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/IoTDBDefaultThreadExceptionHandlerTest.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/IoTDBThreadPoolFactoryTest.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/HashLock.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/IoTDBDaemonThreadFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/IoTDBDefaultThreadExceptionHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/IoTThreadFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/ThreadName.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/WrappedRunnable.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/IThreadPoolMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedScheduledExecutorService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedScheduledExecutorServiceMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedSingleThreadExecutorService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedSingleThreadExecutorServiceMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedSingleThreadScheduledExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedSingleThreadScheduledExecutorMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedThreadPoolExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/concurrent/threadpool/WrappedThreadPoolExecutorMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/conf/IoTDBConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusExample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/statemachine/BaseStateMachine.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/statemachine/SchemaRegionStateMachine.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/manage/CrossSpaceCompactionResource.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/manage/CrossSpaceMergeResource.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/recover/RewriteCrossSpaceCompactionLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/recover/RewriteCrossSpaceCompactionLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/SizeTieredCompactionLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/SizeTieredCompactionLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/log/CompactionLogAnalyzer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/log/CompactionLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/CQLogReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cq/CQLogWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/ConfigurationException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/IoTDBException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/ShutdownException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/StartupException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/SchemaDirCreationFailureException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/runtime/RPCServiceException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/runtime/SQLParserException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sql/SQLParserException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sql/StatementAnalyzeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/IMetaManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/ISchemaEngine.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/IStorageGroupSchemaManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/MManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/SchemaEngine.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/SchemaRegion.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/StorageGroupSchemaManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogUpgrader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/MTree.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/MTreeAboveSG.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/MTreeBelowSG.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/MNodeAboveSGCollector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MNodeAboveSGLevelCounter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/TimeseriesStatistics.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/MRocksDBManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/MetaDataTransfer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RMNodeValueType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RSchemaConstants.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RSchemaEngine.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RSchemaLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RSchemaReadWriteHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RSchemaUtils.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RockDBConstants.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RockDBLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RocksDBMNodeType.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RocksDBReadWriteHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/RocksDBUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/SchemaDataTransfer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/mnode/RMNodeType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/mnode/RMNodeValueType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateLogReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateLogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/upgrade/MetadataUpgrader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/SinkHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/SourceHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/Analysis.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/DataRegion.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/DataRegionTimeSlice.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/FillPolicy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/FilterNullPolicy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/FragmentId.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/FragmentInstanceId.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/GroupByTimeParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/MPPQueryContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/QueryId.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/QuerySession.java
create 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/common/TsBlock.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/TsBlockMetadata.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/Coordinator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/ExecFragmentInstance.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceState.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentState.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryStateMachine.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/ClusterScheduler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/IScheduler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/StandaloneScheduler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/Operator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/OperatorContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/SeriesScanOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/AggregateOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/DeviceMergeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/FillOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/FilterNullOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/GroupByLevelOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/LimitOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/OffsetOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/ProcessOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/SortOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/TimeJoinOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/sink/FragmentSinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/sink/SinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/source/SeriesAggregateScanOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/source/SeriesScanOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/source/SourceOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/LocalExecutionPlanner.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/optimization/PlanOptimizer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/DistributedQueryPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/DistributionPlanner.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/FragmentInstance.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/LogicalPlanner.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/LogicalQueryPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/PlanFragment.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/PlanFragmentId.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNodeId.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNodeIdAllocator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNodeUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/SimplePlanNodeRewriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/ShowDevicesNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/ShowNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/AggregateNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/DeviceMergeNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/ExchangeNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/FillNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/FilterNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/FilterNullNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/GroupByLevelNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/LimitNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/OffsetNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/ProcessNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/SortNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/TimeJoinNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/CsvSinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/FragmentSinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/SinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/ThriftSinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/CsvSourceNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/SeriesAggregateScanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/SeriesScanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/SourceNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertMultiTabletNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertRowNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertRowsNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertRowsOfOneDeviceNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertTabletNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/tree/Expression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/constant/InfluxConstant.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/constant/InfluxDBConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/constant/InfluxSQLConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/InfluxFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/InfluxFunctionFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/InfluxFunctionValue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/aggregator/InfluxAggregator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/aggregator/InfluxCountFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/aggregator/InfluxMeanFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/aggregator/InfluxMedianFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/aggregator/InfluxModeFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/aggregator/InfluxSpreadFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/aggregator/InfluxStddevFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/aggregator/InfluxSumFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/selector/InfluxFirstFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/selector/InfluxLastFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/selector/InfluxMaxFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/selector/InfluxMinFunction.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/function/selector/InfluxSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/handler/QueryHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/operator/InfluxQueryOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/operator/InfluxSelectComponent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBLogicalGenerator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBSqlVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/util/CommonUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/util/FieldUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/util/FilterUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/util/QueryResultUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/util/StringUtils.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreateSnapshotOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateSnapshotPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/RemovableAggregateResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/AlignedGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByEngineDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeDataSet.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeEngineDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalAlignedGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/AlignedGroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/GroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/SlidingWindowGroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/SlidingWindowGroupByExecutorFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/EmptyQueueSlidingWindowGroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/LocalAlignedGroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/LocalGroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/MonotonicQueueSlidingWindowGroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/NormalQueueSlidingWindowGroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/SmoothQueueSlidingWindowGroupByExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFContinuouslySatisfy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFInRange.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFNonZeroCount.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFNonZeroDuration.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFOnOff.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFZeroCount.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFZeroDuration.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/IService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/JMXService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/RegisterManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/ServiceType.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/StartupCheck.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/StartupChecks.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/ThriftService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/ThriftServiceThread.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/constant/FilterConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/constant/StatementType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/parser/ASTVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/parser/StatementGenerator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/AggregationQueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/FillQueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/GroupByFillQueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/GroupByQueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/LastQueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/QueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/ShowDevicesStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/ShowTimeSeriesStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/Statement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/UDAFQueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/UDTFQueryStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/FillComponent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/FromComponent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/GroupByLevelComponent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/GroupByTimeComponent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/OrderBy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/ResultColumn.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/ResultSetFormat.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/SelectComponent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/WhereCondition.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/component/WithoutPolicy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/filter/BasicFilterType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/filter/BasicFunctionFilter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/filter/FunctionFilter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/filter/InFilter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/filter/LikeFilter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/filter/QueryFilter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sql/statement/filter/RegexpFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/TestOnly.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/AggrWindowIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/ITimeRangeIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowWithNaturalMonthIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/TimeRangeIteratorFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/recover/RecoverResult.java
rename server/src/main/resources/META-INF/services/{org.apache.iotdb.metrics.Reporter => org.apache.iotdb.metrics.reporter.Reporter} (100%)
delete mode 100644 server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBDefaultThreadExceptionHandlerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/recover/RewriteCrossSpaceCompactionRecoverCompatibleTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/recover/SizeTieredCompactionRecoverCompatibleTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/MManagerAdvancedTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/MManagerBasicTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/MManagerImproveTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/MTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/SchemaEngineAdvancedTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/SchemaEngineBasicTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/SchemaEngineImproveTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mlog/MLogUpgraderTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/MTreeAboveSGTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/MTreeBelowSGTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/rocksdb/RSchemaReadWriteHandlerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/rocksdb/RocksDBReadWriteHandlerTest.java
create 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/sql/plan/DistributionPlannerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBLogicalGeneratorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/qp/sql/ASTVisitorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByEngineDataSetTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sql/StatementGeneratorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/TimeRangeIteratorTest.java
create mode 100644 thrift-confignode/pom.xml
create mode 100644 thrift-confignode/src/main/thrift/confignode.thrift
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/FreqDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/IntZigzagDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/LongZigzagDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/FreqEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/IntZigzagEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/LongZigzagEncoder.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/AlignedChunkReaderByTimestamp.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/ChunkReaderByTimestamp.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/utils/BitConstructor.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/utils/BitReader.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/utils/Constants.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/utils/RamUsageEstimatorV2.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/FreqDecoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/IntZigzagDecoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/LongZigzagDecoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/ChunkReaderTest.java