You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2023/02/27 01:28:17 UTC
[iotdb] branch lmh/exchangeMem updated (93a96c3fa9 -> 04d5fccb29)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/exchangeMem
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 93a96c3fa9 add UT
add c83d8c814d Add logs for LACK_DATA_PARTITION_ALLOCATION and DiskSpaceWarningThreshold triggering (#8968)
add 2ad3a7a1c7 update wal file version after next file has been created (#8994)
add cf5a51a5e8 [IOTDB-5341] Support GROUP BY VARIATION in aggregation query (front end part) (#8941)
add 4d8507afa5 [IOTDB-5478] Fix incorrect query filter after binding schema and removing wildcard (#8996)
add 64af71b2e0 Fix a part of bad url in the official documentation (#8991)
add 86c46dca1a [IoTDB-5457]java native api has not been support modified template (#8965)
add df298dc83f [IOTDB-5495]Improve unit tests about show devices (#9006)
add ab9189c22b Eliminate useless isDefaultSchemaMemoryConfig (#9008)
add ce0ad2d483 [IOTDB-5021] Using Junit parameterized test to optimize schema IT framework (#8097)
add 4834c1fc3a [IOTDB-5496] Rename VerticallyConcatOperator as HorizontallyConcatOperator
add 0a68bb7f39 [IOTDB-5499] Eliminate useless log during auto creating schema (#9013)
add ed34105697 [IOTDB-5498] Fix SessionPool OOM when the numbers of devices and sessions are large (#9012)
add 302391ce82 Fix IT error by parallel suites (#9016)
add a77571f63a Correct DataPartiton Fetch request parameter contruction (#8953)
add 6944a5c3c0 [IOTDB-5451] Support cluster Database heterogeneous by ALTER SQL (#8971)
add dfd6d3d9fa [IOTDB-5479] Optimize the wal impl of confignode simple consensus (#8997)
add 3623ca006c change default cross performer and inner unseq performer to FAST (#9004)
add 4b5f4ff5ed Skip broken tsfile when recovering system (#9003)
add 61ef21ae22 [IOTDB-5510] Block and wait to create timeseries when releasing memory (#9030)
add 4abad1cdac [IOTDB-5477] Refactor the interaction between InsertNode and SchemaFetcher (#8993)
add f60fd2044f [IOTDB-5504] Fix illegal argument exception occurs when scheduling compaction
add 5dd2031ab4 [IOTDB-5474] Fix count nodes using level bug (#9035)
add 5f8f2b9f88 [IOTDB-5021] Adapting all schemaIT to add Schema_File mode (#9034)
add 87574002be [IOTDB-5488] Fix set system to readonly on local (#9032)
add 10fd7eb215 [IOTDB-5470] Refactor compaction metrics (#9033)
add 2b05d8ca35 [IOTDB-5501] Fix memory leak in MemoryPool
add e67f8909ec Bump spring-boot-starter-web in /grafana-connector (#5424)
add 6571374982 Bump commons-compress from 1.9 to 1.21 in /hive-connector (#9037)
add b239efe75d [IOTDB-5514] Fix race condition in MemoryPool without synchronized block (#9041)
add 66611b1d1c [IOTDB-5513] Fix duplicate LastQueryNode due to change of partition slot algorithm (#9040)
add 0ac0fb57e8 [IOTDB-5502] Source counters for construct batches in IoTConsensus (#9023)
add bca08f0f26 [IOTDB-5491] Add IoTConsumus memory control metric items (#9022)
add adf55e896e [IOTDB-4209] Use .pst to accelerate recovery in SchemaFile mode (#7995)
add 1e2da83d83 [IOTDB-5497] Test for ConfigNode consensus efficiency (#9015)
add ab8130a74e [IOTDB-5505] Bump Ratis version to latest 2.4.2-snapshot (#9027)
add 344962356b [IOTDB-5480] IoTConsensus sync lag may be negative under single copy (#9031)
add a9168656d6 [IOTDB-5337] Parallelization of write operation in FragmentInstanceDispatcher (#8920)
add 8a1eb28efa [IOTDB-5506] Refactor RatisConsensus(#9029)
add 33719b66b3 [IOTDB-5456]Implement COUNT_IF built-in aggregation function
add 8438f41d32 [IOTDB-5458] Add Performance Overview Metrics and Dashboard (#8982)
add 199b9367c3 [IOTDB-5485] Rename StorageGroup to Database in ConfigNode (#9028)
add d0d89a1ed7 [IOTDB-5393] Show Region creation time when execute show regions (#8958)
add e718dd8a30 [IOTDB-5531] Update IoT Consensus Metric from ms precision to ns precision (#9058)
add 251fc9a040 update download url in website (#9057)
add 4631c7f8e6 [IOTDB-5526] Fix NPE while construct timeseries black list in SchemaRegion (#9055)
add eaee1d8dbf [IOTDB-4005] Add degree of parallelism to pipeline engine
add d7241c2903 [IOTDB-5509] Add level control for cross compaction selecting (#9059)
add 821e1756ed [IOTDB-5515] Support GROUP BY SERIES in aggregation query
add c577012169 [IOTDB-4005] Optimize the pipeline build logic for consumeAllNode
add bc34211891 Fix typo in README.md (#9065)
add 077704ecfa Fix bad url in the official documentation (#9060)
add d6135299cb [IOTDB-5474] Refactor DataNodeSchemaCache Structure (#9050)
add bba7c65cc3 [IOTDB-5480][IOTDB-5491][IOTDB-5502] Update DataNode Dashboard (#9063)
add a1df687753 [IOTDB-5469] create template with backquote characters successfully but get schema info failed (#9073)
add 2d508f7dd7 [IOTDB-5112] Fixed IoTConsensus synchronization stuck under low load or during restart (#9064)
add 3ca4f8fa13 Fix device alignment check during data insertion (#9079)
add c20cde60aa Finish (#9077)
add 1fff33b317 Fix concurrency problem (#9076)
add 1a69b40c4c [IOTDB-5528] Refactor schema engine and region statistics (#9052)
add 1b4631c182 [IOTDB-5517] Add metrics for disk io (#9054)
add 82389195ef [IOTDB-5547] Bug fix: driver will release resources concurrently which leads to concurrentModify
add 78d233ba3e [IOTDB-5189][IOTDB-5529]Optimize the memory usage and execution of fast compaction (#9048)
add 20a82d8a10 [IOTDB-5549] Ensure concurrently MNode memory release (#9089)
add ce5df3cfc9 [Website] Add Grafana plugin download link for v0.13.4 (#9092)
add 0cd44616f8 Improve the document of FREQ encoding (#9095)
add 21c2110ef5 [IOTDB-5512] Fixed IoTConsensus may repeatedly send some log when restarting (#9074)
add 79ea9c36eb [IOTDB-5548] Fix typo in ASTVisitor.createSchemaTemplate and ASTvisitor.parseIdentifier (#9086)
add c7702dcf40 [IOTDB-5463] Support pushdowning limit offset condition to SeriesScanUtil
add 91045d9b3c [IOTDB-5517] Add metrics for disk io (#9094)
add e14325d94d [IOTDB-5560] Increase default consensusLogAppenderBufferSize from 4M to 16M to reduce the probability of large request write failures (#9101)
add 8605ae4952 [IOTDB-5533] Make IoTDB Internal Reporter as default
add 8f8652f25b [IOTDB-5553] Fix NPE while using count_if (contains keep expression) with group by level (#9100)
add 6ace6afa08 [IOTDB-4438] Add session window in RawDataAggregationOperator window management framework
add 9816ea3074 [IOTDB-5556] Gracefully exit Cluster Nodes through stop script (#9102)
add 4127dc0012 [IOTDB-5561] Fix NPE of SchemaRegionTemplateTest.testDeactivateTemplate (#9105)
add e204dddfc8 [IOTDB-5562] Change the data type of AutoGuage from long to double in metric module (#9107)
add 4dcd5641fc [IOTDB-5512] Fixed same flushIndex situation (#9111)
add 55e8678c3d Update Template.md (#9110)
add d90819f45c modify README.md for release 1.0.1 (#9114)
add d6e015eab1 [IOTDB-5517] Add metrics for disk io (#9113)
add 16c1c9efab Fix python IT fail caused by the database root.__system (#9116)
add bb7973f564 [IOTDB-5516] Try sync delete schema region when dropping database (#9108)
add 99ea2c9f7e [IOTDB-5546] Allow consumeAllOperator to run when only some of children is blocked
add 63e88d9221 feat(site): 1. Add Page RightMenu 2. Enable Algolia Search 3. Add ESLint And Fix config.js (#9125)
add ee49665f4d [IOTDB-5524] Add Metrics for Schema Module (#9109)
add b20758ac56 [IOTDB-5516] Accelerate async delete DataRegion during dropping database (#9120)
add 3a4aee19cc Fix CI error by ignore license check for some site files (#9127)
add 92358e9d30 [IOTDB-5577] Metric dashboard for Schema Module (#9135)
add a2c935aa68 [IOTDB-5533] Add IoTDB Internal Reporter params back and Modify the config of root.__system (#9119)
add 081b44d4d6 feat(WebSite) :DocSearch Filter By Version (#9134)
add 8238428d3c [IOTDB-4005] Allow the following child pipeline to run in advance
add 753d3f29fb [IOTDB-5559] Implement metric exporters for RatisConsensus (#9099)
add 6f02e5888a Remove 0.8-0.12 docs & fix the bad urls on the master branch (#9091)
add a25af89278 Add a paper to the Publication_zh doc (#9067)
add 854e4c8b9c [IOTDB-5454] Support shuffle function of DataExchangeModule
add a3869ec324 [IOTDB-5147]Optimize compaction schedule when priority is BALANCE (#9103)
add 2f385d4067 Update nifi doc (#9051)
add 1c040f28db Fix some broken links in README (#9066)
add de6d1526bd [IOTDB-5578] Keep CacheMemoryManager monitor alive when exception (#9133)
add ce0c43263f [IOTDB-5524] Update metric docs for schema module (#9136)
add 06bb621a99 Modify Group-By UserGuide
add 468c0fbd19 [IOTDB-5542] ConfigNode counter dashboard (#9129)
add 5920e65a20 [IOTDB-5581] Missing reset of aggregators in RawDataAggregationOperator
add ad93ca04fb [IOTDB-5575] Pipe SDK: PipeProcessor & PipeConnector (#9131)
add 415f68e36b [IOTDB-4898] Push offset and limit down to ScanOperator if possible
add aa94bbd83d Merge remote-tracking branch 'origin/master' into lmh/exchangeMem
add 04d5fccb29 update
No new revisions were added by this update.
Summary of changes:
.github/workflows/site-build.yml | 6 +-
README.md | 6 +-
README_ZH.md | 4 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 3 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 27 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 12 +
client-py/iotdb/sqlalchemy/tests/test_dialect.py | 2 +-
client-py/tests/test_dataframe.py | 4 +-
client-py/tests/test_todf.py | 6 +-
.../confignode/client/ConfigNodeRequestType.java | 3 +-
.../client/async/AsyncDataNodeClientPool.java | 7 +
.../client/sync/SyncConfigNodeClientPool.java | 2 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 16 +-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 11 +-
.../confignode/conf/ConfigNodeDescriptor.java | 8 +
.../confignode/conf/ConfigNodeStartupCheck.java | 1 +
.../consensus/request/ConfigPhysicalPlan.java | 37 +-
.../consensus/request/ConfigPhysicalPlanType.java | 15 +-
.../CountDatabasePlan.java} | 25 +-
.../GetDatabasePlan.java} | 13 +-
.../request/read/region/GetRegionInfoListPlan.java | 6 +-
.../PollSpecificRegionMaintainTaskPlan.java} | 56 +-
...orageGroupPlan.java => DatabaseSchemaPlan.java} | 29 +-
...orageGroupPlan.java => DeleteDatabasePlan.java} | 19 +-
...geGroupPlan.java => PreDeleteDatabasePlan.java} | 33 +-
.../response/{ => auth}/PermissionInfoResp.java | 2 +-
.../consensus/response/{ => cq}/ShowCQResp.java | 3 +-
.../CountDatabaseResp.java} | 11 +-
.../DatabaseSchemaResp.java} | 25 +-
.../response/{ => datanode}/ConfigurationResp.java | 3 +-
.../{ => datanode}/DataNodeConfigurationResp.java | 3 +-
.../{ => datanode}/DataNodeRegisterResp.java | 3 +-
.../{ => datanode}/DataNodeToStatusResp.java | 4 +-
.../response/{ => function}/FunctionTableResp.java | 2 +-
.../{ => partition}/DataPartitionResp.java | 2 +-
.../response/{ => partition}/GetRegionIdResp.java | 2 +-
.../{ => partition}/GetSeriesSlotListResp.java | 2 +-
.../{ => partition}/GetTimeSlotListResp.java | 2 +-
.../response/{ => partition}/PathInfoResp.java | 2 +-
.../{ => partition}/RegionInfoListResp.java | 2 +-
.../{ => partition}/SchemaNodeManagementResp.java | 2 +-
.../{ => partition}/SchemaPartitionResp.java | 2 +-
.../consensus/response/{ => pipe}/PipeResp.java | 3 +-
.../response/{ => pipe}/PipeSinkResp.java | 3 +-
.../{ => template}/AllTemplateSetInfoResp.java | 2 +-
.../response/{ => template}/TemplateInfoResp.java | 2 +-
.../{ => template}/TemplateSetInfoResp.java | 2 +-
.../{ => trigger}/TransferringTriggersResp.java | 2 +-
.../{ => trigger}/TriggerLocationResp.java | 2 +-
.../response/{ => trigger}/TriggerTableResp.java | 2 +-
.../consensus/response/{ => udf}/JarResp.java | 2 +-
.../statemachine/ConfigNodeRegionStateMachine.java | 70 +-
.../confignode/manager/ClusterSchemaManager.java | 168 +-
.../iotdb/confignode/manager/ConfigManager.java | 106 +-
.../apache/iotdb/confignode/manager/IManager.java | 45 +-
.../confignode/manager/PermissionManager.java | 8 +-
.../iotdb/confignode/manager/ProcedureManager.java | 14 +-
.../iotdb/confignode/manager/SyncManager.java | 10 +-
.../iotdb/confignode/manager/TriggerManager.java | 10 +-
.../iotdb/confignode/manager/UDFManager.java | 4 +-
.../manager/{ => consensus}/ConsensusManager.java | 42 +-
.../iotdb/confignode/manager/cq/CQManager.java | 2 +-
.../iotdb/confignode/manager/load/LoadManager.java | 35 +-
.../manager/load/LoadManagerMetrics.java | 326 --
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../region/CopySetRegionGroupAllocator.java | 2 +-
.../region/GreedyRegionGroupAllocator.java | 8 +-
.../balancer/region/IRegionGroupAllocator.java | 2 +-
.../manager/node/ClusterNodeStartUtils.java | 21 +-
.../iotdb/confignode/manager/node/NodeManager.java | 24 +-
.../iotdb/confignode/manager/node/NodeMetrics.java | 104 +
.../node/heartbeat/ConfigNodeHeartbeatCache.java | 11 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 4 +-
.../node/heartbeat/NodeHeartbeatSample.java | 20 +-
.../manager/partition/PartitionManager.java | 425 +-
.../manager/partition/PartitionMetrics.java | 353 ++
.../iotdb/confignode/persistence/AuthorInfo.java | 2 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 8 +-
.../iotdb/confignode/persistence/UDFInfo.java | 4 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 2 +-
.../persistence/executor/ConfigPlanExecutor.java | 85 +-
.../persistence/metric/PartitionInfoMetrics.java | 198 -
.../confignode/persistence/node/NodeInfo.java | 2 +-
...itionTable.java => DatabasePartitionTable.java} | 96 +-
.../persistence/partition/PartitionInfo.java | 309 +-
.../persistence/partition/RegionGroup.java | 19 +-
.../partition/maintainer/RegionCreateTask.java | 6 +
.../partition/maintainer/RegionMaintainTask.java | 3 +
.../persistence/schema/ClusterSchemaInfo.java | 229 +-
.../persistence/sync/ClusterSyncInfo.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 23 +-
.../procedure/env/DataNodeRemoveHandler.java | 15 +-
...Procedure.java => DeleteDatabaseProcedure.java} | 121 +-
.../procedure/store/ConfigProcedureStore.java | 2 +-
.../procedure/store/ProcedureFactory.java | 6 +-
.../iotdb/confignode/service/ConfigNode.java | 51 +-
.../confignode/service/ConfigNodeShutdownHook.java | 96 +
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 2 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 208 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 100 +-
.../region/GreedyRegionGroupAllocatorTest.java | 14 +-
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../persistence/ClusterSchemaInfoTest.java | 49 +-
.../confignode/persistence/PartitionInfoTest.java | 20 +-
...eTest.java => DeleteDatabaseProcedureTest.java} | 13 +-
consensus/pom.xml | 2 +-
.../org/apache/iotdb/consensus/common/Utils.java | 23 +-
.../consensus/iot/IoTConsensusServerImpl.java | 34 +-
.../consensus/iot/IoTConsensusServerMetrics.java | 67 +
.../consensus/iot/client/DispatchLogHandler.java | 4 +-
.../iotdb/consensus/iot/logdispatcher/Batch.java | 9 +
.../iot/logdispatcher/IndexController.java | 13 +-
.../logdispatcher/IoTConsensusMemoryManager.java | 24 +-
.../IoTConsensusMemoryManagerMetrics.java | 18 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 31 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 13 +-
.../ratis/ApplicationStateMachineProxy.java | 9 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 16 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 19 +-
.../iotdb/consensus/ratis/RequestMessage.java | 6 +-
.../iotdb/consensus/ratis/ResponseMessage.java | 6 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 9 +-
.../consensus/ratis/metrics/CounterProxy.java | 42 +-
.../iotdb/consensus/ratis/metrics/GaugeProxy.java | 27 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 202 +
.../ratis/metrics/MetricRegistryManager.java | 98 +
.../consensus/ratis/metrics/RatisMetricSet.java | 22 +-
.../consensus/ratis/metrics/RefCountingMap.java | 97 +
.../iotdb/consensus/ratis/metrics/TimerProxy.java | 24 +-
.../org.apache.ratis.metrics.MetricRegistries | 17 +
.../iot/logdispatcher/IndexControllerTest.java | 25 +-
.../iot/logdispatcher/SyncStatusTest.java | 10 +-
docs/Download/README.md | 43 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 2 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 46 +-
.../Data-Concept/Data-Model-and-Terminology.md | 2 +-
docs/UserGuide/Data-Concept/Encoding.md | 4 +-
docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 4 +-
docs/UserGuide/FAQ/Frequently-asked-questions.md | 2 +-
docs/UserGuide/Monitor-Alert/Alerting.md | 4 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 6126 ++++++++++++++------
.../Apache-IoTDB-DataNode-Dashboard.json | 5729 ++++++++++++++----
...ache-IoTDB-Performance-Overview-Dashboard.json} | 2112 ++++---
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 472 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 2 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 98 +-
docs/UserGuide/Query-Data/Align-By.md | 2 +-
docs/UserGuide/Query-Data/Group-By.md | 274 +-
docs/UserGuide/Query-Data/Overview.md | 5 +-
docs/UserGuide/Query-Data/Select-Expression.md | 2 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 8 +
docs/UserGuide/Reference/Status-Codes.md | 1 +
docs/zh/Download/README.md | 42 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 2 +-
.../UserGuide/API/Programming-Java-Native-API.md | 38 +-
.../Data-Concept/Data-Model-and-Terminology.md | 2 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 6 +-
.../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 4 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 2 +-
.../zh/UserGuide/IoTDB-Introduction/Publication.md | 1 +
docs/zh/UserGuide/Monitor-Alert/Alerting.md | 4 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 639 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 2 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 2 +-
.../UserGuide/Operators-Functions/Aggregation.md | 92 +-
docs/zh/UserGuide/Query-Data/Group-By.md | 267 +
docs/zh/UserGuide/Query-Data/Overview.md | 7 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 2 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 31 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 5 +-
docs/zh/UserGuide/Write-Data/Batch-Load-Tool.md | 2 +-
grafana-connector/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
integration-test/checkstyle.xml | 4 +-
integration-test/pom.xml | 12 +-
.../iotdb/it/env/cluster/DataNodeWrapper.java | 1 +
.../iotdb/it/env/cluster/MppCommonConfig.java | 12 +
.../it/env/cluster/MppSharedCommonConfig.java | 14 +
.../iotdb/it/env/remote/RemoteCommonConfig.java | 10 +
.../framework/IoTDBTestRunnerWithParameters.java | 59 +
.../IoTDBTestRunnerWithParametersFactory.java | 17 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +
.../confignode/it/IoTDBClusterAuthorityIT.java | 1 +
.../it/IoTDBConfigNodeConsensusEfficiencyIT.java | 203 +
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 9 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 1 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 57 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 1 +
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 103 +
.../it/cluster/IoTDBClusterRestartIT.java | 6 +-
.../it/database/IoTDBDatabaseRegionControlIT.java | 236 +
.../IoTDBDatabaseSetAndDeleteIT.java} | 85 +-
.../load/IoTDBClusterRegionLeaderBalancingIT.java | 9 +-
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 7 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 20 +-
.../IoTDBCustomRegionGroupExtensionIT.java | 10 +-
.../it/partition/IoTDBPartitionCreationIT.java | 6 +-
.../it/partition/IoTDBPartitionDurableIT.java | 6 +-
.../it/partition/IoTDBPartitionGetterIT.java | 16 +-
.../partition/IoTDBPartitionInheritPolicyIT.java | 6 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 7 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 16 +-
.../it/aggregation/IoTDBAggregationByLevel2IT.java | 22 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 4 +-
.../IoTDBCountIf2IT.java} | 30 +-
.../IoTDBCountIf3IT.java} | 34 +-
.../iotdb/db/it/aggregation/IoTDBCountIfIT.java | 259 +
.../db/it/aggregation/IoTDBTagAggregation2IT.java | 51 +
.../db/it/aggregation/IoTDBTagAggregationIT.java | 4 +-
.../db/it/alignbydevice/IoTDBAlignByDevice2IT.java | 22 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 2 +-
.../IoTDBOrderByWithAlignByDevice2IT.java | 22 +-
.../IoTDBOrderByWithAlignByDeviceIT.java | 2 +-
.../db/it/alignbydevice/IoTDBShuffleSink1IT.java | 150 +
.../db/it/alignbydevice/IoTDBShuffleSink2IT.java | 205 +
.../IoTDBAlignedSeriesQuery4IT.java} | 33 +-
.../db/it/groupby/IoTDBGroupByConditionIT.java | 399 ++
.../iotdb/db/it/groupby/IoTDBGroupBySessionIT.java | 502 ++
.../db/it/groupby/IoTDBGroupByVariationIT.java | 578 ++
.../iotdb/db/it/schema/AbstractSchemaIT.java | 92 +
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 59 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 65 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 82 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 23 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 297 +-
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 211 +-
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 11 +-
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 516 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 32 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 760 +--
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 28 +-
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 13 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 33 +-
.../java/org/apache/iotdb/isession/ISession.java | 7 +
.../dropwizard/DropwizardMetricManager.java | 4 +-
.../dropwizard/type/DropwizardAutoGauge.java | 16 +-
.../iotdb/metrics/AbstractMetricManager.java | 27 +-
.../iotdb/metrics/AbstractMetricService.java | 18 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 2 +-
.../metrics/config/MetricConfigDescriptor.java | 1 -
.../iotdb/metrics/impl/DoNothingAutoGauge.java | 4 +-
.../iotdb/metrics/impl/DoNothingMetricManager.java | 28 +-
.../iotdb/metrics/metricsets/disk/DiskMetrics.java | 277 +
.../metricsets/disk/IDiskMetricsManager.java | 123 +
.../metricsets/disk/LinuxDiskMetricsManager.java | 462 ++
.../metricsets/disk/MacDiskMetricsManager.java | 9 +-
.../metricsets/disk/WindowsDiskMetricsManager.java | 9 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 11 +-
.../metrics/metricsets/jvm/JvmMemoryMetrics.java | 12 +-
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 14 +-
.../metricsets/logback/MetricsTurboFilter.java | 10 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 12 +-
.../reporter/prometheus/PrometheusReporter.java | 6 +-
.../org/apache/iotdb/metrics/type/AutoGauge.java | 2 +-
.../iotdb/metrics/type/HistogramSnapshot.java | 4 +-
.../iotdb/metrics/config/MetricConfigTest.java | 5 +-
.../micrometer/MicrometerMetricManager.java | 10 +-
.../micrometer/type/MicrometerAutoGauge.java | 17 +-
.../resources/conf/iotdb-common.properties | 25 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 1 +
.../org/apache/iotdb/commons/cluster/NodeType.java | 3 +-
.../iotdb/commons/cluster/RegionRoleType.java | 1 +
.../iotdb/commons/concurrent/ThreadName.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 9 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 1 +
.../commons/service/metric/MetricService.java | 10 +-
.../iotdb/commons/service/metric/enums/Metric.java | 32 +-
.../udf/builtin/BuiltinAggregationFunction.java | 47 +
...tinScalarFunction.java => BuiltinFunction.java} | 19 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 14 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 6 +-
pipe-api/pom.xml | 68 +
.../org/apache/iotdb/pipe/api/PipeConnector.java | 136 +
.../org/apache/iotdb/pipe/api/PipeProcessor.java | 117 +
.../java/org/apache/iotdb/pipe/api/access/Row.java | 154 +
.../apache/iotdb/pipe/api/access/RowIterator.java | 75 +
.../iotdb/pipe/api/collector/EventCollector.java | 62 +
.../iotdb/pipe/api/collector/RowCollector.java | 33 +-
.../api/customizer/PipeParameterValidator.java | 99 +
.../iotdb/pipe/api/customizer/PipeParameters.java | 112 +
.../api/customizer/PipeRuntimeConfiguration.java | 13 +-
.../iotdb/pipe/api/customizer/PipeStrategy.java | 17 +-
.../PipeConnectorRuntimeConfiguration.java | 84 +
.../connector/parallel/ParallelStrategy.java | 10 +-
.../retry/EqualRetryIntervalStrategy.java | 63 +
.../retry/ExponentialRetryIntervalStrategy.java | 70 +
.../customizer/connector/retry/RetryStrategy.java | 28 +-
.../customizer/connector/reuse/ReuseStrategy.java | 10 +-
.../PipeProcessorRuntimeConfiguration.java | 19 +-
.../org/apache/iotdb/pipe/api/event/Event.java | 9 +-
.../pipe/api/event/deletion/DeletionEvent.java | 42 +-
.../api/event/insertion/TabletInsertionEvent.java | 56 +
.../api/event/insertion/TsFileInsertionEvent.java | 44 +
.../PipeAttributeNotProvidedException.java | 14 +-
.../iotdb/pipe/api/exception/PipeException.java | 14 +-
.../exception/PipeParameterNotValidException.java | 10 +-
.../exception/PipeStrategyNotValidException.java | 10 +-
.../org/apache/iotdb/pipe/api/type/Binary.java | 151 +
.../java/org/apache/iotdb/pipe/api/type/Type.java | 26 +-
pom.xml | 4 +
.../schemaregion/rocksdb/RSchemaRegion.java | 12 +
.../rocksdb/mnode/RStorageGroupMNode.java | 6 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 12 +
.../resources/conf/iotdb-datanode.properties | 2 +-
.../src/main/codegen/templates/evEventWindow.ftl | 9 +-
.../codegen/templates/evEventWindowManager.ftl | 31 +-
server/src/main/codegen/templates/eventWindow.ftl | 7 +-
.../main/codegen/templates/eventWindowManager.ftl | 5 -
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 10 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 83 +-
.../iotdb/db/client/DataNodeInternalClient.java | 1 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 60 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 57 +-
.../statemachine/DataRegionStateMachine.java | 8 +-
.../IoTConsensusDataRegionStateMachine.java | 8 +-
.../org/apache/iotdb/db/constant/SqlConstant.java | 1 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 12 +-
.../impl/ReadPointCompactionPerformer.java | 11 +-
.../execute/task/AbstractCompactionTask.java | 14 +
.../execute/task/CrossSpaceCompactionTask.java | 6 +-
.../execute/task/InnerSpaceCompactionTask.java | 6 +-
.../fast/AlignedSeriesCompactionExecutor.java | 11 +-
.../fast/NonAlignedSeriesCompactionExecutor.java | 17 +-
.../executor/fast/SeriesCompactionExecutor.java | 345 +-
.../fast/element/ChunkMetadataElement.java | 5 -
.../utils/executor/fast/element/PointElement.java | 12 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 26 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 42 +-
.../execute/utils/reader/PointPriorityReader.java | 60 +-
.../utils/reader/SeriesDataBlockReader.java | 44 +-
.../utils/writer/AbstractCompactionWriter.java | 15 +-
.../compaction/schedule/CompactionScheduler.java | 6 +-
.../compaction/schedule/CompactionTaskManager.java | 28 +-
.../compaction/schedule/CompactionWorker.java | 7 +-
.../DefaultCompactionTaskComparatorImpl.java | 21 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 44 +-
.../impl/SizeTieredCompactionSelector.java | 24 +-
.../utils/CrossSpaceCompactionCandidate.java | 6 +-
.../iotdb/db/engine/flush/FlushManagerMetrics.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 8 +-
.../db/engine/querycontext/QueryDataSource.java | 25 -
.../iotdb/db/engine/storagegroup/DataRegion.java | 140 +-
.../db/engine/storagegroup/TsFileProcessor.java | 21 +
.../apache/iotdb/db/metadata/MetadataConstant.java | 4 +
.../db/metadata/cache/DataNodeSchemaCache.java | 161 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 18 +-
.../metadata/cache/dualkeycache/IDualKeyCache.java | 57 +
.../dualkeycache/IDualKeyCacheComputation.java} | 28 +-
.../cache/dualkeycache/IDualKeyCacheStats.java} | 28 +-
.../dualkeycache/impl/CacheEntryGroupImpl.java | 75 +
.../dualkeycache/impl/CacheSizeComputerImpl.java | 55 +
.../cache/dualkeycache/impl/CacheStats.java | 110 +
.../dualkeycache/impl/DualKeyCacheBuilder.java | 85 +
.../cache/dualkeycache/impl/DualKeyCacheImpl.java | 281 +
.../dualkeycache/impl/DualKeyCachePolicy.java} | 10 +-
.../cache/dualkeycache/impl/ICacheEntry.java} | 25 +-
.../cache/dualkeycache/impl/ICacheEntryGroup.java | 39 +-
.../dualkeycache/impl/ICacheEntryManager.java} | 28 +-
.../dualkeycache/impl/ICacheSizeComputer.java} | 11 +-
.../dualkeycache/impl/LRUCacheEntryManager.java | 216 +
.../iotdb/db/metadata/logfile/MLogDescription.java | 63 +
.../db/metadata/logfile/MLogDescriptionReader.java | 39 +-
.../db/metadata/logfile/MLogDescriptionWriter.java | 53 +
.../iotdb/db/metadata/logfile/SchemaLogReader.java | 5 +
.../iotdb/db/metadata/logfile/SchemaLogWriter.java | 5 +-
.../ISchemaEngineMetric.java} | 9 +-
.../ISchemaRegionMetric.java} | 9 +-
.../metadata/metric/SchemaEngineCachedMetric.java | 187 +
.../db/metadata/metric/SchemaEngineMemMetric.java | 131 +
.../db/metadata/metric/SchemaMetricManager.java | 85 +
.../metadata/metric/SchemaRegionCachedMetric.java | 188 +
.../metric/SchemaRegionMemMetric.java} | 74 +-
.../db/metadata/mnode/IStorageGroupMNode.java | 6 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 6 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 10 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 4 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 78 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 55 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 45 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 91 +-
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 8 +
.../db/metadata/mtree/store/MemMTreeStore.java | 66 +-
.../store/ReentrantReadOnlyCachedMTreeStore.java | 6 +
.../mtree/store/disk/cache/CacheManager.java | 24 +-
.../mtree/store/disk/cache/CacheMemoryManager.java | 251 +-
.../mtree/store/disk/cache/ICacheManager.java | 4 +
.../mtree/store/disk/cache/LRUCacheManager.java | 21 +-
.../mtree/store/disk/cache/PlainCacheManager.java | 10 +
.../mtree/store/disk/memcontrol/IMemManager.java | 52 -
.../disk/memcontrol/IReleaseFlushStrategy.java} | 12 +-
.../mtree/store/disk/memcontrol/MemManager.java | 86 +
.../MemManagerNodeEstimatedSizeBasedImpl.java | 132 -
.../memcontrol/MemManagerNodeNumBasedImpl.java | 105 -
....java => ReleaseFlushStrategyNumBasedImpl.java} | 29 +-
.../ReleaseFlushStrategySizeBasedImpl.java | 51 +
.../mtree/store/disk/schemafile/SchemaFile.java | 8 +-
.../db/metadata/mtree/traverser/Traverser.java | 4 +-
.../traverser/TraverserWithLimitOffsetWrapper.java | 6 +-
.../impl/read/AbstractShowSchemaPlanImpl.java | 10 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 6 +-
.../impl/read/ShowDevicesPlanImpl.java | 2 +-
.../impl/read/ShowTimeSeriesPlanImpl.java | 4 +-
.../plan/schemaregion/read/IShowSchemaPlan.java | 4 +-
.../rescon/CachedSchemaEngineStatistics.java | 75 +
.../rescon/CachedSchemaRegionStatistics.java | 122 +
.../metadata/rescon/ISchemaEngineStatistics.java | 29 +-
.../metadata/rescon/ISchemaRegionStatistics.java | 22 +-
...tistics.java => MemSchemaEngineStatistics.java} | 81 +-
.../metadata/rescon/MemSchemaRegionStatistics.java | 103 +
.../db/metadata/rescon/SchemaResourceManager.java | 20 +-
.../rescon/SchemaResourceManagerMetrics.java | 100 -
.../metadata/rescon/SchemaStatisticsManager.java | 56 -
.../db/metadata/schemaregion/ISchemaRegion.java | 8 +
.../db/metadata/schemaregion/SchemaEngine.java | 47 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 16 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 62 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 187 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 4 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 8 +-
.../iotdb/db/mpp/aggregation/Accumulator.java | 8 +-
.../db/mpp/aggregation/AccumulatorFactory.java | 60 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 6 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 26 +-
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 5 +-
...untAccumulator.java => CountIfAccumulator.java} | 85 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 26 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 50 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 24 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 38 +-
.../mpp/aggregation/LastValueDescAccumulator.java | 24 +-
.../db/mpp/aggregation/MaxTimeAccumulator.java | 4 +-
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 4 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 26 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 4 +-
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 4 +-
.../db/mpp/aggregation/MinValueAccumulator.java | 26 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 26 +-
.../slidingwindow/SlidingWindowAggregator.java | 2 +-
.../SlidingWindowAggregatorFactory.java | 9 +-
.../iotdb/db/mpp/common/FragmentInstanceId.java | 7 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 4 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 33 +
.../schematree/IMeasurementSchemaInfo.java} | 20 +-
.../schematree/node/SchemaMeasurementNode.java | 3 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 100 +-
.../db/mpp/execution/driver/DataDriverContext.java | 3 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 26 +-
.../db/mpp/execution/driver/DriverContext.java | 21 +-
.../iotdb/db/mpp/execution/driver/IDriver.java | 8 +-
.../mpp/execution/driver/SchemaDriverContext.java | 5 +-
.../exchange/IMPPDataExchangeManager.java | 34 +-
.../execution/exchange/MPPDataExchangeManager.java | 334 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 56 +-
.../exchange/sink/DownStreamChannelIndex.java | 24 +-
.../exchange/sink/DownStreamChannelLocation.java | 111 +
.../exchange/{ISinkHandle.java => sink/ISink.java} | 41 +-
.../mpp/execution/exchange/sink/ISinkChannel.java | 23 +-
.../mpp/execution/exchange/sink/ISinkHandle.java | 43 +-
.../LocalSinkChannel.java} | 89 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 299 +
.../{SinkHandle.java => sink/SinkChannel.java} | 184 +-
.../exchange/{ => source}/ISourceHandle.java | 2 +-
.../exchange/{ => source}/LocalSourceHandle.java | 24 +-
.../exchange/{ => source}/SourceHandle.java | 69 +-
.../execution/executor/RegionWriteExecutor.java | 34 +-
.../fragment/FragmentInstanceContext.java | 86 +-
.../fragment/FragmentInstanceExecution.java | 21 +-
.../fragment/FragmentInstanceManager.java | 22 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 41 +-
.../db/mpp/execution/operator/AggregationUtil.java | 3 +-
.../process/AbstractConsumeAllOperator.java | 126 +
.../operator/process/AggregationOperator.java | 84 +-
.../operator/process/DeviceMergeOperator.java | 1 +
.../operator/process/MergeSortOperator.java | 103 +-
.../process/RawDataAggregationOperator.java | 36 +-
.../process/SlidingWindowAggregationOperator.java | 2 +-
.../operator/process/TagAggregationOperator.java | 93 +-
...erator.java => HorizontallyConcatOperator.java} | 77 +-
.../process/join/RowBasedTimeJoinOperator.java | 131 +-
.../operator/process/join/TimeJoinOperator.java | 4 +-
.../operator/schema/source/DeviceSchemaSource.java | 6 +-
.../schema/source/SchemaSourceFactory.java | 6 +-
.../schema/source/TimeSeriesSchemaSource.java | 8 +-
.../operator/sink/IdentitySinkOperator.java | 132 +
.../operator/sink/ShuffleHelperOperator.java | 134 +
.../AbstractSeriesAggregationScanOperator.java | 6 +-
.../AlignedSeriesAggregationScanOperator.java | 18 +-
.../operator/source/AlignedSeriesScanOperator.java | 18 +-
.../operator/source/AlignedSeriesScanUtil.java | 80 +-
.../operator/source/ExchangeOperator.java | 2 +-
.../source/SeriesAggregationScanOperator.java | 20 +-
.../operator/source/SeriesScanOperator.java | 33 +-
.../execution/operator/source/SeriesScanUtil.java | 228 +-
.../mpp/execution/operator/window/EventWindow.java | 10 +
.../operator/window/EventWindowManager.java | 26 +-
.../operator/window/EventWindowParameter.java | 10 +-
.../execution/operator/window/IWindowManager.java | 32 +-
.../window/{EventWindow.java => SeriesWindow.java} | 76 +-
.../operator/window/SeriesWindowManager.java | 194 +
...owParameter.java => SeriesWindowParameter.java} | 42 +-
.../execution/operator/window/SessionWindow.java | 157 +
...indowManager.java => SessionWindowManager.java} | 95 +-
...WindowType.java => SessionWindowParameter.java} | 17 +-
.../operator/window/TimeWindowManager.java | 7 +-
.../operator/window/WindowManagerFactory.java | 19 +-
.../mpp/execution/operator/window/WindowType.java | 5 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 126 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 25 +-
.../db/mpp/metric/PerformanceOverviewMetrics.java | 142 +
.../metric/PerformanceOverviewMetricsManager.java | 177 +
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 4 +-
.../db/mpp/metric/QueryPlanCostMetricSet.java | 9 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 14 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 41 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 222 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 76 +-
.../plan/analyze/ColumnPaginationController.java | 10 +-
.../db/mpp/plan/analyze/ConcatPathRewriter.java | 25 +
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 130 +-
.../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 4 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 16 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 180 +-
.../schema/ISchemaAutoCreation.java} | 24 +-
.../schema/ISchemaComputation.java} | 25 +-
.../ISchemaComputationWithAutoCreation.java} | 9 +-
.../db/mpp/plan/analyze/schema/ISchemaFetcher.java | 44 +-
.../mpp/plan/analyze/schema/ISchemaValidation.java | 22 +-
.../mpp/plan/analyze/schema/SchemaValidator.java | 34 +-
.../db/mpp/plan/execution/QueryExecution.java | 39 +-
.../plan/execution/config/ConfigTaskVisitor.java | 13 +-
.../config/executor/ClusterConfigTaskExecutor.java | 191 +-
.../config/executor/IConfigTaskExecutor.java | 7 +-
.../config/metadata/DatabaseSchemaTask.java | 80 +
.../config/metadata/SetStorageGroupTask.java | 74 -
.../execution/config/metadata/ShowRegionTask.java | 10 +-
.../plan/execution/memory/MemorySourceHandle.java | 2 +-
.../memory/StatementMemorySourceVisitor.java | 5 +-
.../db/mpp/plan/expression/ExpressionFactory.java | 107 +
.../plan/expression/multi/FunctionExpression.java | 40 +-
.../plan/expression/multi/FunctionType.java} | 11 +-
.../visitor/ColumnTransformerVisitor.java | 6 +-
.../visitor/IntermediateLayerVisitor.java | 6 +-
.../mpp/plan/optimization/LimitOffsetPushDown.java | 241 +
.../db/mpp/plan/optimization/PlanOptimizer.java | 3 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 217 +-
.../db/mpp/plan/parser/StatementGenerator.java | 302 +-
.../plan/planner/LocalExecutionPlanContext.java | 30 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 20 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 43 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 38 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 2 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 577 +-
.../db/mpp/plan/planner/PipelineDriverFactory.java | 23 +-
.../distribution/DistributionPlanContext.java | 14 +
.../planner/distribution/DistributionPlanner.java | 159 +-
.../planner/distribution/ExchangeNodeAdder.java | 206 +-
.../planner/distribution/NodeGroupContext.java | 49 +-
.../SimpleFragmentParallelPlanner.java | 44 +-
.../plan/planner/distribution/SourceRewriter.java | 95 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 15 -
.../plan/planner/plan/node/PlanGraphPrinter.java | 47 +-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 23 +
.../mpp/plan/planner/plan/node/PlanNodeType.java | 17 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 70 +-
.../node/metedata/read/DevicesSchemaScanNode.java | 8 +-
.../node/metedata/read/SchemaQueryScanNode.java | 12 +-
.../metedata/read/TimeSeriesSchemaScanNode.java | 8 +-
.../planner/plan/node/process/AggregationNode.java | 165 +-
.../planner/plan/node/process/DeviceMergeNode.java | 6 +
.../planner/plan/node/process/ExchangeNode.java | 31 +-
.../plan/node/process/GroupByLevelNode.java | 7 +
.../planner/plan/node/process/GroupByTagNode.java | 7 +
...ConcatNode.java => HorizontallyConcatNode.java} | 28 +-
.../plan/planner/plan/node/process/LimitNode.java | 10 +-
.../planner/plan/node/process/MergeSortNode.java | 19 +
.../plan/planner/plan/node/process/OffsetNode.java | 10 +-
.../planner/plan/node/process/TimeJoinNode.java | 8 +
.../planner/plan/node/sink/FragmentSinkNode.java | 202 -
.../planner/plan/node/sink/IdentitySinkNode.java | 99 +
.../plan/node/sink/MultiChildrenSinkNode.java | 117 +
.../planner/plan/node/sink/ShuffleSinkNode.java | 105 +
.../plan/node/source/AlignedSeriesScanNode.java | 24 +-
.../planner/plan/node/source/SeriesScanNode.java | 20 +-
.../planner/plan/node/write/BatchInsertNode.java | 11 +-
.../plan/node/write/InsertMultiTabletsNode.java | 52 +-
.../plan/planner/plan/node/write/InsertNode.java | 76 +-
.../planner/plan/node/write/InsertRowNode.java | 100 +-
.../planner/plan/node/write/InsertRowsNode.java | 53 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 51 +-
.../planner/plan/node/write/InsertTabletNode.java | 83 +-
.../plan/parameter/AggregationDescriptor.java | 89 +-
.../CrossSeriesAggregationDescriptor.java | 110 +-
.../planner/plan/parameter/GroupByParameter.java | 82 +
.../plan/parameter/GroupBySeriesParameter.java | 87 +
.../plan/parameter/GroupBySessionParameter.java | 76 +
.../plan/parameter/GroupByTimeParameter.java | 2 +
.../plan/parameter/GroupByVariationParameter.java | 87 +
.../planner/plan/parameter/SeriesScanOptions.java | 151 +
.../db/mpp/plan/scheduler/AsyncPlanNodeSender.java | 105 +
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 61 +
.../db/mpp/plan/scheduler/ClusterScheduler.java | 12 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 72 +-
.../iotdb/db/mpp/plan/statement/Statement.java | 2 +-
.../iotdb/db/mpp/plan/statement/StatementType.java | 2 +-
.../db/mpp/plan/statement/StatementVisitor.java | 10 +-
.../plan/statement/component/GroupByComponent.java | 57 +
.../{Ordering.java => GroupBySeriesComponent.java} | 26 +-
...{Ordering.java => GroupBySessionComponent.java} | 23 +-
...rdering.java => GroupByVariationComponent.java} | 25 +-
.../db/mpp/plan/statement/component/Ordering.java | 4 +
.../db/mpp/plan/statement/crud/QueryStatement.java | 91 +-
...Statement.java => DatabaseSchemaStatement.java} | 27 +-
.../mpp/plan/statement/metadata/ShowStatement.java | 12 +-
.../metadata/ShowStorageGroupStatement.java | 8 +-
.../plan/statement/sys/ShowQueriesStatement.java | 17 +-
.../query/reader/chunk/MemAlignedPageReader.java | 61 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 211 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 3 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 41 +-
.../db/service/metrics/CompactionMetrics.java | 232 +
.../db/service/metrics/DataNodeMetricsHelper.java | 4 +
.../iotdb/db/service/metrics/FileMetrics.java | 30 +-
.../metrics/IoTDBInternalLocalReporter.java | 4 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 6 +-
.../metrics/recorder/CompactionMetricsManager.java | 225 +
.../recorder/CompactionMetricsRecorder.java | 190 -
.../service/thrift/impl/ClientRPCServiceImpl.java | 58 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 53 +-
.../db/sync/transport/server/ReceiverManager.java | 5 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 1 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 105 +-
.../iotdb/db/utils/concurrent/FiniteSemaphore.java | 56 +
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 17 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../engine/compaction/AbstractCompactionTest.java | 13 +-
.../engine/compaction/CompactionSchedulerTest.java | 3 +-
.../CompactionSchedulerWithFastPerformerTest.java | 3 +-
.../compaction/FastAlignedCrossCompactionTest.java | 398 ++
.../FastCrossCompactionPerformerTest.java | 34 -
.../FastInnerCompactionPerformerTest.java | 30 -
.../FastNonAlignedCrossCompactionTest.java | 420 +-
.../ReadPointCompactionPerformerTest.java | 73 +-
.../CrossSpaceCompactionWithFastPerformerTest.java | 2 +
...eCompactionWithFastPerformerValidationTest.java | 1 +
...sSpaceCompactionWithReadPointPerformerTest.java | 2 +
...actionWithReadPointPerformerValidationTest.java | 1 +
.../engine/compaction/cross/MergeUpgradeTest.java | 2 +
.../cross/RewriteCompactionFileSelectorTest.java | 33 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 16 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 16 +-
.../inner/InnerCompactionMoreDataTest.java | 1 -
.../SizeTieredCompactionRecoverTest.java | 17 -
.../compaction/utils/CompactionCheckerUtils.java | 1 -
.../compaction/utils/CompactionConfigRestorer.java | 4 +
.../compaction/utils/TsFileGeneratorUtils.java | 10 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 1 -
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 8 -
.../cache/dualkeycache/DualKeyCacheTest.java | 110 +
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 18 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 25 +-
.../schemaRegion/SchemaRegionBasicTest.java | 45 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 58 +
.../schemaRegion/SchemaRegionTestUtil.java | 11 +
.../schemaRegion/SchemaStatisticsTest.java | 251 +
.../apache/iotdb/db/metric/MetricServiceTest.java | 24 +-
.../iotdb/db/mpp/aggregation/AccumulatorTest.java | 71 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 34 +-
...nkHandleTest.java => LocalSinkChannelTest.java} | 110 +-
.../execution/exchange/LocalSourceHandleTest.java | 1 +
.../exchange/MPPDataExchangeManagerTest.java | 65 +-
.../{SinkHandleTest.java => SinkChannelTest.java} | 298 +-
.../mpp/execution/exchange/SourceHandleTest.java | 16 +-
.../{StubSinkHandle.java => StubSink.java} | 10 +-
.../operator/AggregationOperatorTest.java | 33 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 127 +-
.../operator/AlignedSeriesScanOperatorTest.java | 148 +-
.../operator/DeviceMergeOperatorTest.java | 61 +-
.../execution/operator/DeviceViewOperatorTest.java | 16 +-
...st.java => HorizontallyConcatOperatorTest.java} | 48 +-
.../execution/operator/LastQueryOperatorTest.java | 28 +-
.../operator/LastQuerySortOperatorTest.java | 26 +-
.../mpp/execution/operator/LimitOperatorTest.java | 28 +-
.../execution/operator/MergeSortOperatorTest.java | 233 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 78 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 85 +-
.../operator/RawDataAggregationOperatorTest.java | 144 +-
.../SeriesAggregationScanOperatorTest.java | 122 +-
.../execution/operator/SeriesScanOperatorTest.java | 11 +-
.../operator/SingleDeviceViewOperatorTest.java | 25 +-
.../SlidingWindowAggregationOperatorTest.java | 18 +-
.../execution/operator/TimeJoinOperatorTest.java | 69 +-
.../operator/UpdateLastCacheOperatorTest.java | 10 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 4 +-
.../operator/schema/SchemaCountOperatorTest.java | 4 +-
.../schema/SchemaQueryScanOperatorTest.java | 4 +-
.../execution/schedule/DriverSchedulerTest.java | 4 +
.../plan/analyze/AggregationDescriptorTest.java | 53 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 6 +-
.../mpp/plan/analyze/ExpressionAnalyzerTest.java | 83 +
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 24 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 299 +
.../db/mpp/plan/optimization/TestPlanBuilder.java | 184 +
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 3 +-
.../db/mpp/plan/plan/PipelineBuilderTest.java | 762 +++
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 18 +
.../iotdb/db/mpp/plan/plan/QueryPlannerTest.java | 17 +-
.../distribution/AggregationDistributionTest.java | 45 +-
.../plan/distribution/AlignedByDeviceTest.java | 1390 ++++-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 21 +-
.../read/DeviceSchemaScanNodeSerdeTest.java | 22 +-
.../NodeManagementMemoryMergeNodeSerdeTest.java | 24 +-
.../metadata/read/SchemaCountNodeSerdeTest.java | 44 +-
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 24 +-
.../plan/node/process/ExchangeNodeSerdeTest.java | 24 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 2 +
.../plan/node/process/GroupByTagNodeSerdeTest.java | 4 +
...rdeTest.java => IdentitySinkNodeSerdeTest.java} | 45 +-
...st.java => ShuffleSinkHandleNodeSerdeTest.java} | 46 +-
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 682 +++
.../series/SeriesScanLimitOffsetPushDownTest.java | 368 ++
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 31 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 16 +-
site/pom.xml | 320 -
site/src/main/.eslintignore | 4 +
site/src/main/.eslintrc.cjs | 73 +
site/src/main/.vuepress/config.js | 3959 +++++--------
.../theme/components/AlgoliaSearchBox.vue | 77 +-
site/src/main/.vuepress/theme/components/Page.vue | 182 +-
.../main/.vuepress/theme/components/RightMenu.vue | 136 +
site/src/main/.vuepress/theme/styles/palette.styl | 1 +
site/src/main/package.json | 16 +-
thrift-commons/src/main/thrift/common.thrift | 3 +-
.../src/main/thrift/confignode.thrift | 139 +-
thrift/src/main/thrift/datanode.thrift | 8 +-
.../tsfile/file/metadata/AlignedChunkMetadata.java | 9 +
.../file/metadata/AlignedTimeSeriesMetadata.java | 8 +
.../file/metadata/statistics/Statistics.java | 4 +
.../iotdb/tsfile/read/reader/IPageReader.java | 3 +
.../tsfile/read/reader/page/AlignedPageReader.java | 73 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 96 +-
.../tsfile/read/reader/page/ValuePageReader.java | 6 +-
.../read/reader/series/PaginationController.java | 66 +
745 files changed, 42928 insertions(+), 17051 deletions(-)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{storagegroup/CountStorageGroupPlan.java => database/CountDatabasePlan.java} (79%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{storagegroup/GetStorageGroupPlan.java => database/GetDatabasePlan.java} (71%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup/SetStorageGroupPlan.java => region/PollSpecificRegionMaintainTaskPlan.java} (52%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/{SetStorageGroupPlan.java => DatabaseSchemaPlan.java} (75%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/{DeleteStorageGroupPlan.java => DeleteDatabasePlan.java} (83%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/{PreDeleteStorageGroupPlan.java => PreDeleteDatabasePlan.java} (75%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => auth}/PermissionInfoResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => cq}/ShowCQResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{CountStorageGroupResp.java => database/CountDatabaseResp.java} (82%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{StorageGroupSchemaResp.java => database/DatabaseSchemaResp.java} (65%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => datanode}/ConfigurationResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => datanode}/DataNodeConfigurationResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => datanode}/DataNodeRegisterResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => datanode}/DataNodeToStatusResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => function}/FunctionTableResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/DataPartitionResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/GetRegionIdResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/GetSeriesSlotListResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/GetTimeSlotListResp.java (96%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/PathInfoResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/RegionInfoListResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/SchemaNodeManagementResp.java (98%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/SchemaPartitionResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => pipe}/PipeResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => pipe}/PipeSinkResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => template}/AllTemplateSetInfoResp.java (94%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => template}/TemplateInfoResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => template}/TemplateSetInfoResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => trigger}/TransferringTriggersResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => trigger}/TriggerLocationResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => trigger}/TriggerTableResp.java (97%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => udf}/JarResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ => consensus}/ConsensusManager.java (93%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManagerMetrics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeMetrics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionMetrics.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/PartitionInfoMetrics.java
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/{StorageGroupPartitionTable.java => DatabasePartitionTable.java} (87%)
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/{DeleteStorageGroupProcedure.java => DeleteDatabaseProcedure.java} (59%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNodeShutdownHook.java
rename confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/{DeleteStorageGroupProcedureTest.java => DeleteDatabaseProcedureTest.java} (78%)
copy metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/DropwizardAutoGauge.java => consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/CounterProxy.java (56%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowType.java => consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/GaugeProxy.java (58%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/IoTDBMetricRegistry.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/MetricRegistryManager.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowType.java => consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/RatisMetricSet.java (61%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/RefCountingMap.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowType.java => consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/TimerProxy.java (60%)
create mode 100644 consensus/src/main/resources/META-INF/services/org.apache.ratis.metrics.MetricRegistries
copy docs/UserGuide/Monitor-Alert/{Apache-IoTDB-ConfigNode-Dashboard.json => Apache-IoTDB-Performance-Overview-Dashboard.json} (63%)
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParameters.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/type/AutoGauge.java => integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParametersFactory.java (63%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBConfigNodeConsensusEfficiencyIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterNodeShutdownHookIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/database/IoTDBDatabaseRegionControlIT.java
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/{IoTDBStorageGroupIT.java => database/IoTDBDatabaseSetAndDeleteIT.java} (70%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowType.java => integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationByLevel2IT.java (60%)
copy integration-test/src/test/java/org/apache/iotdb/db/it/{schema/IoTDBDeleteTimeseriesSchemaFileIT.java => aggregation/IoTDBCountIf2IT.java} (62%)
rename integration-test/src/test/java/org/apache/iotdb/db/it/{schema/IoTDBMetadataFetchSchemaFileIT.java => aggregation/IoTDBCountIf3IT.java} (62%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBCountIfIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBTagAggregation2IT.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowType.java => integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBAlignByDevice2IT.java (60%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowType.java => integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBOrderByWithAlignByDevice2IT.java (59%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBShuffleSink1IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBShuffleSink2IT.java
rename integration-test/src/test/java/org/apache/iotdb/db/it/{schema/IoTDBDeleteTimeseriesSchemaFileIT.java => aligned/IoTDBAlignedSeriesQuery4IT.java} (58%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByConditionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupBySessionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByVariationIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/AbstractSchemaIT.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/IDiskMetricsManager.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/LinuxDiskMetricsManager.java
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/MacDiskMetricsManager.java (81%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/WindowsDiskMetricsManager.java (80%)
rename node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/{BuiltinScalarFunction.java => BuiltinFunction.java} (77%)
create mode 100644 pipe-api/pom.xml
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeConnector.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeProcessor.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/access/Row.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/access/RowIterator.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/EventCollector.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/BatchInsertNode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java (55%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeParameterValidator.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeParameters.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingAutoGauge.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeRuntimeConfiguration.java (76%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/Ordering.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeStrategy.java (74%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/PipeConnectorRuntimeConfiguration.java
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/parallel/ParallelStrategy.java (81%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/EqualRetryIntervalStrategy.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/ExponentialRetryIntervalStrategy.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/BatchInsertNode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/RetryStrategy.java (56%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/reuse/ReuseStrategy.java (82%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/type/AutoGauge.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/processor/PipeProcessorRuntimeConfiguration.java (58%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/Event.java (85%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/BatchInsertNode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/deletion/DeletionEvent.java (59%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/insertion/TabletInsertionEvent.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/insertion/TsFileInsertionEvent.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/Ordering.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeAttributeNotProvidedException.java (74%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingAutoGauge.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeException.java (76%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingAutoGauge.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeParameterNotValidException.java (81%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingAutoGauge.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeStrategyNotValidException.java (81%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/type/Binary.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowType.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/type/Type.java (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/IDualKeyCache.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/operator/window/WindowType.java => metadata/cache/dualkeycache/IDualKeyCacheComputation.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/operator/window/WindowType.java => metadata/cache/dualkeycache/IDualKeyCacheStats.java} (55%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/impl/CacheEntryGroupImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/impl/CacheSizeComputerImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/impl/CacheStats.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/impl/DualKeyCacheBuilder.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/impl/DualKeyCacheImpl.java
copy server/src/main/java/org/apache/iotdb/db/metadata/{schemaregion/SchemaEngineMode.java => cache/dualkeycache/impl/DualKeyCachePolicy.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/operator/window/WindowType.java => metadata/cache/dualkeycache/impl/ICacheEntry.java} (61%)
copy metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/DropwizardAutoGauge.java => server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/impl/ICacheEntryGroup.java (52%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/operator/window/WindowType.java => metadata/cache/dualkeycache/impl/ICacheEntryManager.java} (55%)
rename server/src/main/java/org/apache/iotdb/db/{mpp/execution/operator/process/AbstractProcessOperator.java => metadata/cache/dualkeycache/impl/ICacheSizeComputer.java} (78%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/impl/LRUCacheEntryManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogDescription.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/JarResp.java => server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogDescriptionReader.java (53%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogDescriptionWriter.java
copy server/src/main/java/org/apache/iotdb/db/metadata/{schemaregion/SchemaEngineMode.java => metric/ISchemaEngineMetric.java} (83%)
copy server/src/main/java/org/apache/iotdb/db/metadata/{schemaregion/SchemaEngineMode.java => metric/ISchemaRegionMetric.java} (83%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaEngineCachedMetric.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaEngineMemMetric.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaMetricManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaRegionCachedMetric.java
copy server/src/main/java/org/apache/iotdb/db/{engine/flush/FlushManagerMetrics.java => metadata/metric/SchemaRegionMemMetric.java} (54%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/IMemManager.java
copy server/src/main/java/org/apache/iotdb/db/metadata/{schemaregion/SchemaEngineMode.java => mtree/store/disk/memcontrol/IReleaseFlushStrategy.java} (70%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/MemManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/MemManagerNodeEstimatedSizeBasedImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/MemManagerNodeNumBasedImpl.java
rename server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/{MemManagerHolder.java => ReleaseFlushStrategyNumBasedImpl.java} (52%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/ReleaseFlushStrategySizeBasedImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/CachedSchemaEngineStatistics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/CachedSchemaRegionStatistics.java
copy node-commons/src/main/java/org/apache/iotdb/commons/cluster/RegionRoleType.java => server/src/main/java/org/apache/iotdb/db/metadata/rescon/ISchemaEngineStatistics.java (66%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/type/AutoGauge.java => server/src/main/java/org/apache/iotdb/db/metadata/rescon/ISchemaRegionStatistics.java (69%)
rename server/src/main/java/org/apache/iotdb/db/metadata/rescon/{MemoryStatistics.java => MemSchemaEngineStatistics.java} (51%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/MemSchemaRegionStatistics.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaResourceManagerMetrics.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaStatisticsManager.java
copy server/src/main/java/org/apache/iotdb/db/mpp/aggregation/{CountAccumulator.java => CountIfAccumulator.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/statement/component/Ordering.java => common/schematree/IMeasurementSchemaInfo.java} (77%)
copy node-commons/src/main/java/org/apache/iotdb/commons/cluster/RegionRoleType.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/DownStreamChannelIndex.java (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/DownStreamChannelLocation.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{ISinkHandle.java => sink/ISink.java} (59%)
copy node-commons/src/main/java/org/apache/iotdb/commons/cluster/RegionRoleType.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/ISinkChannel.java (68%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PathInfoResp.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/ISinkHandle.java (58%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{LocalSinkHandle.java => sink/LocalSinkChannel.java} (69%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/ShuffleSinkHandle.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{SinkHandle.java => sink/SinkChannel.java} (80%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{ => source}/ISourceHandle.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{ => source}/LocalSourceHandle.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{ => source}/SourceHandle.java (90%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractConsumeAllOperator.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/{VerticallyConcatOperator.java => HorizontallyConcatOperator.java} (75%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/sink/IdentitySinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/sink/ShuffleHelperOperator.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{EventWindow.java => SeriesWindow.java} (51%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/SeriesWindowManager.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{EventWindowParameter.java => SeriesWindowParameter.java} (63%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/SessionWindow.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{EventWindowManager.java => SessionWindowManager.java} (58%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{WindowType.java => SessionWindowParameter.java} (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/PerformanceOverviewMetrics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/PerformanceOverviewMetricsManager.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/{planner/plan/node/write/BatchInsertNode.java => analyze/schema/ISchemaAutoCreation.java} (63%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/{planner/plan/node/write/BatchInsertNode.java => analyze/schema/ISchemaComputation.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/{metadata/schemaregion/SchemaEngineMode.java => mpp/plan/analyze/schema/ISchemaComputationWithAutoCreation.java} (83%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/type/AutoGauge.java => server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ISchemaValidation.java (54%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/DatabaseSchemaTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/SetStorageGroupTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/ExpressionFactory.java
copy server/src/main/java/org/apache/iotdb/db/{metadata/schemaregion/SchemaEngineMode.java => mpp/plan/expression/multi/FunctionType.java} (85%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/optimization/LimitOffsetPushDown.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{VerticallyConcatNode.java => HorizontallyConcatNode.java} (75%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/FragmentSinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/IdentitySinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/MultiChildrenSinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/ShuffleSinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/GroupByParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/GroupBySeriesParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/GroupBySessionParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/GroupByVariationParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/SeriesScanOptions.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/AsyncPlanNodeSender.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/AsyncSendPlanNodeHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/GroupByComponent.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/{Ordering.java => GroupBySeriesComponent.java} (61%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/{Ordering.java => GroupBySessionComponent.java} (66%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/{Ordering.java => GroupByVariationComponent.java} (66%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{SetStorageGroupStatement.java => DatabaseSchemaStatement.java} (85%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/CompactionMetrics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CompactionMetricsManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CompactionMetricsRecorder.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/concurrent/FiniteSemaphore.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/cache/dualkeycache/DualKeyCacheTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaStatisticsTest.java
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/{LocalSinkHandleTest.java => LocalSinkChannelTest.java} (58%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/{SinkHandleTest.java => SinkChannelTest.java} (68%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/{StubSinkHandle.java => StubSink.java} (91%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/{VerticallyConcatOperatorTest.java => HorizontallyConcatOperatorTest.java} (84%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/ExpressionAnalyzerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/optimization/LimitOffsetPushDownTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/optimization/TestPlanBuilder.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/PipelineBuilderTest.java
copy server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/sink/{FragmentSinkNodeSerdeTest.java => IdentitySinkNodeSerdeTest.java} (54%)
rename server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/sink/{FragmentSinkNodeSerdeTest.java => ShuffleSinkHandleNodeSerdeTest.java} (57%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/reader/series/AlignedSeriesScanLimitOffsetPushDownTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesScanLimitOffsetPushDownTest.java
create mode 100644 site/src/main/.eslintignore
create mode 100644 site/src/main/.eslintrc.cjs
create mode 100644 site/src/main/.vuepress/theme/components/RightMenu.vue
create mode 100644 site/src/main/.vuepress/theme/styles/palette.styl
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/series/PaginationController.java