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/17 07:10:31 UTC
[iotdb] branch lmh/modelManager updated (7202cba5b6 -> 2cd8fc889f)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/modelManager
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7202cba5b6 implement ModelInfo
add 5f914f014e [IOTDB-3662] upgrade audit log (#8791)
add 362f56cdf5 Change version to 1.1.0-SNAPSHOT (#8796)
add 5de6adf3de [IOTDB-5386] Implement SchemaSource Component to Simplify Schema Operators (#8792)
add c1dde58682 Jenkins disable integration (#8787)
add c085fb1a8c [IOTDB-4005] Pipeline fragmentInstance to implement parallel execution
add 27549169a3 [IOTDB-5384] add core_client_count_for_each_node_in_client_manager and max_client_count_for_each_node_in_client_manager parameters for confignode and datanode （#8800）
add a1cc705fdd [IOTDB-5387] Refine IT: Make JVM parameters mutable easily (#8795)
add 7b1977330a [IOTDB-5328] Rename "REMOVE_DATANODE_PROCESS" in MIGRATE_REGION_PROCEDURE to "REGION_MIGRATE_PROCESS" (#8790)
add 76d3a13e29 Eliminate LocalSchemaProcessor and stale code (#8802)
add 4dcaf696d5 Eliminate LocalConfigNode and Fix NPE while forceMLog (#8804)
add dfb013b710 Separate SYNC_CONNECTION_ERROR and DISPATCH_ERROR (#8726)
add 8e40479c42 [IOTDB-5288][IOTDB-5163] Fix the file metrics is wrong (#8805)
add 5ad3384f0f Change config in SourceHandleTest according to IoTDBDescriptor
add 44fb69a7ff Fix wal manager test (#8808)
add 5dac205243 [IOTDB-4437] Implement event window in RawDataAggregationOperator
add 43cd37bdcf [IOTDB-5389] Cause DataNode startup to fail when wal_mode is disabled in IoTConsensus (#8798)
add 3ddaa39983 [IOTDB-5391] Implement SchemaReader using iterative Traverser (#8816)
add 4f1409df4d Fix testGetSlots bug (#8819)
add ee93ad4145 [IOTDB-4960]SchemaFile implements separate FileChannel for read/write operation (#8813)
add 8224a70a41 [IOTDB-5398] Handle failure in schema query if there is exception occurs during the iteration (#8830)
add 309206e504 [IOTDB-5392] accelerate pointPriorityReader in fast compaction
add 3c01a93437 [IOTDB-5401] Reduce the estimated size of memory retained after calling next in SeriesAggregationScanOperator
add b93dbfa5e6 [IOTDB-5369] Add query related panels in Grafana Dashboard (#8764)
add 4ee81d4d68 [IOTDB-5345] Use the logical clock to identify the snapshot version of IoTConsensus (#8807)
add a009560f26 [IOTDB-5390] Keep mqtt_host same with rpc_address (#8831)
add 2122ae3353 [IOTDB-5404] Fix concurrency problem of metricSets in AbstractMetricService (#8841)
add 4a73e612d3 Fix mqtt docs (#8845)
add df26f54db3 [IOTDB-5403] Refine IT: Add ensureNodeStatus to test status after starting or stopping (#8844)
add ed75dfcc81 finish (#8837)
add 0e5e53ad97 [IOTDB-5370] Implement MultilevelPriorityQueue for query schedule
add 3299f1310e Update the user guide of Flink-IoTDB sink (#8848)
add 9d5d78285d [IOTDB-4674] Reimplement settle by compaction (#8644)
add a7f910ffc4 Finish (#8847)
add 0308ab6cab [IOTDB-5404] Optimize concurrency problem of metricSets in AbstractMetricService (#8855)
add d970dc6a98 [IOTDB-5414] Timeseries with alias deleted success but can still be queried by alias (#8865)
add 8383c48012 [IOTDB-5324] Fix wal cann't be deleted in destDataNode after region migration when data_replication_factor is 1 in IoTConsensus (#8836)
add db335faecc Fix jenkins sonar report error (#8868)
add 280ea4e034 [IOTDB-5399] Implement batch auto create schema (#8826)
add c32b3f524c Add Metric Doc (#8857)
add a5167ac654 Update Data-Repairing.md (#8852)
add e0d1cc9e08 Add query metrics doc (#8853)
add 2684767547 [IOTDB-5410] Refine IT: Refine Session and SessionPool IT (#8860)
add 993cf647fb fix data partition update error (#8840)
add a387d290f2 [IOTDB-5372] Support data type cast in SELECT INTO
add ac726021a9 [IOTDB-5412]Print Help Message when loading empty tsfile (#8877)
add d82ae63f95 [IOTDB-5396] Iterative interface for query about TagManager (#8878)
add 5ad67dedf0 [IOTDB-5415] Move parameters into correct ConfigClass (#8867)
add 5ee9541dae [IOTDB-5417] Fix missing hasNext() before next() in TagAggregationOperator
add 974afbadb9 [IOTDB-5424] Fix FI memory allocation limit calculation
add ecc0224195 Update IoTDBConfig.java (#8887)
add 5e2e9d33c7 Fix typo in README
add bcf1b923ab [IOTDB-5382]Support DIFF as built-in scalar function in IoTDB
add 1345d259d1 [IOTDB-5423] Disable reusing same JVM and processing in random order in tests (#8890)
add 7ccc5b0497 Revert "[IOTDB-5415] Move parameters into correct ConfigClass (#8867)" (#8898)
add 7d2a79d779 Add distance-based outlier detection funtion (#8892)
add 93a2d57013 Fix files with unapporved license error after running OpenIdAuthorizerTest (#8900)
add deb848a968 [IOTDB-5429] Disable first election in RatisConsensus UT to avoid inconsistency states (#8896)
add 030302c965 [IOTDB-5287] Added status “Discouraged” to RegionGroup (#8901)
add f241aba4db [IOTDB-5140] Add metrics for compaction deserializing pages or writing chunks (#8879)
add c5e8ec4c1d [IOTDB-5432] Use freemarker to generate eventWindow and eventWindowManager
add ca84f2f904 [IOTDB-5425] Consolidate all ConfigNodeClient to be managed by clientManager (#8891)
add 6629816b25 fix win CI
add 5aaa80a37d [IOTDB-5431] Fix concurrent bug caused by using synchronizedSet() in DriverScheduler
add 1dec87939a Use gitbox thrift url instead of github to avoid download issue in China
add b9f209f69a Add AR function in Operators-Functions/Machine-Learning
add 76a8b7d720 [IOTDB-5338] WAL buffer flush threshold optimaztion (#8832)
add eef5c5c981 [IOTDB-5434] Fix occasional timeout error in CI
add 57974350ec [IOTDB-5435] Add close method for logWriter of ConfigNodeRegionStateMachine (#8917)
add 315d6526fa Use gitbox to accelerate the picture loading (#8918)
add 24b99cb9a3 [IOTDB-5426] Cannot trigger flush for sequence file when timed flush enabled (#8921)
add c130222b48 [IOTDB-5284] Fix some sonar bugs (#8846)
add fe7629694c [IOTDB-4684]Devices with the same name but different alignment properties are compacted into the wrong alignment property (#8820)
add 69ec952810 Update Programming-Go-Native-API.md (#8930)
add 2f63c44787 Chimp compression (#8766)
add f21261bdba Revert "[IOTDB-5426] Cannot trigger flush for sequence file when timed flush enabled (#8921)" (#8933)
add 8e35dc02ef [IOTDB-5320] Add executeAggregationQuery interface in session API
add e1ee85ba01 [IOTDB-5206] Set empty target resource to DELETED and then delete it after compaction (#8736)
add 648b047e18 [IOTDB-5381] Formatting variables output (#8821)
add 174242a678 [IOTDB-5418] Add metric for mods file (#8932)
add 58667c379b Fix English docs with Chinese characters (#8940)
add c807fca28b [IOTDB-5442] SchemaFile update StorageGroupNode asynchronously (#8939)
add b3117e4b32 [IOTDB-5395] Update file metrics when loading tsfile
add db6f17e77d Update SchemaFile to be compatible with MeasurementSchema.props (#8902)
add e93221f177 [IOTDB-5413] ReadWriteLock for CachedMTreeStore (#8864)
add e0663f3ab0 Bump httpclient from 4.5.13 to 4.5.14 (#8950)
add 1848fc93bb [IOTDB-5446] Add V_1_0 version and update version used in IoTDB (#8952)
add 2fc195c3a8 [IOTDB-5441] Fix NPE while fetch schema that is not in template used by related device (#8951)
add c7fa8ac1d2 [IOTDB-5455] Fix case sensitive when use Diff in where & NPE when series in where/having is not exist (#8956)
add 5c06988797 [IOTDB-5257] Optimize SyncLog Logic in IoT Consensus (#8863)
add fabc0fa4f7 Update `V_0_12`, `V_0_13` to `V_1_0` (#8961)
add a0c7c0bbe7 [IOTDB-5445] Support cluster Database heterogeneous through database definition (#8942)
add 31ac1c3027 [IOTDB-5399] Collect complete dispatch result for return (#8963)
add 35d289ee33 [IOTDB-5448] Formatting getOrCreatePartitionTables log (#8946)
add 00350a0860 Open schema cache statistics (#8969)
add 3ce5230cbd [IOTDB-5447]fix the ConcurrentModificationException (#8955)
add 5602d0ea51 Fix C++ client compile error (#8973)
add 423e525920 [IOTDB-5471] Add isDone() check in WrappedThreadPoolExecutor#afterExecute (#8983)
add c5f60c480e Accelerate Count TimeSeries (#8981)
add e5b6676ccc [IOTDB-5459] Memory control cross SchemaRegion (#8966)
add 52ddf6357a [IOTDB-5426] Cannot trigger flush for sequence file when timed flush enabled (#8938)
add a7aa8ca238 [IOTDB-5450] Add only one task of a query to timeoutQueue (#8960)
add cc83ab87f3 [IOTDB-5449] Allow query scheduler to receive more tasks (#8957)
add 907cb53d99 Modify doc of 'Show Queries' with more accurate description (#8989)
add c8d488a8d3 Renaming some variable REMOVE_DATANODE_PROCESS to REGION_MIGRATE_PROCESS (#8990)
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 9bac9aa725 Merge remote-tracking branch 'origin/master' into lmh/modelManager
add 2cd8fc889f spotless apply
No new revisions were added by this update.
Summary of changes:
.github/workflows/main-win.yml | 47 +-
.github/workflows/site-build.yml | 2 +-
Jenkinsfile | 66 +-
README.md | 4 +-
antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 18 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 16 +
cli/pom.xml | 6 +-
client-cpp/pom.xml | 2 +-
client-cpp/src/main/Session.cpp | 2 +
client-cpp/src/main/Session.h | 13 +-
client-py/iotdb/Session.py | 2 +-
client-py/iotdb/utils/IoTDBConstants.py | 1 +
client-py/pom.xml | 2 +-
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 5 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 95 +-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 1 +
.../confignode/conf/ConfigNodeDescriptor.java | 53 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 10 +-
.../consensus/request/ConfigPhysicalPlan.java | 33 +-
.../consensus/request/ConfigPhysicalPlanType.java | 14 +-
.../CountDatabasePlan.java} | 25 +-
.../GetDatabasePlan.java} | 13 +-
.../request/read/region/GetRegionInfoListPlan.java | 6 +-
...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 | 89 +-
...eption.java => DatabaseNotExistsException.java} | 6 +-
.../confignode/manager/ClusterSchemaManager.java | 347 +-
.../iotdb/confignode/manager/ConfigManager.java | 218 +-
.../apache/iotdb/confignode/manager/IManager.java | 27 +-
.../confignode/manager/PermissionManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 19 +-
.../iotdb/confignode/manager/SyncManager.java | 4 +-
.../iotdb/confignode/manager/TriggerManager.java | 8 +-
.../iotdb/confignode/manager/UDFManager.java | 4 +-
.../iotdb/confignode/manager/cq/CQManager.java | 2 +-
.../iotdb/confignode/manager/load/LoadManager.java | 6 +-
.../manager/load/LoadManagerMetrics.java | 10 +-
.../manager/load/balancer/RegionBalancer.java | 6 +-
.../manager/node/ClusterNodeStartUtils.java | 21 +-
.../iotdb/confignode/manager/node/NodeManager.java | 10 +-
.../manager/partition/PartitionManager.java | 125 +-
.../manager/partition/RegionGroupStatus.java | 11 +-
.../partition/heartbeat/RegionGroupCache.java | 17 +-
.../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 | 83 +-
.../persistence/metric/PartitionInfoMetrics.java | 43 +-
.../confignode/persistence/node/NodeInfo.java | 2 +-
...itionTable.java => DatabasePartitionTable.java} | 60 +-
.../persistence/partition/PartitionInfo.java | 110 +-
.../persistence/partition/RegionGroup.java | 19 +-
.../persistence/schema/ClusterSchemaInfo.java | 181 +-
.../persistence/sync/ClusterSyncInfo.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 22 +-
.../procedure/env/DataNodeRemoveHandler.java | 21 +-
.../impl/schema/DeleteStorageGroupProcedure.java | 16 +-
.../statemachine/CreateRegionGroupsProcedure.java | 6 +-
.../impl/statemachine/RegionMigrateProcedure.java | 15 +-
.../iotdb/confignode/service/ConfigNode.java | 4 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 216 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 71 +-
.../manager/ClusterSchemaManagerTest.java | 22 +-
.../manager/partition/RegionGroupCacheTest.java | 2 +-
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../persistence/ClusterSchemaInfoTest.java | 52 +-
.../confignode/persistence/PartitionInfoTest.java | 20 +-
.../impl/DeleteStorageGroupProcedureTest.java | 4 +-
consensus/pom.xml | 7 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 39 +-
.../org/apache/iotdb/consensus/common/Utils.java | 23 +-
.../DeserializedBatchIndexedConsensusRequest.java | 65 +
.../iotdb/consensus/config/IoTConsensusConfig.java | 15 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 1 +
.../consensus/iot/IoTConsensusServerImpl.java | 252 +-
.../consensus/iot/IoTConsensusServerMetrics.java | 69 +-
.../consensus/iot/client/DispatchLogHandler.java | 4 +-
.../iot/client/IoTConsensusClientPool.java | 4 +-
.../iotdb/consensus/iot/logdispatcher/Batch.java | 9 +
.../iot/logdispatcher/IndexController.java | 3 +-
.../logdispatcher/IoTConsensusMemoryManager.java | 24 +-
.../IoTConsensusMemoryManagerMetrics.java | 18 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 35 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 8 +-
.../service/IoTConsensusRPCServiceProcessor.java | 8 +-
.../ratis/ApplicationStateMachineProxy.java | 13 +-
.../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 +-
.../iotdb/consensus/simple/SimpleServerImpl.java | 5 +
.../apache/iotdb/consensus/EmptyStateMachine.java | 5 +
.../apache/iotdb/consensus/iot/ReplicateTest.java | 32 +-
.../apache/iotdb/consensus/iot/StabilityTest.java | 55 +-
.../iotdb/consensus/iot/util/TestStateMachine.java | 29 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 8 +
.../apache/iotdb/consensus/ratis/TestUtils.java | 13 +-
.../consensus/simple/SimpleConsensusTest.java | 5 +
distribution/pom.xml | 2 +-
docs/Development/HowtoContributeCode.md | 2 +-
docs/Download/README.md | 27 +-
docs/UserGuide/API/Programming-JDBC.md | 4 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 84 +-
docs/UserGuide/API/Programming-MQTT.md | 6 +-
.../Data-Concept/Data-Model-and-Terminology.md | 2 +-
docs/UserGuide/Data-Concept/Data-Type.md | 25 +-
docs/UserGuide/Data-Concept/Encoding.md | 35 +-
.../UserGuide/Ecosystem-Integration/Flink-IoTDB.md | 3 +-
docs/UserGuide/FAQ/Frequently-asked-questions.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 9 +-
docs/UserGuide/Monitor-Alert/Alerting.md | 2 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 149 +-
.../Apache-IoTDB-DataNode-Dashboard.json | 12251 ++++++++++++++++---
...ache-IoTDB-Performance-Overview-Dashboard.json} | 2112 ++--
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 501 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 98 +-
.../Operators-Functions/Anomaly-Detection.md | 71 +-
.../Operators-Functions/Data-Repairing.md | 104 +
.../Operators-Functions/Machine-Learning.md | 84 +
.../Operators-Functions/Variation-Trend.md | 63 +
docs/UserGuide/Query-Data/Group-By.md | 189 +-
docs/UserGuide/Query-Data/Overview.md | 56 +-
docs/UserGuide/Query-Data/Select-Into.md | 2 +-
.../UserGuide/QuickStart/Command-Line-Interface.md | 2 +-
docs/UserGuide/QuickStart/Files.md | 2 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 6 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 47 +-
docs/UserGuide/Reference/Status-Codes.md | 16 +-
docs/zh/Download/README.md | 27 +-
docs/zh/UserGuide/API/Programming-Go-Native-API.md | 2 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 4 +-
.../UserGuide/API/Programming-Java-Native-API.md | 76 +-
docs/zh/UserGuide/API/Programming-MQTT.md | 6 +-
.../Data-Concept/Data-Model-and-Terminology.md | 2 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 33 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 33 +-
.../UserGuide/Ecosystem-Integration/Flink-IoTDB.md | 8 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 2 +-
.../Maintenance-Tools/Maintenance-Command.md | 9 +-
docs/zh/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 468 +-
.../UserGuide/Operators-Functions/Aggregation.md | 92 +-
.../Operators-Functions/Anomaly-Detection.md | 73 +-
.../Operators-Functions/Data-Repairing.md | 102 +
.../Operators-Functions/Machine-Learning.md | 85 +
docs/zh/UserGuide/Operators-Functions/Overview.md | 5 +
.../Operators-Functions/Variation-Trend.md | 63 +
docs/zh/UserGuide/Query-Data/Group-By.md | 182 +
docs/zh/UserGuide/Query-Data/Overview.md | 58 +-
docs/zh/UserGuide/Query-Data/Select-Into.md | 2 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 81 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 254 +-
example/client-cpp-example/pom.xml | 2 +-
example/ext-pipe-plugin-example/pom.xml | 4 +-
example/flink/pom.xml | 2 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 2 +-
.../org/apache/iotdb/flink/FlinkIoTDBSource.java | 5 +-
example/hadoop/pom.xml | 2 +-
example/influxdb-protocol-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 2 +-
.../iotdb/SyntaxConventionRelatedExample.java | 2 +-
example/kafka/pom.xml | 2 +-
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 +-
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 63 +-
example/rest-java-example/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 70 +-
.../iotdb/SyntaxConventionRelatedExample.java | 2 +-
example/trigger/pom.xml | 2 +-
example/tsfile/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
external-api/pom.xml | 2 +-
external-pipe-api/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana-connector/pom.xml | 4 +-
grafana-plugin/pom.xml | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 4 +-
influxdb-protocol/pom.xml | 6 +-
integration-test/checkstyle.xml | 4 +-
integration-test/import-control.xml | 5 +-
integration-test/pom.xml | 13 +-
.../apache/iotdb/it/env/cluster/AbstractEnv.java | 99 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 43 +-
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 19 +-
.../iotdb/it/env/cluster/DataNodeWrapper.java | 9 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 25 +-
.../iotdb/it/env/cluster/MppClusterConfig.java | 15 +
.../iotdb/it/env/cluster/MppCommonConfig.java | 29 +-
.../apache/iotdb/it/env/cluster/MppJVMConfig.java | 116 +
.../it/env/cluster/MppSharedCommonConfig.java | 31 +-
.../iotdb/it/env/remote/RemoteClusterConfig.java | 12 +
.../iotdb/it/env/remote/RemoteCommonConfig.java | 13 +-
.../iotdb/it/env/remote/RemoteJVMConfig.java | 26 +-
.../iotdb/it/env/remote/RemoteServerEnv.java | 47 +
.../framework/IoTDBTestRunnerWithParameters.java | 59 +
.../IoTDBTestRunnerWithParametersFactory.java | 23 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 1 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 130 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 2 -
.../org/apache/iotdb/itbase/env/ClusterConfig.java | 30 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 10 +-
.../env/{BaseNodeWrapper.java => JVMConfig.java} | 47 +-
.../confignode/it/IoTDBClusterAuthorityIT.java | 1 +
.../it/IoTDBConfigNodeConsensusEfficiencyIT.java | 203 +
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 9 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 1 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 141 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 4 +-
.../it/cluster/IoTDBClusterRestartIT.java | 9 +-
.../it/database/IoTDBDatabaseRegionControlIT.java | 236 +
.../IoTDBDatabaseSetAndDeleteIT.java} | 85 +-
.../load/IoTDBClusterRegionLeaderBalancingIT.java | 37 +-
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 7 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 89 +-
.../IoTDBCustomRegionGroupExtensionIT.java | 14 +-
...urableIT.java => IoTDBPartitionCreationIT.java} | 612 +-
.../it/partition/IoTDBPartitionDurableIT.java | 103 +-
.../it/partition/IoTDBPartitionGetterIT.java | 114 +-
.../partition/IoTDBPartitionInheritPolicyIT.java | 6 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 1 -
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 1 +
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 7 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 16 +-
.../it/aggregation/IoTDBAggregationByLevel2IT.java | 26 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 4 +-
.../IoTDBCountIf2IT.java} | 30 +-
.../IoTDBCountIf3IT.java} | 34 +-
.../iotdb/db/it/aggregation/IoTDBCountIfIT.java | 241 +
.../db/it/alignbydevice/IoTDBAlignByDevice2IT.java | 26 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 2 +-
.../IoTDBOrderByWithAlignByDevice2IT.java | 26 +-
.../IoTDBOrderByWithAlignByDeviceIT.java | 2 +-
.../IoTDBAlignedSeriesQuery4IT.java} | 33 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 10 -
.../scalar/IoTDBDiffFunction2IT.java} | 30 +-
.../scalar/IoTDBDiffFunction3IT.java} | 30 +-
.../scalar/IoTDBDiffFunctionIT.java | 360 +
.../iotdb/db/it/groupby/IoTDBGroupBySeriesIT.java | 404 +
.../db/it/groupby/IoTDBGroupByVariationIT.java | 541 +
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 40 +
.../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 | 746 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 28 +-
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 13 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 33 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 237 +-
.../apache/iotdb/db/it/sync/SyncTransportTest.java | 4 +-
.../apache/iotdb/db/it/utils/AlignedWriteUtil.java | 12 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 45 +
.../apache/iotdb/libudf/it/anomaly/AnomalyIT.java | 66 +
.../apache/iotdb/libudf/it/dlearn/DLearnIT.java | 311 +
.../session/it/IoTDBSessionAlignedInsertIT.java | 2 -
.../iotdb/session/it/IoTDBSessionComplexIT.java | 2 -
.../it/IoTDBSessionDisableMemControlIT.java | 2 -
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 2 -
.../iotdb/session/it/IoTDBSessionQueryIT.java | 327 +
.../session/it/IoTDBSessionSchemaTemplateIT.java | 2 -
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 2 -
.../session/it/IoTDBSessionSyntaxConventionIT.java | 2 -
.../org/apache/iotdb/session/it/SessionIT.java | 83 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 230 +-
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 12 +-
.../src/test/resources/logback-test.xml | 2 +
integration/pom.xml | 2 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 3 -
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 6 +-
.../IoTDBDeletionVersionAdaptionIT.java | 18 +-
.../IoTDBQueryVersionAdaptionIT.java | 8 +-
isession/pom.xml | 2 +-
.../java/org/apache/iotdb/isession/ISession.java | 32 +
.../org/apache/iotdb/isession/SessionConfig.java | 2 +-
.../apache/iotdb/isession/pool/ISessionPool.java | 27 +-
.../org/apache/iotdb/isession/util/Version.java | 3 +-
jdbc/pom.xml | 6 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 4 +-
.../main/java/org/apache/iotdb/jdbc/Constant.java | 3 +-
library-udf/pom.xml | 2 +-
.../apache/iotdb/library/anomaly/UDTFOutlier.java | 99 +
.../org/apache/iotdb/library/dlearn/UDTFAR.java | 131 +
metrics/dropwizard-metrics/pom.xml | 2 +-
metrics/interface/pom.xml | 2 +-
.../iotdb/metrics/AbstractMetricService.java | 21 +-
.../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/prometheus/PrometheusReporter.java | 6 +-
.../iotdb/metrics/type/HistogramSnapshot.java | 4 +-
metrics/micrometer-metrics/pom.xml | 4 +-
.../micrometer/MicrometerMetricManager.java | 4 +-
metrics/pom.xml | 5 +-
mlnode/pom.xml | 2 +-
node-commons/pom.xml | 6 +-
.../resources/conf/iotdb-common.properties | 55 +-
.../apache/iotdb/commons/client/ClientManager.java | 13 +-
.../iotdb/commons/concurrent/ThreadName.java | 6 +-
.../threadpool/WrappedThreadPoolExecutor.java | 5 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 5 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 16 +-
.../commons/service/metric/MetricService.java | 10 +-
.../iotdb/commons/service/metric/enums/Metric.java | 5 +-
.../commons/service/metric/enums/Operation.java | 40 -
.../udf/builtin/BuiltinAggregationFunction.java | 47 +
...gregationFunction.java => BuiltinFunction.java} | 39 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 24 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 4 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 14 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 6 +-
openapi/pom.xml | 2 +-
pom.xml | 13 +-
rewrite-tsfile-tool/pom.xml | 2 +-
.../java/org/apache/iotdb/RewriteTsFileTool.java | 5 +-
schema-engine-rocksdb/pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 68 +-
.../rocksdb/mnode/RStorageGroupMNode.java | 6 +-
schema-engine-tag/pom.xml | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 54 +-
server/pom.xml | 6 +-
.../resources/conf/iotdb-datanode.properties | 9 -
.../resources/tools/tsfile/settle-tsfile.bat | 62 +
.../resources/tools/tsfile/settle-tsfile.sh | 32 +-
server/src/main/codegen/config.fmpp | 1 +
.../{config.fmpp => dataModel/CompareType.tdd} | 17 +-
.../src/main/codegen/templates/evEventWindow.ftl | 67 +
.../codegen/templates/evEventWindowManager.ftl | 113 +
server/src/main/codegen/templates/eventWindow.ftl | 84 +
.../main/codegen/templates/eventWindowManager.ftl | 51 +
.../apache/iotdb/db/audit/AuditLogOperation.java | 16 +-
.../org/apache/iotdb/db/audit/AuditLogStorage.java | 14 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 236 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 10 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 94 +-
.../iotdb/db/client/DataNodeInternalClient.java | 8 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 208 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 86 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 6 +
.../db/consensus/DataRegionConsensusImpl.java | 20 +-
.../consensus/statemachine/BaseStateMachine.java | 9 +-
.../statemachine/DataRegionStateMachine.java | 251 +-
.../IoTConsensusDataRegionStateMachine.java | 117 +
.../statemachine/SchemaRegionStateMachine.java | 11 +-
.../org/apache/iotdb/db/constant/SqlConstant.java | 4 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 12 +-
.../iotdb/db/engine/TsFileMetricManager.java | 28 +
.../exception/CompactionExceptionHandler.java | 15 +-
.../performer/impl/FastCompactionPerformer.java | 23 +-
.../impl/ReadChunkCompactionPerformer.java | 5 +-
.../execute/recover/CompactionRecoverTask.java | 110 +-
.../execute/task/AbstractCompactionTask.java | 18 +-
.../execute/task/CompactionTaskSummary.java | 82 +-
.../execute/task/CrossSpaceCompactionTask.java | 91 +-
.../execute/task/InnerSpaceCompactionTask.java | 70 +-
.../subtask/FastCompactionPerformerSubTask.java | 6 +-
...Summary.java => FastCompactionTaskSummary.java} | 27 +-
.../compaction/execute/utils/CompactionUtils.java | 23 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 60 +-
.../fast/AlignedSeriesCompactionExecutor.java | 4 +-
.../fast/NonAlignedSeriesCompactionExecutor.java | 4 +-
.../executor/fast/SeriesCompactionExecutor.java | 67 +-
.../fast/element/ChunkMetadataElement.java | 3 +
.../readchunk/AlignedSeriesCompactionExecutor.java | 44 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 60 +-
.../execute/utils/log/CompactionLogAnalyzer.java | 26 +-
.../execute/utils/log/CompactionLogger.java | 12 +
.../execute/utils/log/TsFileIdentifier.java | 6 +-
.../execute/utils/reader/PointPriorityReader.java | 14 +-
.../utils/writer/AbstractCompactionWriter.java | 15 +-
.../writer/AbstractCrossCompactionWriter.java | 5 +-
.../writer/AbstractInnerCompactionWriter.java | 4 +-
.../compaction/schedule/CompactionScheduler.java | 8 +-
.../compaction/schedule/CompactionTaskManager.java | 15 +-
.../compaction/schedule/CompactionWorker.java | 7 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 13 +-
.../iotdb/db/engine/flush/FlushManagerMetrics.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 8 +-
.../db/engine/modification/ModificationFile.java | 9 +
.../db/engine/settle/SettleRequestHandler.java | 323 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 170 +-
.../db/engine/storagegroup/DataRegionInfo.java | 17 +-
.../engine/storagegroup/HashLastFlushTimeMap.java | 2 +-
.../storagegroup/IDTableLastFlushTimeMap.java | 2 +-
.../db/engine/storagegroup/TsFileManager.java | 16 +-
.../db/engine/storagegroup/TsFileProcessor.java | 21 +
.../db/engine/storagegroup/TsFileResource.java | 7 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 294 -
.../db/localconfignode/LocalDataPartitionInfo.java | 111 -
.../localconfignode/LocalDataPartitionTable.java | 127 -
.../localconfignode/LocalSchemaPartitionTable.java | 122 -
.../iotdb/db/metadata/LocalSchemaProcessor.java | 250 -
.../apache/iotdb/db/metadata/MetadataConstant.java | 1 +
.../db/metadata/cache/DataNodeSchemaCache.java | 160 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 18 +-
.../metadata/cache/dualkeycache/IDualKeyCache.java | 57 +
.../dualkeycache/IDualKeyCacheComputation.java} | 28 +-
.../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 | 7 +-
.../dualkeycache/impl/ICacheEntry.java} | 25 +-
.../dualkeycache/impl/ICacheEntryGroup.java} | 44 +-
.../dualkeycache/impl/ICacheEntryManager.java} | 26 +-
.../dualkeycache/impl/ICacheSizeComputer.java | 12 +-
.../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 +-
.../db/metadata/mnode/IStorageGroupMNode.java | 6 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 6 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 10 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 21 -
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 6 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 383 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 301 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 45 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 328 +-
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 10 +
.../db/metadata/mtree/store/MemMTreeStore.java | 71 +-
.../store/ReentrantReadOnlyCachedMTreeStore.java | 136 +
.../mtree/store/StampedWriterPreferredLock.java | 207 +
.../mtree/store/disk/MTreeFlushTaskManager.java | 71 -
.../mtree/store/disk/MTreeReleaseTaskManager.java | 73 -
.../mtree/store/disk/cache/CacheManager.java | 55 +-
.../mtree/store/disk/cache/CacheMemoryManager.java | 282 +
.../mtree/store/disk/cache/ICacheManager.java | 3 +
.../mtree/store/disk/cache/LRUCacheManager.java | 6 +-
.../mtree/store/disk/cache/PlainCacheManager.java | 5 +
.../disk/memcontrol/IReleaseFlushStrategy.java | 28 +-
.../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/RecordUtils.java | 23 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 29 +-
.../disk/schemafile/pagemgr/BTreePageManager.java | 5 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 27 +-
.../db/metadata/mtree/traverser/Traverser.java | 36 +-
.../traverser/TraverserWithLimitOffsetWrapper.java | 10 +
.../mtree/traverser/basic/DatabaseTraverser.java | 6 +-
.../mtree/traverser/basic/EntityTraverser.java | 6 +-
.../mtree/traverser/basic/MNodeTraverser.java | 6 +-
.../traverser/basic/MeasurementTraverser.java | 6 +-
.../MeasurementCounter.java} | 34 +-
.../mtree/traverser/updater/EntityUpdater.java | 6 +-
.../traverser/updater/MeasurementUpdater.java | 6 +-
.../schemaregion/result/ShowTimeSeriesResult.java | 10 +-
.../metadata/query/info/ITimeSeriesSchemaInfo.java | 5 +-
.../db/metadata/query/reader/ISchemaReader.java | 16 +-
.../rescon/CachedSchemaEngineStatistics.java | 84 +
.../rescon/CachedSchemaRegionStatistics.java | 94 +
.../metadata/rescon/ISchemaEngineStatistics.java | 25 +-
.../metadata/rescon/ISchemaRegionStatistics.java | 24 +-
...tistics.java => MemSchemaEngineStatistics.java} | 68 +-
.../metadata/rescon/MemSchemaRegionStatistics.java | 93 +
.../SchemaEngineStatisticsHolder.java} | 24 +-
.../db/metadata/rescon/SchemaResourceManager.java | 20 +-
.../rescon/SchemaResourceManagerMetrics.java | 30 +-
.../metadata/rescon/SchemaStatisticsManager.java | 56 -
.../db/metadata/schemaregion/ISchemaRegion.java | 74 +-
.../db/metadata/schemaregion/SchemaEngine.java | 9 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 169 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 309 +-
.../storagegroup/IStorageGroupSchemaManager.java | 53 -
.../storagegroup/StorageGroupSchemaManager.java | 78 -
.../apache/iotdb/db/metadata/tag/TagManager.java | 132 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 69 +-
.../iotdb/db/mpp/aggregation/Accumulator.java | 8 +-
.../db/mpp/aggregation/AccumulatorFactory.java | 64 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 6 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 34 +-
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 9 +-
...untAccumulator.java => CountIfAccumulator.java} | 85 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 34 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 62 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 36 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 50 +-
.../mpp/aggregation/LastValueDescAccumulator.java | 36 +-
.../db/mpp/aggregation/MaxTimeAccumulator.java | 6 +-
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 6 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 34 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 6 +-
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 6 +-
.../db/mpp/aggregation/MinValueAccumulator.java | 34 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 34 +-
.../slidingwindow/SlidingWindowAggregator.java | 2 +-
.../SlidingWindowAggregatorFactory.java | 13 +-
.../iotdb/db/mpp/common/FragmentInstanceId.java | 7 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 37 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 6 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 33 +
.../common/schematree/DeviceGroupSchemaTree.java | 94 -
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 71 -
.../common/schematree/IMeasurementSchemaInfo.java} | 13 +-
.../schematree/node/SchemaMeasurementNode.java | 3 +-
.../schematree/visitor/SchemaTreeVisitor.java | 1 +
.../iotdb/db/mpp/execution/StateMachine.java | 4 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 37 +-
.../db/mpp/execution/driver/DataDriverContext.java | 48 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 42 +-
.../db/mpp/execution/driver/DriverContext.java | 85 +-
.../iotdb/db/mpp/execution/driver/IDriver.java | 7 +-
.../db/mpp/execution/driver/SchemaDriver.java | 5 +-
.../mpp/execution/driver/SchemaDriverContext.java | 14 +-
.../exchange/IMPPDataExchangeManager.java | 4 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 27 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 31 +-
.../execution/exchange/MPPDataExchangeManager.java | 219 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 28 +-
.../db/mpp/execution/exchange/SinkHandle.java | 31 +-
.../db/mpp/execution/exchange/SourceHandle.java | 41 +-
.../execution/executor/RegionWriteExecutor.java | 159 +-
.../fragment/FragmentInstanceContext.java | 127 +-
.../fragment/FragmentInstanceExecution.java | 25 +-
.../fragment/FragmentInstanceManager.java | 45 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 44 +-
.../db/mpp/execution/operator/AggregationUtil.java | 3 +-
.../db/mpp/execution/operator/OperatorContext.java | 32 +-
.../operator/factory/OperatorFactory.java} | 26 +-
.../operator/factory/SourceOperatorFactory.java} | 24 +-
.../operator/process/AbstractIntoOperator.java | 47 +-
.../operator/process/AggregationOperator.java | 6 +-
.../operator/process/DeviceViewIntoOperator.java | 8 +-
.../execution/operator/process/IntoOperator.java | 10 +-
.../process/RawDataAggregationOperator.java | 76 +-
.../process/SingleInputAggregationOperator.java | 12 +-
.../process/SlidingWindowAggregationOperator.java | 13 +-
.../operator/process/TagAggregationOperator.java | 2 +-
...erator.java => HorizontallyConcatOperator.java} | 11 +-
.../process/join/RowBasedTimeJoinOperator.java | 6 +
.../operator/process/join/TimeJoinOperator.java | 1 -
.../last/AbstractUpdateLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelMergeOperator.java | 7 +
...tor.java => CountGroupByLevelScanOperator.java} | 79 +-
.../operator/schema/CountMergeOperator.java | 7 +
.../operator/schema/DevicesCountOperator.java | 65 -
.../schema/NodePathsSchemaScanOperator.java | 159 -
.../operator/schema/SchemaCountOperator.java | 36 +-
.../operator/schema/SchemaQueryScanOperator.java | 37 +-
.../operator/schema/TimeSeriesCountOperator.java | 85 -
.../DeviceSchemaSource.java} | 66 +-
.../operator/schema/source/ISchemaSource.java | 50 +
.../operator/schema/source/NodeSchemaSource.java | 81 +
.../PathsUsingTemplateSource.java} | 81 +-
.../schema/source/SchemaSourceFactory.java | 78 +
.../TimeSeriesSchemaSource.java} | 81 +-
.../AbstractSeriesAggregationScanOperator.java | 8 +-
.../operator/source/AlignedSeriesScanUtil.java | 3 +-
.../operator/source/ExchangeOperator.java | 4 +
.../operator/source/SeriesScanOperator.java | 76 +-
.../execution/operator/source/SeriesScanUtil.java | 6 +-
.../window/{TimeWindow.java => EventWindow.java} | 69 +-
.../operator/window/EventWindowManager.java | 122 +
.../operator/window/EventWindowParameter.java | 61 +
.../db/mpp/execution/operator/window/IWindow.java | 2 +-
.../execution/operator/window/IWindowManager.java | 95 +-
.../execution/operator/window/SeriesWindow.java | 109 +
.../operator/window/SeriesWindowManager.java | 191 +
.../operator/window/SeriesWindowParameter.java | 53 +
.../mpp/execution/operator/window/TimeWindow.java | 2 +-
.../operator/window/TimeWindowManager.java | 80 +-
.../operator/window/TimeWindowParameter.java | 11 +-
.../operator/window/WindowManagerFactory.java | 88 +
.../operator/window/WindowParameter.java} | 23 +-
.../mpp/execution/operator/window/WindowType.java | 19 +-
.../execution/schedule/AbstractDriverThread.java | 9 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 303 +-
...eption.java => DriverTaskAbortedException.java} | 8 +-
.../mpp/execution/schedule/DriverTaskThread.java | 20 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../mpp/execution/schedule/ExecutionContext.java | 10 +
.../mpp/execution/schedule/IDriverScheduler.java | 9 -
.../schedule/queue/IDIndexedAccessible.java | 2 +-
.../schedule/queue/IndexedBlockingQueue.java | 10 +-
.../queue/IndexedBlockingReserveQueue.java | 81 +
.../execution/schedule/queue/L1PriorityQueue.java | 10 +-
.../execution/schedule/queue/L2PriorityQueue.java | 16 +-
.../queue/multilevelqueue/DriverTaskHandle.java | 92 +
.../multilevelqueue/MultilevelPriorityQueue.java | 290 +
.../schedule/queue/multilevelqueue/Priority.java | 73 +
.../db/mpp/execution/schedule/task/DriverTask.java | 134 +-
.../task/{DriverTaskID.java => DriverTaskId.java} | 49 +-
...tricSet.java => DataExchangeCostMetricSet.java} | 10 +-
.../db/mpp/metric/DataExchangeCountMetricSet.java | 119 +
.../db/mpp/metric/PerformanceOverviewMetrics.java | 142 +
.../metric/PerformanceOverviewMetricsManager.java | 177 +
.../db/mpp/metric/QueryExecutionMetricSet.java | 5 -
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 17 +-
.../db/mpp/metric/QueryPlanCostMetricSet.java | 9 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 14 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 49 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 319 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 76 +-
.../db/mpp/plan/analyze/ConcatPathRewriter.java | 25 +
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 112 +-
.../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 7 +
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 63 +
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 5 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 23 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 276 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 10 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 311 +-
.../schema/ISchemaAutoCreation.java} | 24 +-
.../schema/ISchemaComputation.java} | 25 +-
.../schema/ISchemaComputationWithAutoCreation.java | 10 +-
.../db/mpp/plan/analyze/schema/ISchemaFetcher.java | 44 +-
.../mpp/plan/analyze/schema/ISchemaValidation.java | 33 +-
.../mpp/plan/analyze/schema/SchemaValidator.java | 34 +-
.../db/mpp/plan/execution/QueryExecution.java | 41 +-
.../plan/execution/config/ConfigTaskVisitor.java | 13 +-
.../config/executor/ClusterConfigTaskExecutor.java | 123 +-
.../config/executor/IConfigTaskExecutor.java | 7 +-
.../config/metadata/DatabaseSchemaTask.java | 80 +
.../config/metadata/SetStorageGroupTask.java | 67 -
.../execution/config/metadata/ShowRegionTask.java | 10 +-
.../config/metadata/ShowStorageGroupTask.java | 42 -
.../config/metadata/ShowVariablesTask.java | 4 -
.../db/mpp/plan/expression/ExpressionFactory.java | 103 +
.../plan/expression/multi/FunctionExpression.java | 35 +-
.../db/mpp/plan/expression/multi/FunctionType.java | 12 +-
.../visitor/ColumnTransformerVisitor.java | 23 +
.../visitor/IntermediateLayerVisitor.java | 22 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 200 +-
.../db/mpp/plan/parser/StatementGenerator.java | 359 +-
.../plan/planner/LocalExecutionPlanContext.java | 193 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 109 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 43 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 62 +-
.../plan/planner/MemoryDistributionCalculator.java | 472 -
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 697 +-
.../db/mpp/plan/planner/PipelineDriverFactory.java | 80 +
.../distribution/DistributionPlanContext.java | 14 +
.../planner/distribution/ExchangeNodeAdder.java | 10 +-
.../plan/planner/distribution/SourceRewriter.java | 109 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 4 +-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 23 +
.../mpp/plan/planner/plan/node/PlanNodeType.java | 14 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 14 +-
.../write/InternalBatchActivateTemplateNode.java | 162 +
.../write/InternalCreateMultiTimeSeriesNode.java | 164 +
.../planner/plan/node/process/AggregationNode.java | 165 +-
.../planner/plan/node/process/DeviceMergeNode.java | 6 +
.../plan/node/process/GroupByLevelNode.java | 7 +
.../planner/plan/node/process/GroupByTagNode.java | 7 +
...ConcatNode.java => HorizontallyConcatNode.java} | 26 +-
.../planner/plan/node/process/MergeSortNode.java | 19 +
.../planner/plan/node/process/TimeJoinNode.java | 8 +
.../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 | 96 +-
.../planner/plan/parameter/AggregationType.java | 113 -
.../CrossSeriesAggregationDescriptor.java | 110 +-
.../parameter/DeviceViewIntoPathDescriptor.java | 45 +-
.../planner/plan/parameter/GroupByParameter.java | 89 +
.../plan/parameter/GroupBySeriesParameter.java | 78 +
.../plan/parameter/GroupByTimeParameter.java | 2 +
.../plan/parameter/GroupByVariationParameter.java | 81 +
.../planner/plan/parameter/IntoPathDescriptor.java | 27 +-
.../db/mpp/plan/scheduler/AsyncPlanNodeSender.java | 105 +
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 61 +
.../db/mpp/plan/scheduler/ClusterScheduler.java | 14 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 95 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +-
.../iotdb/db/mpp/plan/statement/StatementType.java | 5 +-
.../db/mpp/plan/statement/StatementVisitor.java | 22 +-
.../{WhereCondition.java => GroupByComponent.java} | 36 +-
...eCondition.java => GroupBySeriesComponent.java} | 26 +-
.../statement/component/GroupByTimeComponent.java | 2 +-
.../component/GroupByVariationComponent.java} | 24 +-
.../plan/statement/component/WhereCondition.java | 6 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 49 +-
.../InternalBatchActivateTemplateStatement.java} | 47 +-
.../InternalCreateMultiTimeSeriesStatement.java} | 45 +-
...Statement.java => DatabaseSchemaStatement.java} | 97 +-
.../metadata/ShowStorageGroupStatement.java | 66 +
.../unary/DiffFunctionColumnTransformer.java | 67 +
.../transformer/unary/DiffFunctionTransformer.java | 103 +
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 +-
.../iotdb/db/query/control/SessionManager.java | 45 +-
.../query/control/clientsession/ClientSession.java | 2 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 2 +
.../java/org/apache/iotdb/db/service/DataNode.java | 30 +-
.../db/service/DataNodeServerCommandLine.java | 17 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +-
.../iotdb/db/service/RegionMigrateService.java | 14 +-
.../db/service/metrics/CompactionMetrics.java | 232 +
.../db/service/metrics/DataNodeMetricsHelper.java | 7 +-
.../iotdb/db/service/metrics/FileMetrics.java | 44 +-
.../metrics/IoTDBInternalLocalReporter.java | 4 +-
.../metrics/recorder/CompactionMetricsManager.java | 225 +
.../recorder/CompactionMetricsRecorder.java | 151 -
.../service/thrift/impl/ClientRPCServiceImpl.java | 236 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 41 +-
.../db/sync/transport/server/ReceiverManager.java | 5 +-
.../tools/settle/TsFileSettleByCompactionTool.java | 123 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 15 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 169 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 17 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 58 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 16 +-
.../iotdb/db/engine/MetadataManagerHelper.java | 158 -
.../engine/compaction/AbstractCompactionTest.java | 6 +
.../engine/compaction/CompactionSchedulerTest.java | 1 +
.../CompactionSchedulerWithFastPerformerTest.java | 1 +
.../compaction/FastAlignedCrossCompactionTest.java | 134 +
.../FastCrossCompactionPerformerTest.java | 54 +-
.../FastNonAlignedCrossCompactionTest.java | 138 +
.../ReadPointCompactionPerformerTest.java | 13 +-
.../compaction/TestUtilsForAlignedSeries.java | 42 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 232 +-
.../CrossSpaceCompactionWithFastPerformerTest.java | 2 +
...eCompactionWithFastPerformerValidationTest.java | 19 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 2 +
...actionWithReadPointPerformerValidationTest.java | 1 +
.../db/engine/compaction/cross/MergeTest.java | 19 -
.../engine/compaction/cross/MergeUpgradeTest.java | 2 +
.../cross/RewriteCompactionFileSelectorTest.java | 33 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 266 +
.../inner/AbstractInnerSpaceCompactionTest.java | 19 -
.../inner/FastCompactionPerformerAlignedTest.java | 21 +-
.../FastCompactionPerformerNoAlignedTest.java | 20 +-
.../InnerSeqCompactionWithFastPerformerTest.java | 8 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 25 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 203 +-
.../InnerUnseqCompactionWithFastPerformerTest.java | 4 +-
...rUnseqCompactionWithReadPointPerformerTest.java | 19 -
.../ReadChunkCompactionPerformerAlignedTest.java | 3 -
.../SizeTieredCompactionRecoverTest.java | 257 +-
.../SizeTieredCompactionSelectorTest.java | 4 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 19 -
.../recover/SizeTieredCompactionRecoverTest.java | 34 +-
.../compaction/utils/CompactionConfigRestorer.java | 4 +
.../utils/MultiTsFileDeviceIteratorTest.java | 105 +
.../db/engine/memtable/MemTableFlushTaskTest.java | 2 -
.../db/engine/settle/SettleRequestHandlerTest.java | 162 +
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 8 -
.../cache/dualkeycache/DualKeyCacheTest.java | 110 +
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 24 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 31 +-
.../mtree/lock/StampedWriterPreferredLockTest.java | 212 +
.../metadata/mtree/schemafile/RecordUtilTests.java | 10 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 2 +-
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 61 +-
.../schemaRegion/SchemaRegionBasicTest.java | 88 +-
.../schemaRegion/SchemaRegionManagementTest.java | 43 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 68 +-
.../schemaRegion/SchemaRegionTestUtil.java | 57 +-
.../schemaRegion/SchemaStatisticsTest.java | 252 +
.../iotdb/db/mpp/aggregation/AccumulatorTest.java | 73 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 52 +-
.../execution/exchange/LocalSinkHandleTest.java | 40 +-
.../execution/exchange/LocalSourceHandleTest.java | 12 +-
.../exchange/MPPDataExchangeManagerTest.java | 8 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 28 +-
.../mpp/execution/exchange/SourceHandleTest.java | 90 +-
.../operator/AggregationOperatorTest.java | 79 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 205 +-
.../operator/AlignedSeriesScanOperatorTest.java | 92 +-
.../execution/operator/AlignedSeriesTestUtil.java | 53 -
.../operator/DeviceMergeOperatorTest.java | 77 +-
.../execution/operator/DeviceViewOperatorTest.java | 16 +-
.../mpp/execution/operator/FillOperatorTest.java | 17 +-
...st.java => HorizontallyConcatOperatorTest.java} | 52 +-
.../operator/LastQueryMergeOperatorTest.java | 25 +-
.../execution/operator/LastQueryOperatorTest.java | 49 +-
.../operator/LastQuerySortOperatorTest.java | 49 +-
.../mpp/execution/operator/LimitOperatorTest.java | 22 +-
.../execution/operator/LinearFillOperatorTest.java | 57 +-
.../execution/operator/MergeSortOperatorTest.java | 205 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 73 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 327 +-
.../operator/RawDataAggregationOperatorTest.java | 604 +-
.../SeriesAggregationScanOperatorTest.java | 218 +-
.../execution/operator/SeriesScanOperatorTest.java | 8 +-
.../operator/SingleDeviceViewOperatorTest.java | 20 +-
.../SlidingWindowAggregationOperatorTest.java | 57 +-
.../execution/operator/TimeJoinOperatorTest.java | 56 +-
.../operator/UpdateLastCacheOperatorTest.java | 13 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 155 +-
.../operator/schema/SchemaCountOperatorTest.java | 283 +-
.../operator/schema/SchemaOperatorTestUtil.java | 66 +
.../schema/SchemaQueryScanOperatorTest.java | 146 +-
.../schedule/DefaultDriverSchedulerTest.java | 229 +-
.../execution/schedule/DriverSchedulerTest.java | 66 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 41 +-
.../schedule/queue/L1PriorityQueueTest.java | 30 +-
.../schedule/queue/L2PriorityQueueTest.java | 36 +-
.../mpp/execution/schedule/queue/QueueElement.java | 4 +-
.../plan/analyze/AggregationDescriptorTest.java | 75 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 6 +-
.../mpp/plan/analyze/ExpressionAnalyzerTest.java | 83 +
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 24 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 6 +-
.../db/mpp/plan/plan/PipelineBuilderTest.java | 762 ++
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 110 +-
.../iotdb/db/mpp/plan/plan/QueryPlannerTest.java | 17 +-
.../distribution/AggregationDistributionTest.java | 88 +-
.../plan/distribution/AlignedByDeviceTest.java | 108 +
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 21 +-
.../node/process/AggregationNodeSerdeTest.java | 118 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 10 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 14 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 4 +-
.../query/reader/series/SeriesReaderTestUtil.java | 18 +
.../iotdb/db/rescon/ResourceManagerTest.java | 19 -
.../security/encrypt/MessageDigestEncryptTest.java | 2 +-
.../DataNodeInternalRPCServiceImplTest.java | 11 +-
.../db/sync/datasource/PipeOpManagerTest.java | 3 -
.../apache/iotdb/db/utils/EnvironmentUtils.java | 16 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 22 +-
.../db/wal/recover/WALRecoverManagerTest.java | 32 -
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 53 -
.../file/UnsealedTsFileRecoverPerformerTest.java | 31 -
.../src/test/resources/iotdb-datanode.properties | 2 +-
service-rpc/pom.xml | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
session/pom.xml | 6 +-
.../java/org/apache/iotdb/session/Session.java | 135 +-
.../apache/iotdb/session/SessionConnection.java | 92 +
.../org/apache/iotdb/session/pool/SessionPool.java | 126 +-
.../java/org/apache/iotdb/session/TabletTest.java | 81 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 63 +
site/pom.xml | 22 +-
.../replace-picture-urls.sh | 11 +-
site/src/main/.vuepress/config.js | 6 +-
spark-iotdb-connector/pom.xml | 2 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 3 -
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 2 +-
thrift-commons/pom.xml | 2 +-
thrift-commons/src/main/thrift/common.thrift | 18 +
thrift-confignode/pom.xml | 2 +-
.../src/main/thrift/confignode.thrift | 142 +-
thrift-influxdb/pom.xml | 2 +-
thrift-iot-consensus/pom.xml | 2 +-
thrift-mlnode/pom.xml | 2 +-
thrift/pom.xml | 2 +-
thrift/src/main/thrift/client.thrift | 25 +-
thrift/src/main/thrift/datanode.thrift | 2 +
trigger-api/pom.xml | 2 +-
tsfile/pom.xml | 6 +-
.../iotdb/tsfile/encoding/decoder/Decoder.java | 14 +
.../decoder/DoublePrecisionChimpDecoder.java | 46 +-
.../tsfile/encoding/decoder/IntChimpDecoder.java | 156 +
.../tsfile/encoding/decoder/LongChimpDecoder.java | 155 +
.../decoder/SinglePrecisionChimpDecoder.java | 46 +-
.../encoder/DoublePrecisionChimpEncoder.java | 55 +
.../tsfile/encoding/encoder/IntChimpEncoder.java | 188 +
.../tsfile/encoding/encoder/LongChimpEncoder.java | 199 +
.../encoder/SinglePrecisionChimpEncoder.java | 55 +
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 29 +-
.../tsfile/file/metadata/enums/TSEncoding.java | 5 +-
.../read/TsFileAlignedSeriesReaderIterator.java | 40 +-
.../iotdb/tsfile/read/TsFileDeviceIterator.java | 2 +-
.../iotdb/tsfile/read/TsFileRestorableReader.java | 10 +-
.../write/writer/TsFileIOWriterEndFileTest.java | 27 +-
.../tsfile/encoding/decoder/ChimpDecoderTest.java | 594 +
udf-api/pom.xml | 2 +-
zeppelin-interpreter/pom.xml | 2 +-
921 files changed, 47254 insertions(+), 16953 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%)
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%)
rename 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/exception/{StorageGroupNotExistsException.java => DatabaseNotExistsException.java} (80%)
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/{StorageGroupPartitionTable.java => DatabasePartitionTable.java} (92%)
copy server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/AlignedByDeviceTest.java => confignode/src/test/java/org/apache/iotdb/confignode/manager/ClusterSchemaManagerTest.java (55%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/request/DeserializedBatchIndexedConsensusRequest.java
copy docs/UserGuide/Monitor-Alert/{Apache-IoTDB-ConfigNode-Dashboard.json => Apache-IoTDB-Performance-Overview-Dashboard.json} (63%)
create mode 100644 docs/UserGuide/Operators-Functions/Machine-Learning.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Machine-Learning.md
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppJVMConfig.java
copy server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/AlignedByDeviceTest.java => integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteJVMConfig.java (67%)
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParameters.java
copy server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/AlignedByDeviceTest.java => integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParametersFactory.java (62%)
copy integration-test/src/main/java/org/apache/iotdb/itbase/env/{BaseNodeWrapper.java => JVMConfig.java} (52%)
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/database/IoTDBDatabaseRegionControlIT.java
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/{IoTDBStorageGroupIT.java => database/IoTDBDatabaseSetAndDeleteIT.java} (70%)
copy integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBPartitionDurableIT.java => IoTDBPartitionCreationIT.java} (52%)
copy server/src/main/java/org/apache/iotdb/db/metadata/query/info/ITimeSeriesSchemaInfo.java => integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBAggregationByLevel2IT.java (59%)
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
copy server/src/main/java/org/apache/iotdb/db/metadata/query/info/ITimeSeriesSchemaInfo.java => integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBAlignByDevice2IT.java (59%)
copy server/src/main/java/org/apache/iotdb/db/metadata/query/info/ITimeSeriesSchemaInfo.java => integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBOrderByWithAlignByDevice2IT.java (58%)
copy integration-test/src/test/java/org/apache/iotdb/db/it/{schema/IoTDBDeleteTimeseriesSchemaFileIT.java => aligned/IoTDBAlignedSeriesQuery4IT.java} (58%)
copy integration-test/src/test/java/org/apache/iotdb/db/it/{schema/IoTDBDeleteTimeseriesSchemaFileIT.java => builtinfunction/scalar/IoTDBDiffFunction2IT.java} (61%)
rename integration-test/src/test/java/org/apache/iotdb/db/it/{schema/IoTDBDeleteTimeseriesSchemaFileIT.java => builtinfunction/scalar/IoTDBDiffFunction3IT.java} (61%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/builtinfunction/scalar/IoTDBDiffFunctionIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupBySeriesIT.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 integration-test/src/test/java/org/apache/iotdb/libudf/it/dlearn/DLearnIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBSessionQueryIT.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/anomaly/UDTFOutlier.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dlearn/UDTFAR.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/service/metric/enums/Operation.java
copy node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/{BuiltinAggregationFunction.java => BuiltinFunction.java} (57%)
create mode 100644 server/src/assembly/resources/tools/tsfile/settle-tsfile.bat
copy integration-test/src/test/resources/iotdb-datanode.properties => server/src/assembly/resources/tools/tsfile/settle-tsfile.sh (53%)
copy server/src/main/codegen/{config.fmpp => dataModel/CompareType.tdd} (82%)
create mode 100644 server/src/main/codegen/templates/evEventWindow.ftl
create mode 100644 server/src/main/codegen/templates/evEventWindowManager.ftl
create mode 100644 server/src/main/codegen/templates/eventWindow.ftl
create mode 100644 server/src/main/codegen/templates/eventWindowManager.ftl
copy isession/src/main/java/org/apache/iotdb/isession/util/Version.java => server/src/main/java/org/apache/iotdb/db/audit/AuditLogOperation.java (78%)
copy isession/src/main/java/org/apache/iotdb/isession/util/Version.java => server/src/main/java/org/apache/iotdb/db/audit/AuditLogStorage.java (79%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/statemachine/IoTConsensusDataRegionStateMachine.java
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/task/subtask/{SubCompactionTaskSummary.java => FastCompactionTaskSummary.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/settle/SettleRequestHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionInfo.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionTable.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/localconfignode/LocalSchemaPartitionTable.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/LocalSchemaProcessor.java
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/metadata/{query/info/ITimeSeriesSchemaInfo.java => cache/dualkeycache/IDualKeyCacheComputation.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/metadata/{query/info/ITimeSeriesSchemaInfo.java => 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 isession/src/main/java/org/apache/iotdb/isession/util/Version.java => server/src/main/java/org/apache/iotdb/db/metadata/cache/dualkeycache/impl/DualKeyCachePolicy.java (88%)
copy server/src/main/java/org/apache/iotdb/db/metadata/{query/info/ITimeSeriesSchemaInfo.java => cache/dualkeycache/impl/ICacheEntry.java} (61%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{mtree/store/disk/memcontrol/IMemManager.java => cache/dualkeycache/impl/ICacheEntryGroup.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/metadata/{query/info/ITimeSeriesSchemaInfo.java => cache/dualkeycache/impl/ICacheEntryManager.java} (55%)
copy isession/src/main/java/org/apache/iotdb/isession/util/Version.java => server/src/main/java/org/apache/iotdb/db/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
copy 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
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/ReentrantReadOnlyCachedMTreeStore.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/StampedWriterPreferredLock.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/MTreeFlushTaskManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/MTreeReleaseTaskManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/CacheMemoryManager.java
copy integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.java => server/src/main/java/org/apache/iotdb/db/metadata/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
copy 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
copy server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{updater/MeasurementUpdater.java => counter/MeasurementCounter.java} (63%)
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 integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.java => server/src/main/java/org/apache/iotdb/db/metadata/rescon/ISchemaEngineStatistics.java (68%)
copy integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseNodeWrapper.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} (60%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/MemSchemaRegionStatistics.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{mtree/store/disk/memcontrol/MemManagerHolder.java => rescon/SchemaEngineStatisticsHolder.java} (56%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaStatisticsManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/IStorageGroupSchemaManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupSchemaManager.java
copy server/src/main/java/org/apache/iotdb/db/mpp/aggregation/{CountAccumulator.java => CountIfAccumulator.java} (54%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/DeviceGroupSchemaTree.java
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/reader/ISchemaReader.java => mpp/common/schematree/IMeasurementSchemaInfo.java} (77%)
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java => mpp/execution/operator/factory/OperatorFactory.java} (58%)
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java => mpp/execution/operator/factory/SourceOperatorFactory.java} (58%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/{VerticallyConcatOperator.java => HorizontallyConcatOperator.java} (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{LevelTimeSeriesCountOperator.java => CountGroupByLevelScanOperator.java} (63%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/DevicesCountOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/NodePathsSchemaScanOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/TimeSeriesCountOperator.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{DevicesSchemaScanOperator.java => source/DeviceSchemaSource.java} (57%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/ISchemaSource.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/NodeSchemaSource.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{PathsUsingTemplateScanOperator.java => source/PathsUsingTemplateSource.java} (63%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/SchemaSourceFactory.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{TimeSeriesSchemaScanOperator.java => source/TimeSeriesSchemaSource.java} (64%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{TimeWindow.java => EventWindow.java} (54%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventWindowManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventWindowParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/SeriesWindow.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/SeriesWindowManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/SeriesWindowParameter.java
copy isession/src/main/java/org/apache/iotdb/isession/util/Version.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/TimeWindowParameter.java (76%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowManagerFactory.java
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java => mpp/execution/operator/window/WindowParameter.java} (65%)
copy isession/src/main/java/org/apache/iotdb/isession/util/Version.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowType.java (73%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/{FragmentInstanceAbortedException.java => DriverTaskAbortedException.java} (82%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/IndexedBlockingReserveQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/multilevelqueue/DriverTaskHandle.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/multilevelqueue/MultilevelPriorityQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/multilevelqueue/Priority.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/{DriverTaskID.java => DriverTaskId.java} (56%)
rename server/src/main/java/org/apache/iotdb/db/mpp/metric/{DataExchangeMetricSet.java => DataExchangeCostMetricSet.java} (94%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/DataExchangeCountMetricSet.java
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 isession/src/main/java/org/apache/iotdb/isession/util/Version.java => server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ISchemaComputationWithAutoCreation.java (78%)
copy consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.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 isession/src/main/java/org/apache/iotdb/isession/util/Version.java => server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/multi/FunctionType.java (80%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/PipelineDriverFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/InternalBatchActivateTemplateNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/InternalCreateMultiTimeSeriesNode.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{VerticallyConcatNode.java => HorizontallyConcatNode.java} (77%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/AggregationType.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/GroupByVariationParameter.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
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/{WhereCondition.java => GroupByComponent.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/{WhereCondition.java => GroupBySeriesComponent.java} (63%)
copy server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java => mpp/plan/statement/component/GroupByVariationComponent.java} (66%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata/ShowStorageGroupStatement.java => internal/InternalBatchActivateTemplateStatement.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata/ShowStorageGroupStatement.java => internal/InternalCreateMultiTimeSeriesStatement.java} (52%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{SetStorageGroupStatement.java => DatabaseSchemaStatement.java} (69%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/DiffFunctionColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/unary/DiffFunctionTransformer.java
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/tools/settle/TsFileSettleByCompactionTool.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/MetadataManagerHelper.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/settle/SettleRequestHandlerTest.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/mtree/lock/StampedWriterPreferredLockTest.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/operator/{VerticallyConcatOperatorTest.java => HorizontallyConcatOperatorTest.java} (81%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaOperatorTestUtil.java
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/plan/PipelineBuilderTest.java
create mode 100644 session/src/test/java/org/apache/iotdb/session/TabletTest.java
create mode 100644 session/src/test/java/org/apache/iotdb/session/pool/SessionPoolTest.java
rename integration-test/src/test/resources/iotdb-datanode.properties => site/replace-picture-urls.sh (54%)
mode change 100644 => 100755
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/JarResp.java => tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/DoublePrecisionChimpDecoder.java (51%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/IntChimpDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/LongChimpDecoder.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/JarResp.java => tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/SinglePrecisionChimpDecoder.java (51%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/DoublePrecisionChimpEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/IntChimpEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/LongChimpEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SinglePrecisionChimpEncoder.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/ChimpDecoderTest.java