This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch ISessionDataSet
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1867b485a6 Delete ISessionDataSet.java
add fd52a2f378 [IOTDB-5269] Fix PathPatternTree.getAllDevicePatterns
(#8589)
add 9b4e8eda57 remove (#8597)
add 424528495c Turn down the max capacity of tsblock from scanOperator
(#8599)
add 0e1dd1b8a2 Refine the inner structure of ClusterSchemaFetcher (#8603)
add 82ceb3586f Delete more stale query code (#8600)
add e8104a499e [IOTDB-5277] SchemaRegion throws NPE when loading snapshot
(#8605)
add 30335b3a73 change docker images name from 1c1d to standalone,
including docs (#8596)
add 1921b6d66d [IOTDB-5264] NumpyTablet supports insert with None values
(#8576)
add daab49b61a [IOTDB-5260] Refactor ClientManager API and Exception
(#8561)
add f73b73fd42 [IOTDB-5284] Fix some code smells (#8612)
add 65fb480844 [IOTDB-5208]Fix file handles increase when TsFileResource
is degraded and compacted with fast performer (#8573)
add b1b17f971a change STARTUP_RETRY_INTERVAL_IN_MS from 30s to 3s (#8629)
add 8bb400d17a Fix Bug in NullColumn
add 8ad71667cd [IOTDB-5278] fix connection problem of dbeaver and supports
more functions (#8624)
add dd7291dbf2 Bump wheel from 0.36.2 to 0.38.1 in /client-py (#8617)
add db38945c16 [IOTDB-5297] Add maxRetryTimes for
IoTDBClusterNodeErrorStartUpIT to avoid infinite loop (#8628)
add 217e3d7747 [IOTDB-5106] Parse PathPattern to Deterministic Finite
Automate (#8607)
add 905a356c8f [IOTDB-5306] Change default port of ConfigNode and DataNode
(#8635)
add 14db9f8784 fix grafana-connector bug (#8636)
add 48bd8c9b68 [IOTDB-5290] Add retry failed tasks thread for sync and
trigger(#8610)
add 15c9231120 [IOTDB-5300] Added node status check in migrate Region sql
(#8641)
add 5a73bc30e9 [IOTDB-5282] Add SQL: show cluster parameter (#8643)
add 1af7fbe3c4 set isClosed to true after submitting close signal (#8623)
add 08f924c707 Add SHOW_CQ privilege (#8655)
add 6762bcb65c [IOTDB-5266] Refine the code of cross selector and fix the
bug when using FileTimeIndex (#8579)
add 0fedffd303 [IOTDB-5313] Fix python client didn't handle redirection
status code correctly (#8659)
add fc8ecd0769 fix some code smells (#8660)
add bed0552fcc fix some code smells (#8658)
add 1ea16d5f6d Recover the confignode ports of docker deployment (#8670)
add 660a79870d [IOTDB-5171] Add query metrics
add 7912781019 [IOTDB-4804] Cpp Client SDK bug-fix (#8555)
add d5b0b1127a Revert "[IOTDB-4804] Cpp Client SDK bug-fix (#8555)" (#8675)
add 82ffaa3c26 [IOTDB-4816]Show queries - implement LogicPlan &
DistributionPlan & Operator
add 6410ffad81 [IOTDB-4630] Implement observer pattern in LoadBalancing
framework (#8483)
add 8a482cae86 [IOTDB-4816]Show queries - add user doc
add bbada1c788 [IOTDB-5322] [IoTDB ML] Define the RPC interface (#8672)
add 3d85d27d21 modify doc of register UDF (#8681)
add bddfa56da9 Fix cpp SDK bug & enable cpp IT (#8680)
add 56a0b4510b Fix out of bound Segment access in SchemaFile (#8685)
add 225b0d2fc1 Optimize write redirection logic (#8687)
add 10ce4783ce [IOTDB-5311]Fix RunTimeException and NoSuchFile Exception
when selecting files causing compaction scheduled thread to get stuck
add 8c495e31da [IOTDB-5286]Fix target files should not be select to
participate in other compaction task (#8615)
add 072588d259 [IOTDB-5327] Move Apache IoTDB Dashboard and update doc
(#8692)
add 358be12ca7 Fix some iotdb-confignode code smells (#8647)
add 8eb7e24eb2 [IOTDB-5284] Fix some iotdb-confignode code smells (#8656)
add b6c71120d3 fix conflicts in test (#8694)
add d8f89bbec5 [IOTDB-5133] Add 0.13 Export-Schema document to website
config (#8695)
add 400e099def Add deadband doc to 0.13.x User-Guide (#8698)
add da559fb09b [IOTDB-5253] Fix chunkMetadata mem metric (#8661)
add 47987e244d Add deadband columns to User-Guide SQL examples (#8702)
add be9e023710 [IOTDB-5284] Fix some confignode code smells (#8648)
add 3b770954e4 [IOTDB-5329] Exception handler for AbstractTreeVisitor
(#8700)
add 954e682fa1 [IOTDB-5309] Wrong calculation for retained size of tsblock
calculate
add 1b7eab5974 [IOTDB-5316] fix bug that Session.setFetchSize is not used
in the following fetch requests
add 78e67aaa71 Make some code more efficient
add 8d180e45d1 [IOTDB-5160] [Metric] Fix the file count of datanode become
negative number
add e4cbca4479 [IOTDB-5285] TimePartition may be error when restarting
with different time partition configuration (#8646)
add 99ee8557a2 Add the details of normal level metrics in zh (#8703)
add 6de111b34b [IOTDB-5333] Fix a typo of max_tsblock_line_number in
iotdb-common.properties (#8705)
add bc887772cd [IOTDB-5245] Fix bug in last query
add 803ca764b2 Fix cluster_name definition conflict (#8713)
add a18cc5cbca IOTDB-5228:NPE if the file does not exist when create
TsFileSequenceReader instance (#8678)
add e42478c9b9 Fix typo in query metric (#8684)
add 6a58af8c8b [IOTDB-3063] Set up SchemaReader and apply them in show
devices and show timeseries (#8677)
add e1f905192d Rename SQL show cluster parameters to show variables (#8715)
add 38438f9d07 Fix testGetSlots IT bug (#8718)
add 402e269d65 [IOTDB-5326] Add cluster_name parameter (#8708)
add 82bd466c0c Bump reload4j from 1.2.22 to 1.2.24 (#8689)
add f2b9c0ebd1 [IOTDB-5285] Modifying system properties before the initial
startup causes the datanode to fail to start (#8717)
add 468d675475 [IOTDB-5346] Fix log error in MemtableFlushTask when
recovering (#8724)
add 415808dc2e Add cluster_name related judgement and logs (#8727)
add bd70ca269b fix the wal comment (#8673)
add d2085948df [IOTDB-5347] Implement iterating query for devices and
timeseries schema query (#8728)
add f38561724e [IOTDB-5351] Add StatisticsUpdaterTrigger as trigger
example and fix possible IT failures
add c65cead563 Make subprocesses' exit under control in IT cases (#8734)
add a1f259d517 Bump spring-boot-dependencies from 1.5.15.RELEASE to
1.5.22.RELEASE (#8690)
add f26ff29ff2 reconstruct compaction package (#8720)
add 7c9395de11 [IOTDB-5342][IOTDB-5359][IOTDB-5360] Some optimization in
AbstractTreeVisitor (#8721)
add fface4c3ca [IOTDB-5077] Support new command formats in SHOW REGIONS
(#8748)
add 11c489bc25 [IOTDB-4933] More detailed error message for udf/trigger
executor and fix typo in udf doc
add df78367ee6 [IOTDB-5308] Limit the output tsblock's size of each
operator[Part1]
add 0f944f7861 [IOTDB-5358]dn_data_dir failed to be effectively set when
executing load (#8749)
add 7e3bea1349 [IOTDB-5361] Refactor device and timeseries count based on
SchemaReader (#8755)
add 067519f297 fix some code smells (#8731)
add 72a94eb531 [IOTDB-5334] Optimize metric related code and log (#8739)
add 2f8abb245c [IOTDB-5284] Fix some code smells (#8730)
add 5a40a19ed4 [IOTDB-5284] Fix some iotdb-server code smells (#8754)
add 22bd622a57 [IOTDB-5284] Fix some code smells (#8751)
add 621e036983 [IOTDB-5284] Fix some iotdb-server code smells (#8743)
add a1c29277ac [IOTDB-5284] Fix some iotdb-server code smells (#8738)
add 1a29eb07c1 [IOTDB-5365] Init lastEnterReadyQueueTime of DriverTask
while creating it
add 24e5d2fe8d [IOTDB-4497] Improve NodeStatus definition (#8732)
add afc58a0ad3 [IOTDB-5364] Refactor Count TimeSeries Group By Level based
on SchemaReader (#8759)
add a2f39140f9 [IOTDB-5303] Refine IT: Make cluster properties mutable
easily (#8671)
add 854288ccd7 [IOTDB-5323] Extend File related Metrics (#8761)
add 6e98062c1f [IOTDB-4817] Support kill query in cluster
add 7bbac9ec98 [IOTDB-5373] Eliminate stale code in LocalConfigNode and
LocalSchemaProcessor to simplify interfaces of ISchemaRegion (#8767)
add 87ed1f975b [IOTDB-5312] Consolidate ClientManagers in Datanodes for
unified management (#8654)
add 2b4732ccd9 [IOTDB-5379] Fix the unit of Prometheus timer metric values
(#8773)
add 4c52365559 [IOTDB-5378] Implement Iterating Query for MTree Node Query
(#8771)
add 228607c5f0 Revert "[IOTDB-5209] Limit the read rate of compaction
execution (#8461)" (#8777)
add a06624782a [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 (#8779)
add 9b82577b26 fix test
add 3a03e51769 [To rel/1.0][IOTDB-5127] add some deprecated methods on
ISession ISessionPool and rename package name (#8578)
add 1a19d88957 [To rel/1.0][IOTDB-5127] update Session and SessionPool
return (#8595)
add 48002969a5 update javadoc (#8789)
add d57fdb023b Merge branch 'master' of https://github.com/apache/iotdb
into ISessionDataSet
add 120fe3effa Merge branch 'ISessionDataSet' of
https://github.com/apache/iotdb into ISessionDataSet
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp.yml | 18 +-
.gitignore | 2 +
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 29 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 17 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 14 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 2 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 10 +-
client-cpp/pom.xml | 71 +-
client-cpp/src/main/Session.cpp | 5 +-
client-cpp/src/main/Session.h | 127 +-
client-cpp/src/test/CMakeLists.txt | 1 +
client-cpp/src/test/cpp/sessionIT.cpp | 94 +-
client-py/README.md | 37 +-
client-py/SessionExample.py | 26 +
client-py/iotdb/Session.py | 5 +-
client-py/iotdb/dbapi/tests/test_connection.py | 1 +
client-py/iotdb/dbapi/tests/test_cursor.py | 1 +
client-py/iotdb/sqlalchemy/tests/test_dialect.py | 3 +-
client-py/iotdb/utils/BitMap.py | 9 +
client-py/iotdb/utils/NumpyTablet.py | 33 +-
client-py/requirements_dev.txt | 2 +-
client-py/tests/test_aligned_timeseries.py | 1 +
client-py/tests/test_delete_data.py | 1 +
client-py/tests/test_numpy_tablet.py | 47 +
client-py/tests/test_one_device.py | 1 +
client-py/tests/test_session.py | 31 +-
.../resources/conf/iotdb-confignode.properties | 19 +-
.../assembly/resources/sbin/start-confignode.bat | 4 +-
.../confignode/client/DataNodeRequestType.java | 5 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 6 +-
.../client/async/AsyncDataNodeClientPool.java | 11 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 6 +-
.../client/async/handlers/AsyncClientHandler.java | 1 +
.../handlers/rpc/AbstractAsyncRPCHandler.java | 2 +-
.../client/sync/SyncConfigNodeClientPool.java | 11 +-
.../client/sync/SyncDataNodeClientPool.java | 10 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 39 +-
.../confignode/conf/ConfigNodeDescriptor.java | 19 +
.../confignode/conf/SystemPropertiesUtils.java | 14 +-
.../consensus/response/DataNodeRegisterResp.java | 7 -
.../consensus/response/DataNodeToStatusResp.java | 4 +-
.../consensus/response/StorageGroupSchemaResp.java | 4 +-
.../consensus/response/TemplateSetInfoResp.java | 4 +-
.../statemachine/ConfigNodeRegionStateMachine.java | 24 +-
.../confignode/exception/ConfigNodeException.java | 2 +-
.../confignode/manager/ClusterSchemaManager.java | 46 +-
.../iotdb/confignode/manager/ConfigManager.java | 141 +-
.../iotdb/confignode/manager/ConsensusManager.java | 12 +-
.../apache/iotdb/confignode/manager/IManager.java | 26 +-
.../iotdb/confignode/manager/ProcedureManager.java | 50 +-
.../confignode/manager/RetryFailedTasksThread.java | 195 +
.../iotdb/confignode/manager/SyncManager.java | 22 +-
.../confignode/manager/cq/CQScheduleTask.java | 26 +-
.../iotdb/confignode/manager/load/LoadManager.java | 35 +-
.../region/CopySetRegionGroupAllocator.java | 4 +-
.../router/leader/MinCostFlowLeaderBalancer.java | 26 +-
.../manager/node/ClusterNodeStartUtils.java | 25 +-
.../iotdb/confignode/manager/node/NodeManager.java | 112 +-
.../manager/node/heartbeat/BaseNodeCache.java | 6 +-
.../node/heartbeat/ConfigNodeHeartbeatCache.java | 2 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 2 +-
.../iotdb/confignode/manager/observer/IEvent.java | 21 +
.../manager/observer/NodeStatisticsEvent.java | 39 +
.../manager/partition/heartbeat/RegionCache.java | 2 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 6 +-
.../iotdb/confignode/persistence/UDFInfo.java | 2 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 6 +-
.../confignode/persistence/node/NodeInfo.java | 16 +-
.../persistence/partition/PartitionInfo.java | 8 +-
.../partition/maintainer/RegionMaintainTask.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 52 +-
.../persistence/schema/TemplateTable.java | 6 +-
.../confignode/procedure/InternalProcedure.java | 2 +-
.../confignode/procedure/StoppableThread.java | 2 +-
.../procedure/env/DataNodeRemoveHandler.java | 2 +-
.../procedure/impl/cq/CreateCQProcedure.java | 4 +-
.../impl/node/AddConfigNodeProcedure.java | 5 +-
.../impl/node/RemoveConfigNodeProcedure.java | 4 +-
.../impl/node/RemoveDataNodeProcedure.java | 2 +-
.../impl/schema/DeleteStorageGroupProcedure.java | 5 +-
.../impl/sync/AbstractOperatePipeProcedure.java | 4 +-
.../procedure/impl/sync/CreatePipeProcedure.java | 3 +-
.../OperatePipeProcedureRollbackProcessor.java | 122 -
.../procedure/impl/sync/StartPipeProcedure.java | 3 +-
.../procedure/impl/sync/StopPipeProcedure.java | 3 +-
.../impl/trigger/CreateTriggerProcedure.java | 4 +-
.../impl/trigger/DropTriggerProcedure.java | 4 +-
.../scheduler/SimpleProcedureScheduler.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 52 +-
.../service/thrift/ConfigNodeRPCService.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 57 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 56 +-
.../load/balancer/router/RegionRouteMapTest.java | 8 +-
.../router/priority/GreedyPriorityTest.java | 8 +-
.../priority/LeaderPriorityBalancerTest.java | 16 +-
.../confignode/persistence/PartitionInfoTest.java | 8 +-
.../impl/CreateRegionGroupsProcedureTest.java | 16 +-
.../impl/node/AddConfigNodeProcedureTest.java | 2 +-
.../impl/node/RemoveConfigNodeProcedureTest.java | 2 +-
.../confignode1conf/iotdb-confignode.properties | 6 +-
.../confignode2conf/iotdb-confignode.properties | 6 +-
.../confignode3conf/iotdb-confignode.properties | 6 +-
.../org/apache/iotdb/consensus/common/Peer.java | 4 +-
.../common/response/ConsensusResponse.java | 2 +-
.../iotdb/consensus/config/ConsensusConfig.java | 9 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 40 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 219 +-
.../consensus/iot/IoTConsensusServerImpl.java | 17 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 73 +-
.../iot/client/IoTConsensusClientPool.java | 24 +-
.../iot/client/SyncIoTConsensusServiceClient.java | 72 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 3 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 2 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 36 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 58 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 8 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 10 +-
docker/ReadMe.md | 4 +-
docker/src/main/DockerCompose/do-docker-build.sh | 18 +-
.../src/main/DockerCompose/docker-compose-1c1d.yml | 41 -
.../DockerCompose/docker-compose-standalone.yml | 41 +
...file-1.0.0-1c1d => Dockerfile-1.0.0-standalone} | 0
.../UserGuide/API/Programming-Python-Native-API.md | 39 +-
.../Administration-Management/Administration.md | 65 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 168 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 94 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 8 +-
.../Maintenance-Tools/Maintenance-Command.md | 97 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 2495 +++++++++++
.../Apache-IoTDB-DataNode-Dashboard.json | 4617 ++++++++++++++++++++
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 56 +-
docs/UserGuide/Operate-Metadata/Template.md | 16 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 105 +-
docs/UserGuide/Operators-Functions/Overview.md | 2 +-
.../Operators-Functions/User-Defined-Function.md | 41 +-
docs/UserGuide/QuickStart/ClusterQuickStart.md | 92 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 6 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 16 +-
.../Reference/ConfigNode-Config-Manual.md | 24 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 28 +-
docs/UserGuide/Reference/Status-Codes.md | 2 +
.../UserGuide/API/Programming-Python-Native-API.md | 39 +-
.../Administration-Management/Administration.md | 65 +-
docs/zh/UserGuide/Cluster/Cluster-Concept.md | 24 +-
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 167 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 80 +-
.../Edge-Cloud-Collaboration/Sync-Tool.md | 8 +-
.../Maintenance-Tools/Maintenance-Command.md | 98 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 79 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 16 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 105 +-
docs/zh/UserGuide/Operators-Functions/Overview.md | 2 +-
.../Operators-Functions/User-Defined-Function.md | 36 +-
docs/zh/UserGuide/QuickStart/ClusterQuickStart.md | 102 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 6 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 16 +-
.../Reference/ConfigNode-Config-Manual.md | 26 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 28 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 2 +
.../iotdb/AlignedTimeseriesSessionExample.java | 2 +-
.../org/apache/iotdb/DataMigrationExample.java | 8 +-
.../iotdb/HybridTimeseriesSessionExample.java | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 6 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 6 +-
.../iotdb/SyntaxConventionRelatedExample.java | 2 +-
.../org/apache/iotdb/trigger/SimpleTrigger.java | 38 -
.../iotdb/trigger/StatisticsUpdaterTrigger.java | 160 +
.../apache/iotdb/trigger/old/AlertingExample.java | 108 -
.../java/org/apache/iotdb/flink/IoTDBSource.java | 2 +-
grafana-connector/pom.xml | 2 +-
.../web/grafana/interceptor/LoginInterceptor.java | 3 +
.../Apache IoTDB ConfigNode Dashboard.json | 2495 -----------
.../Apache IoTDB DataNode Dashboard.json | 4617 --------------------
integration-test/checkstyle.xml | 2 +-
integration-test/import-control.xml | 1 +
integration-test/pom.xml | 4 +-
.../trigger/example/TriggerFireTimesCounter.java | 26 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 656 ---
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 385 --
.../java/org/apache/iotdb/it/env/Cluster1Env.java | 45 -
.../org/apache/iotdb/it/env/ConfigFactory.java | 45 -
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 136 -
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 164 -
.../java/org/apache/iotdb/it/env/EnvFactory.java | 3 +
.../java/org/apache/iotdb/it/env/EnvUtils.java | 90 -
.../java/org/apache/iotdb/it/env/MppConfig.java | 398 --
.../apache/iotdb/it/env/RemoteServerConfig.java | 23 -
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 266 --
.../java/org/apache/iotdb/it/env/SimpleEnv.java | 45 -
.../apache/iotdb/it/env/cluster/AbstractEnv.java | 692 +++
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 442 ++
.../apache/iotdb/it/env/cluster/Cluster1Env.java | 35 +
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 158 +
.../iotdb/it/env/cluster/DataNodeWrapper.java | 198 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 125 +
.../apache/iotdb/it/env/cluster/MppBaseConfig.java | 120 +
.../iotdb/it/env/cluster/MppClusterConfig.java | 68 +
.../iotdb/it/env/cluster/MppCommonConfig.java | 334 ++
.../iotdb/it/env/cluster/MppConfigNodeConfig.java | 50 +
.../iotdb/it/env/cluster/MppDataNodeConfig.java | 50 +
.../it/env/cluster/MppSharedCommonConfig.java | 346 ++
.../org/apache/iotdb/it/env/cluster/SimpleEnv.java | 32 +
.../iotdb/it/env/remote/RemoteClusterConfig.java | 56 +
.../iotdb/it/env/remote/RemoteCommonConfig.java | 249 ++
.../it/env/remote/RemoteConfigNodeConfig.java | 23 +
.../iotdb/it/env/remote/RemoteDataNodeConfig.java | 23 +
.../iotdb/it/env/remote/RemoteServerEnv.java | 257 ++
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 5 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 419 --
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 59 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 4 -
.../org/apache/iotdb/itbase/env/ClusterConfig.java | 60 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 113 +
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 22 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 22 +
.../apache/iotdb/cli/it/StartClientScriptIT.java | 4 +-
.../confignode/it/IoTDBClusterAuthorityIT.java | 2 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 35 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 9 +-
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 10 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 123 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 97 +-
.../it/cluster/IoTDBClusterRestartIT.java | 60 +-
.../load/IoTDBClusterRegionLeaderBalancingIT.java | 77 +-
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 57 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 61 +-
.../IoTDBCustomRegionGroupExtensionIT.java | 72 +-
.../it/partition/IoTDBPartitionDurableIT.java | 65 +-
.../it/partition/IoTDBPartitionGetterIT.java | 90 +-
.../partition/IoTDBPartitionInheritPolicyIT.java | 52 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 64 +-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 82 +-
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBDatetimeFormatIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 19 +-
.../org/apache/iotdb/db/it/IoTDBEncodingIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBExecuteBatchIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBFilterBetweenIT.java | 4 +-
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 30 +-
.../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 7 +-
.../apache/iotdb/db/it/IoTDBFlushQueryMergeIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBInsertNaNIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBInsertNullIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 4 +-
.../iotdb/db/it/IoTDBInsertWithoutTimeIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 47 +-
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 34 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 8 +-
.../db/it/IoTDBQueryWithRecreatedTimeseriesIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBQuotedPathIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBRecoverIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBRecoverUnclosedIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 4 +-
.../it/IoTDBSameMeasurementsDifferentTypesIT.java | 30 +-
.../java/org/apache/iotdb/db/it/IoTDBSettleIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 4 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 4 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBTimeZoneIT.java | 4 +-
.../java/org/apache/iotdb/db/it/IoTDBTtlIT.java | 4 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 4 +-
.../it/aggregation/IoTDBAggregationDeleteIT.java | 10 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 6 +-
.../aggregation/IoTDBAggregationLargeDataIT.java | 9 +-
.../it/aggregation/IoTDBAggregationOptimizeIT.java | 4 +-
.../aggregation/IoTDBAggregationScanOrderIT.java | 24 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 4 +-
.../db/it/aggregation/IoTDBTagAggregationIT.java | 4 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 4 +-
.../IoTDBOrderByWithAlignByDeviceIT.java | 4 +-
.../aligned/IoTDBAggregationWithDeletion2IT.java | 31 +-
.../it/aligned/IoTDBAggregationWithDeletionIT.java | 28 +-
.../db/it/aligned/IoTDBAlignedDataDeletionIT.java | 20 +-
.../db/it/aligned/IoTDBAlignedLastQuery2IT.java | 31 +-
.../db/it/aligned/IoTDBAlignedLastQuery3IT.java | 31 +-
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 29 +-
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 31 +-
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 30 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 28 +-
.../IoTDBAlignedSeriesQueryWithDeletionIT.java | 29 +-
.../IoTDBCountMultiTimesWithDeletionIT.java | 29 +-
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 30 +-
...GroupByQueryWithValueFilterWithDeletion2IT.java | 30 +-
...BGroupByQueryWithValueFilterWithDeletionIT.java | 29 +-
...upByQueryWithoutValueFilterWithDeletion2IT.java | 31 +-
...oupByQueryWithoutValueFilterWithDeletionIT.java | 31 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 18 +-
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 18 +-
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 18 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 10 +-
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 27 +-
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 24 +-
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 30 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 29 +-
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 30 +-
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 29 +-
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 27 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 24 +-
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 4 +-
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 92 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 54 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 354 --
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 11 +-
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 4 +-
.../iotdb/db/it/groupby/IoTDBGroupByUnseqIT.java | 28 +-
.../apache/iotdb/db/it/groupby/IoTDBHavingIT.java | 11 +-
.../iotdb/db/it/groupby/IoTDBLeftORightCIT.java | 4 +-
.../iotdb/db/it/last/IoTDBLastWithTTLIT.java | 4 +-
.../apache/iotdb/db/it/mqtt/IoTDBMQTTSinkIT.java | 12 +-
.../org/apache/iotdb/db/it/query/IoTDBAliasIT.java | 4 +-
.../iotdb/db/it/query/IoTDBArithmeticIT.java | 4 +-
.../iotdb/db/it/query/IoTDBFuzzyQueryIT.java | 4 +-
.../org/apache/iotdb/db/it/query/IoTDBInIT.java | 4 +-
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 11 +-
.../iotdb/db/it/query/IoTDBNullValueFillIT.java | 4 +-
.../iotdb/db/it/query/IoTDBPaginationIT.java | 11 +-
.../apache/iotdb/db/it/query/IoTDBQueryDemoIT.java | 4 +-
.../query/IoTDBQueryWithComplexValueFilterIT.java | 4 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 4 +-
.../it/query/IoTDBSelectCompareExpressionIT.java | 4 +-
.../iotdb/db/it/query/IoTDBSelectSchemaIT.java | 4 +-
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 4 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 4 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 4 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 4 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 4 +-
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 12 +-
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 4 +-
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 11 +-
.../schema/IoTDBDeleteTimeseriesSchemaFileIT.java | 8 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 40 +-
.../it/schema/IoTDBMetadataFetchSchemaFileIT.java | 8 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 4 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 4 +-
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 4 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 4 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 22 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto3IT.java | 18 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 13 +-
.../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 4 +-
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 4 +-
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 4 +-
.../db/it/trigger/IoTDBTriggerManagementIT.java | 12 +-
.../org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java | 14 +-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 4 +-
.../db/it/udf/IoTDBUDFOtherWindowQueryIT.java | 33 +-
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 33 +-
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 24 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 4 +-
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 4 +-
.../iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java | 14 +-
.../iotdb/db/it/watermark/IoTDBWatermarkIT.java | 34 +-
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 4 +-
.../db/it/withoutNull/IoTDBWithoutAnyNullIT.java | 4 +-
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 9 +-
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 4 +-
.../apache/iotdb/libudf/it/anomaly/AnomalyIT.java | 10 +-
.../apache/iotdb/libudf/it/dmatch/DMatchIT.java | 10 +-
.../iotdb/libudf/it/dprofile/DProfileIT.java | 10 +-
.../iotdb/libudf/it/dquality/DQualityIT.java | 10 +-
.../apache/iotdb/libudf/it/drepair/DRepairIT.java | 10 +-
.../iotdb/libudf/it/frequency/FrequencyIT.java | 10 +-
.../apache/iotdb/libudf/it/series/SeriesIT.java | 10 +-
.../apache/iotdb/libudf/it/string/StringIT.java | 10 +-
.../iotdb/session/it/IoTDBConnectionInfoIT.java | 4 +-
.../session/it/IoTDBSessionAlignedInsertIT.java | 29 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 12 +-
.../it/IoTDBSessionDisableMemControlIT.java | 19 +-
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 8 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 14 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 4 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 40 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 22 +-
.../org/apache/iotdb/session/it/SessionIT.java | 8 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 17 +-
.../org/apache/iotdb/tools/ExportCsvTestIT.java | 4 +-
.../org/apache/iotdb/tools/ExportTsFileTestIT.java | 4 +-
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 4 +-
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 1397 -> 1519 bytes
.../iotdb/db/integration/IoTDBCompactionIT.java | 2 +-
.../integration/IoTDBCompactionWithIDTableIT.java | 2 +-
.../integration/IoTDBSizeTieredCompactionIT.java | 4 +-
.../session/IoTDBSessionAlignedABDeviceIT.java | 10 +-
.../session/IoTDBSessionAlignedAggregationIT.java | 14 +-
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 8 +-
.../iotdb/session/IoTDBSessionIteratorIT.java | 28 +-
.../java/org/apache/iotdb/isession/ISession.java | 15 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 315 --
.../isession/pool/ISessionDataSetWrapper.java | 56 +
.../apache/iotdb/isession/pool/ISessionPool.java | 15 +-
.../iotdb/isession/pool/SessionDataSetWrapper.java | 110 -
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 166 +-
.../dropwizard/DropwizardMetricNameTool.java | 11 +
.../dropwizard/reporter/DropwizardJmxReporter.java | 17 +-
.../type/DropwizardHistogramSnapshot.java | 14 +-
.../iotdb/metrics/AbstractMetricManager.java | 73 +-
.../iotdb/metrics/AbstractMetricService.java | 98 +-
.../apache/iotdb/metrics/CompositeReporter.java | 14 +-
.../iotdb/metrics/DoNothingMetricService.java | 4 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 95 +-
.../metrics/config/MetricConfigDescriptor.java | 12 +-
.../metrics/impl/DoNothingHistogramSnapshot.java | 12 +-
.../iotdb/metrics/metricsets/IMetricSet.java | 6 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 4 +-
.../iotdb/metrics/metricsets/jvm/JvmMetrics.java | 2 +-
.../iotdb/metrics/metricsets/jvm/JvmUtils.java | 8 +-
.../metrics/metricsets/logback/LogbackMetrics.java | 2 +-
.../metricsets/logback/MetricsTurboFilter.java | 12 +-
.../apache/iotdb/metrics/reporter/JmxReporter.java | 2 +-
.../apache/iotdb/metrics/reporter/Reporter.java | 6 +-
.../reporter/iotdb/InternalIoTDBReporter.java | 67 -
.../iotdb/IoTDBInternalMemoryReporter.java | 57 +
.../reporter/iotdb/IoTDBInternalReporter.java | 67 +
.../metrics/reporter/iotdb/IoTDBReporter.java | 12 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 180 +
.../iotdb/MemoryInternalIoTDBReporter.java | 57 -
.../reporter/iotdb/SessionIoTDBReporter.java | 175 -
.../reporter/prometheus/PrometheusReporter.java | 14 +-
.../org/apache/iotdb/metrics/type/AutoGauge.java | 2 +-
.../org/apache/iotdb/metrics/type/Counter.java | 6 +-
.../java/org/apache/iotdb/metrics/type/Gauge.java | 8 +-
.../org/apache/iotdb/metrics/type/Histogram.java | 6 +-
.../iotdb/metrics/type/HistogramSnapshot.java | 20 +-
.../java/org/apache/iotdb/metrics/type/Rate.java | 14 +-
.../java/org/apache/iotdb/metrics/type/Timer.java | 12 +-
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 16 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 14 +-
.../apache/iotdb/metrics/utils/MetricLevel.java | 4 +-
.../org/apache/iotdb/metrics/utils/SystemType.java | 45 +
.../iotdb/metrics/config/MetricConfigTest.java | 4 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 8 +-
.../type/MicrometerHistogramSnapshot.java | 14 +-
.../metrics/micrometer/type/MicrometerTimer.java | 2 +-
.../type/MicrometerTimerHistogramSnapshot.java | 87 +
mlnode/.gitignore | 1 +
mlnode/pom.xml | 160 +
node-commons/pom.xml | 4 +
.../resources/conf/iotdb-common.properties | 18 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 12 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 2 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 3 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 2 +-
.../commons/client/AsyncBaseClientFactory.java | 57 -
.../iotdb/commons/client/BaseClientFactory.java | 41 -
.../commons/client/ClientFactoryProperty.java | 95 -
.../apache/iotdb/commons/client/ClientManager.java | 81 +-
.../iotdb/commons/client/ClientPoolFactory.java | 145 +-
.../iotdb/commons/client/ClientPoolProperty.java | 84 -
.../iotdb/commons/client/IClientManager.java | 24 +-
.../iotdb/commons/client/IClientPoolFactory.java | 7 +-
.../apache/iotdb/commons/client/ThriftClient.java | 89 +
.../AsyncConfigNodeHeartbeatServiceClient.java | 73 +-
.../async/AsyncConfigNodeIServiceClient.java | 75 +-
.../async/AsyncDataNodeHeartbeatServiceClient.java | 73 +-
.../async/AsyncDataNodeInternalServiceClient.java | 73 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 77 +-
.../BorrowNullClientManagerException.java | 29 +
.../client/exception/ClientManagerException.java | 31 +
.../CreateTAsyncClientManagerException.java | 27 +
.../client/factory/AsyncThriftClientFactory.java | 57 +
.../commons/client/factory/BaseClientFactory.java | 40 +
.../client/factory/ThriftClientFactory.java | 34 +
.../client/property/ClientPoolProperty.java | 90 +
.../client/property/ThriftClientProperty.java | 96 +
.../client/sync/SyncConfigNodeIServiceClient.java | 51 +-
.../sync/SyncDataNodeInternalServiceClient.java | 67 +-
.../SyncDataNodeMPPDataExchangeServiceClient.java | 57 +-
.../commons/client/sync/SyncThriftClient.java | 31 -
.../sync/SyncThriftClientWithErrorHandler.java | 62 +-
.../iotdb/commons/concurrent/ThreadName.java | 8 +-
.../threadpool/WrappedThreadPoolExecutor.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 45 +-
.../iotdb/commons/conf/CommonDescriptor.java | 67 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 26 +-
.../iotdb/commons/partition/DataPartition.java | 2 +-
.../apache/iotdb/commons/partition/Partition.java | 2 +-
.../partition/executor/hash/BKDRHashExecutor.java | 4 +-
.../partition/executor/hash/JSHashExecutor.java | 4 +-
.../apache/iotdb/commons/path/PathPatternTree.java | 11 +-
.../apache/iotdb/commons/path/fa/FAFactory.java | 55 +
.../iotdb/commons/path/fa/IFATransition.java | 4 +-
.../apache/iotdb/commons/path/fa/IPatternFA.java | 58 +
.../apache/iotdb/commons/path/fa/SimpleNFA.java | 522 ---
.../apache/iotdb/commons/path/fa/dfa/DFAState.java | 66 +
.../iotdb/commons/path/fa/dfa/PatternDFA.java | 152 +
.../iotdb/commons/path/fa/dfa/graph/Closure.java | 66 +
.../iotdb/commons/path/fa/dfa/graph/DFAGraph.java | 173 +
.../iotdb/commons/path/fa/dfa/graph/NFAGraph.java | 126 +
.../fa/dfa/transition/AbstractDFATransition.java | 54 +
.../fa/dfa/transition/DFAPreciseTransition.java | 44 +
.../fa/dfa/transition/DFAWildcardTransition.java | 56 +
.../iotdb/commons/path/fa/nfa/SimpleNFA.java | 530 +++
.../commons/schema/tree/AbstractTreeVisitor.java | 225 +-
.../tree/AbstractTreeVisitorWithLimitOffset.java | 101 -
.../security/encrypt/MessageDigestEncrypt.java | 4 +-
.../service/AbstractThriftServiceThread.java | 10 +-
.../iotdb/commons/service/ThriftServiceThread.java | 2 +-
.../commons/service/metric/MetricService.java | 52 +-
.../commons/service/metric/MetricServiceMBean.java | 1 +
.../iotdb/commons/service/metric/enums/Metric.java | 14 +-
.../commons/service/metric/enums/Operation.java | 1 +
.../iotdb/commons/service/metric/enums/Tag.java | 6 +-
.../iotdb/commons/sync/metadata/SyncMetadata.java | 2 +
.../apache/iotdb/commons/sync/pipe/PipeInfo.java | 4 +-
.../iotdb/commons/sync/pipesink/IoTDBPipeSink.java | 2 +-
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 2 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 1 +
.../apache/iotdb/commons/udf/utils/KDTreeUtil.java | 10 +-
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 2 +-
.../commons/utils/BasicStructureSerDeUtil.java | 4 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 4 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 13 +-
.../iotdb/commons/client/ClientManagerTest.java | 107 +-
.../iotdb/commons/path/PathPatternTreeTest.java | 5 +-
.../apache/iotdb/commons/path/PatternDFATest.java | 153 +
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 8 +-
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 16 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 2 +-
pom.xml | 6 +-
.../java/org/apache/iotdb/RewriteTsFileTool.java | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 186 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 127 +-
.../utils/ShowTimeSeriesResultUtils.java | 41 +-
.../resources/conf/iotdb-datanode.properties | 23 +-
.../src/assembly/resources/sbin/start-datanode.bat | 8 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 4 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 24 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 117 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 4 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 127 +-
.../iotdb/db/client/DataNodeInternalClient.java | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 91 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 56 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 443 +-
.../db/consensus/DataRegionConsensusImpl.java | 26 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 28 +-
.../org/apache/iotdb/db/constant/SqlConstant.java | 66 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 8 +-
.../iotdb/db/engine/TsFileMetricManager.java | 24 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 4 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 52 +-
.../iotdb/db/engine/cache/ChunkCacheMetrics.java | 67 -
.../db/engine/cache/TimeSeriesMetadataCache.java | 157 +-
.../cache/TimeSeriesMetadataCacheMetrics.java | 77 -
.../compaction/CompactionExceptionHandler.java | 246 --
.../compaction/CompactionRecoverManager.java | 119 -
.../db/engine/compaction/CompactionScheduler.java | 170 -
.../engine/compaction/CompactionTaskManager.java | 395 --
.../db/engine/compaction/CompactionUtils.java | 307 --
.../db/engine/compaction/CompactionWorker.java | 121 -
.../DefaultCompactionTaskComparatorImpl.java | 121 -
.../comparator/ICompactionTaskComparator.java | 35 -
.../compaction/constant/CompactionPriority.java | 26 -
.../compaction/constant/CompactionTaskStatus.java | 26 -
.../engine/compaction/constant/CompactionType.java | 25 -
.../constant/CrossCompactionPerformer.java | 48 -
.../constant/CrossCompactionSelector.java | 47 -
.../constant/InnerSeqCompactionPerformer.java | 48 -
.../constant/InnerSequenceCompactionSelector.java | 48 -
.../constant/InnerUnseqCompactionPerformer.java | 49 -
.../InnerUnsequenceCompactionSelector.java | 48 -
.../compaction/constant/ProcessChunkType.java | 25 -
.../cross/AbstractCrossSpaceEstimator.java | 39 -
.../compaction/cross/CrossSpaceCompactionTask.java | 381 --
.../compaction/cross/ICrossSpaceSelector.java | 30 -
.../rewrite/CrossSpaceCompactionResource.java | 74 -
.../RewriteCrossSpaceCompactionSelector.java | 422 --
.../ICrossSpaceCompactionFileSelector.java | 33 -
.../task/FastCompactionPerformerSubTask.java | 146 -
.../rewrite/task/ReadPointPerformerSubTask.java | 96 -
.../cross/utils/AbstractCompactionEstimator.java | 63 -
.../utils/AlignedSeriesCompactionExecutor.java | 347 --
.../cross/utils/ChunkMetadataElement.java | 56 -
.../engine/compaction/cross/utils/FileElement.java | 31 -
.../cross/utils/IFileQueryMemMeasurement.java | 36 -
.../cross/utils/InplaceCompactionEstimator.java | 172 -
.../utils/NonAlignedSeriesCompactionExecutor.java | 210 -
.../engine/compaction/cross/utils/PageElement.java | 101 -
.../compaction/cross/utils/PointElement.java | 50 -
.../utils/ReadPointCrossCompactionEstimator.java | 196 -
.../cross/utils/SeriesCompactionExecutor.java | 591 ---
.../exception/CompactionExceptionHandler.java | 247 ++
.../execute/performer/ICompactionPerformer.java | 48 +
.../performer/ICrossCompactionPerformer.java | 28 +
.../execute/performer/ISeqCompactionPerformer.java | 28 +
.../performer/IUnseqCompactionPerformer.java | 28 +
.../constant/CrossCompactionPerformer.java | 48 +
.../constant/InnerSeqCompactionPerformer.java | 48 +
.../constant/InnerUnseqCompactionPerformer.java | 49 +
.../performer/impl/FastCompactionPerformer.java | 308 ++
.../impl/ReadChunkCompactionPerformer.java | 191 +
.../impl/ReadPointCompactionPerformer.java | 334 ++
.../execute/recover/CompactionRecoverManager.java | 118 +
.../execute/recover/CompactionRecoverTask.java | 504 +++
.../execute/task/AbstractCompactionTask.java | 151 +
.../execute/task/CompactionTaskSummary.java | 75 +
.../execute/task/CrossSpaceCompactionTask.java | 381 ++
.../execute/task/InnerSpaceCompactionTask.java | 454 ++
.../subtask/FastCompactionPerformerSubTask.java | 145 +
.../task/subtask/ReadPointPerformerSubTask.java | 96 +
.../task/subtask/SubCompactionTaskSummary.java | 40 +
.../compaction/execute/utils/CompactionUtils.java | 295 ++
.../execute/utils/MultiTsFileDeviceIterator.java | 528 +++
.../fast/AlignedSeriesCompactionExecutor.java | 342 ++
.../fast/NonAlignedSeriesCompactionExecutor.java | 211 +
.../executor/fast/SeriesCompactionExecutor.java | 590 +++
.../fast/element/ChunkMetadataElement.java | 56 +
.../utils/executor/fast/element/FileElement.java | 31 +
.../utils/executor/fast/element/PageElement.java | 101 +
.../utils/executor/fast/element/PointElement.java | 50 +
.../readchunk/AlignedSeriesCompactionExecutor.java | 201 +
.../readchunk/SingleSeriesCompactionExecutor.java | 353 ++
.../execute/utils/log/CompactionLogAnalyzer.java | 162 +
.../execute/utils/log/CompactionLogger.java | 83 +
.../execute/utils/log/TsFileIdentifier.java | 234 +
.../execute/utils/reader/IDataBlockReader.java | 31 +
.../execute/utils/reader/PointPriorityReader.java | 191 +
.../utils/reader/SeriesDataBlockReader.java | 156 +
.../utils/writer/AbstractCompactionWriter.java | 311 ++
.../writer/AbstractCrossCompactionWriter.java | 244 ++
.../writer/AbstractInnerCompactionWriter.java | 113 +
.../utils/writer/FastCrossCompactionWriter.java | 215 +
.../utils/writer/FastInnerCompactionWriter.java | 212 +
.../writer/ReadPointCrossCompactionWriter.java | 101 +
.../writer/ReadPointInnerCompactionWriter.java | 79 +
.../inner/AbstractInnerSpaceEstimator.java | 39 -
.../compaction/inner/IInnerSeqSpaceSelector.java | 28 -
.../compaction/inner/IInnerUnseqSpaceSelector.java | 28 -
.../compaction/inner/InnerSpaceCompactionTask.java | 452 --
.../sizetiered/SizeTieredCompactionSelector.java | 215 -
.../utils/AlignedSeriesCompactionExecutor.java | 200 -
.../inner/utils/MultiTsFileDeviceIterator.java | 527 ---
.../utils/SingleSeriesCompactionExecutor.java | 351 --
.../compaction/log/CompactionLogAnalyzer.java | 162 -
.../db/engine/compaction/log/CompactionLogger.java | 83 -
.../db/engine/compaction/log/TsFileIdentifier.java | 234 -
.../compaction/performer/ICompactionPerformer.java | 48 -
.../performer/ICrossCompactionPerformer.java | 27 -
.../performer/ISeqCompactionPerformer.java | 27 -
.../performer/IUnseqCompactionPerformer.java | 27 -
.../performer/impl/FastCompactionPerformer.java | 308 --
.../impl/ReadChunkCompactionPerformer.java | 192 -
.../impl/ReadPointCompactionPerformer.java | 335 --
.../engine/compaction/reader/IDataBlockReader.java | 31 -
.../compaction/reader/PointPriorityReader.java | 191 -
.../compaction/reader/SeriesDataBlockReader.java | 156 -
.../compaction/schedule/CompactionScheduler.java | 170 +
.../compaction/schedule/CompactionTaskManager.java | 406 ++
.../compaction/schedule/CompactionWorker.java | 121 +
.../DefaultCompactionTaskComparatorImpl.java | 121 +
.../comparator/ICompactionTaskComparator.java | 35 +
.../schedule/constant/CompactionPriority.java | 26 +
.../schedule/constant/CompactionTaskStatus.java | 26 +
.../schedule/constant/CompactionType.java | 25 +
.../schedule/constant/ProcessChunkType.java | 25 +
.../compaction/selector/ICompactionSelector.java | 80 +
.../compaction/selector/ICrossSpaceSelector.java | 30 +
.../selector/IInnerSeqSpaceSelector.java | 28 +
.../selector/IInnerUnseqSpaceSelector.java | 28 +
.../selector/constant/CrossCompactionSelector.java | 47 +
.../constant/InnerSequenceCompactionSelector.java | 48 +
.../InnerUnsequenceCompactionSelector.java | 48 +
.../estimator/AbstractCompactionEstimator.java | 63 +
.../estimator/AbstractCrossSpaceEstimator.java | 38 +
.../estimator/AbstractInnerSpaceEstimator.java | 38 +
.../estimator/IFileQueryMemMeasurement.java | 36 +
.../estimator/InplaceCompactionEstimator.java | 171 +
.../ReadPointCrossCompactionEstimator.java | 195 +
.../impl/RewriteCrossSpaceCompactionSelector.java | 261 ++
.../impl/SizeTieredCompactionSelector.java | 216 +
.../utils/CrossCompactionTaskResource.java | 119 +
.../utils/CrossSpaceCompactionCandidate.java | 259 ++
.../compaction/task/AbstractCompactionTask.java | 151 -
.../compaction/task/CompactionRecoverTask.java | 507 ---
.../compaction/task/CompactionTaskSummary.java | 75 -
.../compaction/task/ICompactionSelector.java | 80 -
.../compaction/task/SubCompactionTaskSummary.java | 40 -
.../writer/AbstractCompactionWriter.java | 309 --
.../writer/AbstractCrossCompactionWriter.java | 242 -
.../writer/AbstractInnerCompactionWriter.java | 113 -
.../writer/FastCrossCompactionWriter.java | 203 -
.../writer/FastInnerCompactionWriter.java | 212 -
.../writer/ReadPointCrossCompactionWriter.java | 94 -
.../writer/ReadPointInnerCompactionWriter.java | 79 -
.../iotdb/db/engine/load/LoadTsFileManager.java | 12 +-
.../modification/utils/TracedBufferedReader.java | 2 +-
.../db/engine/querycontext/QueryDataSource.java | 31 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 47 +-
.../engine/storagegroup/TsFileNameGenerator.java | 11 +-
.../db/engine/storagegroup/TsFileProcessor.java | 108 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 7 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 26 +-
.../db/engine/storagegroup/TsFileResource.java | 44 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 4 +
.../engine/trigger/sink/forward/ForwardEvent.java | 1 +
.../db/engine/trigger/utils/BatchHandlerQueue.java | 1 +
.../apache/iotdb/db/exception/MergeException.java | 2 +-
.../exception/index/DistanceMetricException.java | 28 -
.../index/IllegalIndexParamException.java | 28 -
.../db/exception/index/IndexManagerException.java | 34 -
.../db/exception/index/IndexRuntimeException.java | 32 -
.../db/exception/index/QueryIndexException.java | 29 -
.../schemafile/RecordDuplicatedException.java | 2 +-
.../schemafile/SegmentOverflowException.java | 9 +-
.../template/DifferentTemplateException.java | 2 +-
.../template/NoTemplateOnMNodeException.java | 2 +-
.../template/UndefinedTemplateException.java | 2 +-
.../exception/query/KilledByOthersException.java | 34 +
.../exception/query/LogicalOperatorException.java | 54 -
.../exception/query/LogicalOptimizeException.java | 46 -
.../db/exception/query/OutOfTTLException.java | 2 +-
.../exception/query/PathNumOverLimitException.java | 33 -
.../query/UnSupportedFillTypeException.java | 33 -
.../iotdb/db/exception/sql/SQLParserException.java | 35 -
.../exception/sql/StatementAnalyzeException.java | 13 -
.../iotdb/db/index/common/IndexConstant.java | 36 -
.../apache/iotdb/db/index/common/IndexType.java | 78 -
.../apache/iotdb/db/index/common/IndexUtils.java | 35 -
.../iotdb/db/localconfignode/LocalConfigNode.java | 843 +---
.../localconfignode/LocalSchemaPartitionTable.java | 2 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 85 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 4 +
.../db/metadata/cache/DataNodeSchemaCache.java | 5 -
.../idtable/AppendOnlyDiskSchemaManager.java | 6 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 2 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 2 +-
.../metadata/mnode/container/MNodeContainers.java | 7 +
.../iotdb/db/metadata/mtree/ConfigMTree.java | 96 -
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 119 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 336 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 338 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 4 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 18 +-
.../mtree/store/disk/cache/CacheManager.java | 6 +-
.../disk/memcontrol/CachedMNodeSizeEstimator.java | 1 +
.../store/disk/schemafile/AliasIndexPage.java | 2 +-
.../mtree/store/disk/schemafile/ISchemaPage.java | 2 -
.../store/disk/schemafile/ISegmentedPage.java | 2 +
.../mtree/store/disk/schemafile/InternalPage.java | 15 +-
.../store/disk/schemafile/MockSchemaFile.java | 12 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 3 +-
.../mtree/store/disk/schemafile/SchemaPage.java | 9 +-
.../mtree/store/disk/schemafile/Segment.java | 2 +-
.../mtree/store/disk/schemafile/SegmentedPage.java | 16 +-
.../disk/schemafile/pagemgr/BTreePageManager.java | 12 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 6 +-
.../db/metadata/mtree/traverser/Traverser.java | 22 +-
.../mtree/traverser/collector/EntityCollector.java | 15 +-
.../traverser/collector/MNodeAboveSGCollector.java | 2 +-
.../mtree/traverser/collector/MNodeCollector.java | 2 +-
.../traverser/collector/MeasurementCollector.java | 6 +-
.../traverser/collector/StorageGroupCollector.java | 2 +-
.../mtree/traverser/counter/CounterTraverser.java | 2 +-
.../mtree/traverser/counter/EntityCounter.java | 46 -
.../counter/MNodeAboveSGLevelCounter.java | 60 -
.../mtree/traverser/counter/MNodeLevelCounter.java | 83 -
.../traverser/counter/MeasurementCounter.java | 73 -
.../counter/MeasurementGroupByLevelCounter.java | 126 -
.../impl/read/AbstractShowSchemaPlanImpl.java | 2 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 25 +-
.../impl/read/ShowDevicesPlanImpl.java | 20 +-
.../schemaregion/impl/read/ShowNodesPlanImpl.java | 39 +
.../plan/schemaregion/read/IShowDevicesPlan.java | 4 +-
.../plan/schemaregion/read/IShowNodesPlan.java | 26 +
.../schemaregion/result/ShowDevicesResult.java | 21 +-
.../plan/schemaregion/result/ShowNodesResult.java | 53 +
.../plan/schemaregion/result/ShowSchemaResult.java | 30 +-
.../schemaregion/result/ShowTimeSeriesResult.java | 60 +-
.../db/metadata/query/info/IDeviceSchemaInfo.java | 25 +
.../db/metadata/query/info/INodeSchemaInfo.java | 27 +
.../iotdb/db/metadata/query/info/ISchemaInfo.java | 29 +
.../metadata/query/info/ITimeSeriesSchemaInfo.java | 36 +
.../db/metadata/query/reader/ISchemaReader.java | 26 +
.../db/metadata/schemaregion/ISchemaRegion.java | 193 +-
.../db/metadata/schemaregion/SchemaEngine.java | 8 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 249 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 246 +-
.../storagegroup/IStorageGroupSchemaManager.java | 153 +-
.../storagegroup/StorageGroupSchemaManager.java | 154 +-
.../metadata/template/ClusterTemplateManager.java | 14 +-
.../iotdb/db/metadata/template/Template.java | 2 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 11 +-
.../db/metadata/utils/ResourceByPathUtils.java | 157 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 84 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 6 +
.../mpp/aggregation/LastValueDescAccumulator.java | 6 +
.../slidingwindow/SlidingWindowAggregator.java | 2 +-
.../SlidingWindowAggregatorFactory.java | 11 +-
.../timerangeiterator/AggrWindowIterator.java | 4 +-
.../TimeRangeIteratorFactory.java | 2 +-
.../iotdb/db/mpp/common/DataNodeEndPoints.java | 44 +
.../iotdb/db/mpp/common/FragmentInstanceId.java | 2 +-
.../db/mpp/common/filter/BasicFilterType.java | 189 -
.../db/mpp/common/filter/BasicFunctionFilter.java | 191 -
.../mpp/common/filter/FilterDeserializeUtil.java | 63 -
.../iotdb/db/mpp/common/filter/FunctionFilter.java | 91 -
.../iotdb/db/mpp/common/filter/InFilter.java | 230 -
.../iotdb/db/mpp/common/filter/LikeFilter.java | 152 -
.../iotdb/db/mpp/common/filter/QueryFilter.java | 354 --
.../iotdb/db/mpp/common/filter/RegexpFilter.java | 150 -
.../db/mpp/common/header/ColumnHeaderConstant.java | 29 +-
.../iotdb/db/mpp/common/header/DatasetHeader.java | 81 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../mpp/common/schematree/ClusterSchemaTree.java | 22 +-
.../common/schematree/node/SchemaInternalNode.java | 1 +
.../db/mpp/common/schematree/node/SchemaNode.java | 2 +-
.../visitor/SchemaTreeDeviceVisitor.java | 15 +-
.../visitor/SchemaTreeMeasurementVisitor.java | 18 +-
.../schematree/visitor/SchemaTreeVisitor.java | 22 +-
.../visitor/SchemaTreeVisitorFactory.java | 46 +
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 120 +
.../iotdb/db/mpp/execution/QueryIdGenerator.java | 2 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 9 +
.../iotdb/db/mpp/execution/driver/DataDriver.java | 56 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 26 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 36 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 12 +
.../execution/exchange/MPPDataExchangeManager.java | 18 +
.../execution/exchange/MPPDataExchangeService.java | 5 +-
.../db/mpp/execution/exchange/SinkHandle.java | 75 +-
.../db/mpp/execution/exchange/SourceHandle.java | 35 +-
.../execution/executor/RegionWriteExecutor.java | 2 +-
.../fragment/FragmentInstanceContext.java | 1 +
.../fragment/FragmentInstanceManager.java | 8 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 12 +
.../mpp/execution/operator/AbstractOperator.java | 94 +
.../iotdb/db/mpp/execution/operator/Operator.java | 23 +
.../db/mpp/execution/operator/OperatorContext.java | 19 +
.../operator/process/AbstractIntoOperator.java | 12 +-
.../operator/process/AbstractProcessOperator.java | 24 +
.../operator/process/AggregationOperator.java | 4 +-
.../operator/process/DeviceMergeOperator.java | 6 +-
.../operator/process/DeviceViewOperator.java | 6 +-
.../execution/operator/process/FillOperator.java | 4 +-
.../operator/process/FilterAndProjectOperator.java | 4 +-
.../execution/operator/process/LimitOperator.java | 4 +-
.../operator/process/LinearFillOperator.java | 6 +-
.../operator/process/MergeSortOperator.java | 6 +-
.../execution/operator/process/OffsetOperator.java | 4 +-
.../process/RawDataAggregationOperator.java | 8 +-
.../operator/process/SingleDeviceViewOperator.java | 6 +-
.../process/SingleInputAggregationOperator.java | 4 +-
.../process/SlidingWindowAggregationOperator.java | 6 +-
.../execution/operator/process/SortOperator.java | 83 +-
.../operator/process/TagAggregationOperator.java | 6 +-
.../operator/process/TransformOperator.java | 8 +-
.../process/join/RowBasedTimeJoinOperator.java | 43 +-
.../operator/process/join/TimeJoinOperator.java | 39 +-
.../process/join/VerticallyConcatOperator.java | 8 +-
.../process/join/merge/MergeSortComparator.java | 110 +-
.../last/AbstractUpdateLastCacheOperator.java | 4 +-
.../last/AlignedUpdateLastCacheOperator.java | 2 +-
.../process/last/LastQueryCollectOperator.java | 6 +-
.../process/last/LastQueryMergeOperator.java | 6 +-
.../operator/process/last/LastQueryOperator.java | 6 +-
.../process/last/LastQuerySortOperator.java | 6 +-
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelMergeOperator.java | 186 +
.../operator/schema/CountMergeOperator.java | 42 +-
.../operator/schema/DevicesCountOperator.java | 82 +-
.../operator/schema/DevicesSchemaScanOperator.java | 44 +-
.../schema/LevelTimeSeriesCountOperator.java | 105 +-
.../schema/NodeManageMemoryMergeOperator.java | 4 +-
.../operator/schema/NodePathsConvertOperator.java | 4 +-
.../operator/schema/NodePathsCountOperator.java | 4 +-
.../schema/NodePathsSchemaScanOperator.java | 94 +-
.../schema/PathsUsingTemplateScanOperator.java | 103 +-
.../operator/schema/SchemaCountOperator.java | 121 +
.../operator/schema/SchemaFetchMergeOperator.java | 6 +-
.../operator/schema/SchemaQueryMergeOperator.java | 6 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 11 +-
.../operator/schema/SchemaQueryScanOperator.java | 63 +-
.../operator/schema/TimeSeriesCountOperator.java | 93 +-
.../schema/TimeSeriesSchemaScanOperator.java | 75 +-
.../source/AbstractDataSourceOperator.java | 32 +
.../AbstractSeriesAggregationScanOperator.java | 25 +-
.../operator/source/AbstractSourceOperator.java | 33 +
.../operator/source/AlignedSeriesScanOperator.java | 50 +-
.../operator/source/AlignedSeriesScanUtil.java | 1 +
.../operator/source/LastCacheScanOperator.java | 2 +-
.../operator/source/SeriesScanOperator.java | 41 +-
.../execution/operator/source/SeriesScanUtil.java | 379 +-
.../operator/source/ShowQueriesOperator.java | 140 +
.../execution/schedule/AbstractDriverThread.java | 11 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 25 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 19 +
.../iotdb/db/mpp/metric/ChunkCacheMetrics.java | 69 +
.../iotdb/db/mpp/metric/DataExchangeMetricSet.java | 195 +
.../db/mpp/metric/DriverSchedulerMetricSet.java | 71 +
.../db/mpp/metric/QueryExecutionMetricSet.java | 132 +
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 129 +
.../db/mpp/metric/QueryPlanCostMetricSet.java | 67 +
.../db/mpp/metric/QueryResourceMetricSet.java | 58 +
.../db/mpp/metric/SeriesScanCostMetricSet.java | 558 +++
.../mpp/metric/TimeSeriesMetadataCacheMetrics.java | 78 +
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 37 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 59 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 11 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 140 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 13 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 27 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 599 ---
.../db/mpp/plan/analyze/ConcatPathRewriter.java | 24 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 48 +-
.../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 7 -
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 71 -
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 78 -
.../db/mpp/plan/analyze/cache/PartitionCache.java | 22 +-
.../analyze/cache/StorageGroupCacheResult.java | 2 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 230 +
.../analyze/schema/ClusterSchemaFetchExecutor.java | 207 +
.../plan/analyze/schema/ClusterSchemaFetcher.java | 354 ++
.../db/mpp/plan/analyze/schema/ISchemaFetcher.java | 71 +
.../mpp/plan/analyze/schema/SchemaValidator.java | 78 +
.../db/mpp/plan/constant/DataNodeEndPoints.java | 39 -
.../iotdb/db/mpp/plan/constant/FilterConstant.java | 103 -
.../iotdb/db/mpp/plan/constant/StatementType.java | 153 -
.../db/mpp/plan/execution/IQueryExecution.java | 9 +
.../db/mpp/plan/execution/QueryExecution.java | 101 +-
.../mpp/plan/execution/config/ConfigExecution.java | 24 +
.../plan/execution/config/ConfigTaskVisitor.java | 23 +-
.../config/executor/ClusterConfigTaskExecutor.java | 131 +-
.../config/executor/IConfigTaskExecutor.java | 5 +
.../config/metadata/ShowClusterDetailsTask.java | 8 +-
.../execution/config/metadata/ShowClusterTask.java | 4 +-
.../config/metadata/ShowVariablesTask.java | 134 +
.../plan/execution/config/sys/KillQueryTask.java | 42 +
.../execution/config/sys/sync/ShowPipeTask.java | 2 +-
.../iotdb/db/mpp/plan/expression/Expression.java | 18 +-
.../iotdb/db/mpp/plan/expression/ResultColumn.java | 146 -
.../plan/expression/binary/BinaryExpression.java | 13 -
.../mpp/plan/expression/leaf/TimestampOperand.java | 5 -
.../plan/expression/multi/FunctionExpression.java | 63 +-
.../plan/expression/ternary/BetweenExpression.java | 1 +
.../plan/expression/ternary/TernaryExpression.java | 32 -
.../mpp/plan/expression/unary/UnaryExpression.java | 11 -
.../visitor/ColumnTransformerVisitor.java | 25 +-
.../visitor/OldIntermediateLayerVisitor.java | 461 --
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 251 +-
.../iotdb/db/mpp/plan/parser/SqlParseError.java | 65 +
.../db/mpp/plan/parser/StatementGenerator.java | 93 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 20 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 64 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 6 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 10 +-
.../plan/planner/MemoryDistributionCalculator.java | 9 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 108 +-
.../db/mpp/plan/planner/SubPlanTypeExtractor.java | 5 +
.../planner/distribution/DistributionPlanner.java | 4 +-
.../planner/distribution/ExchangeNodeAdder.java | 24 +
.../SimpleFragmentParallelPlanner.java | 33 +-
.../plan/planner/distribution/SourceRewriter.java | 42 +-
.../db/mpp/plan/planner/plan/PlanFragment.java | 24 +-
.../iotdb/db/mpp/plan/planner/plan/SubPlan.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 23 +-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 2 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../metedata/read/AbstractSchemaMergeNode.java | 4 +-
.../metedata/read/PathsUsingTemplateScanNode.java | 2 +
.../node/metedata/read/SchemaFetchMergeNode.java | 1 +
.../node/metedata/read/SchemaQueryMergeNode.java | 1 +
.../write/CreateAlignedTimeSeriesNode.java | 1 +
.../metedata/write/CreateMultiTimeSeriesNode.java | 1 +
.../node/metedata/write/CreateTimeSeriesNode.java | 1 +
.../plan/node/process/MultiChildProcessNode.java | 4 +-
.../planner/plan/node/process/ProcessNode.java | 2 +-
.../plan/node/process/SingleChildProcessNode.java | 4 +-
.../plan/planner/plan/node/process/SortNode.java | 54 +-
.../node/process/last/LastQueryCollectNode.java | 1 +
.../plan/node/process/last/LastQueryMergeNode.java | 1 +
.../plan/node/process/last/LastQueryNode.java | 7 +-
.../mpp/plan/planner/plan/node/sink/SinkNode.java | 2 +-
.../source/AlignedSeriesAggregationScanNode.java | 3 +
.../node/source/SeriesAggregationScanNode.java | 3 +
.../node/source/SeriesAggregationSourceNode.java | 2 +-
.../planner/plan/node/source/SeriesSourceNode.java | 2 +-
.../planner/plan/node/source/ShowQueriesNode.java | 110 +
.../plan/node/source/VirtualSourceNode.java | 41 +
.../plan/parameter/AggregationDescriptor.java | 17 +-
.../CrossSeriesAggregationDescriptor.java | 1 +
.../planner/plan/parameter/OrderByParameter.java | 10 +
.../plan/planner/plan/parameter/OutputColumn.java | 2 +-
.../db/mpp/plan/rewriter/DnfFilterOptimizer.java | 163 -
.../db/mpp/plan/rewriter/IFilterOptimizer.java | 29 -
.../plan/rewriter/MergeSingleFilterOptimizer.java | 179 -
.../db/mpp/plan/rewriter/RemoveNotOptimizer.java | 103 -
.../scheduler/AbstractFragInsStateTracker.java | 6 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 8 +
.../scheduler/FixedRateFragInsStateTracker.java | 8 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 41 +-
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 7 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 8 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 18 +-
.../iotdb/db/mpp/plan/statement/Statement.java | 1 -
.../iotdb/db/mpp/plan/statement/StatementType.java | 153 +
.../db/mpp/plan/statement/StatementVisitor.java | 10 +
.../plan/statement/component/IntoComponent.java | 8 +-
.../plan/statement/component/SelectComponent.java | 2 +-
.../plan/statement/crud/DeleteDataStatement.java | 2 +-
.../crud/InsertMultiTabletsStatement.java | 3 +-
.../plan/statement/crud/InsertRowStatement.java | 3 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 5 +-
.../plan/statement/crud/InsertRowsStatement.java | 3 +-
.../mpp/plan/statement/crud/InsertStatement.java | 2 +-
.../plan/statement/crud/InsertTabletStatement.java | 3 +-
.../plan/statement/crud/LoadTsFileStatement.java | 2 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 2 +-
.../InternalCreateTimeSeriesStatement.java | 2 +-
.../statement/internal/SchemaFetchStatement.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 2 +-
.../plan/statement/metadata/CountStatement.java | 2 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 2 +-
.../metadata/CreateContinuousQueryStatement.java | 2 +-
.../metadata/CreateFunctionStatement.java | 2 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 2 +-
.../metadata/CreateTimeSeriesStatement.java | 2 +-
.../statement/metadata/CreateTriggerStatement.java | 2 +-
.../metadata/DeleteStorageGroupStatement.java | 2 +-
.../metadata/DeleteTimeSeriesStatement.java | 2 +-
.../metadata/DropContinuousQueryStatement.java | 2 +-
.../statement/metadata/DropFunctionStatement.java | 2 +-
.../statement/metadata/DropTriggerStatement.java | 2 +-
.../metadata/SetStorageGroupStatement.java | 2 +-
.../plan/statement/metadata/SetTTLStatement.java | 2 +-
.../metadata/ShowContinuousQueriesStatement.java | 2 +-
.../statement/metadata/ShowRegionStatement.java | 14 +-
.../mpp/plan/statement/metadata/ShowStatement.java | 2 +-
.../statement/metadata/ShowVariablesStatement.java | 36 +
.../plan/statement/metadata/UnSetTTLStatement.java | 2 +-
.../template/ActivateTemplateStatement.java | 2 +-
.../template/CreateSchemaTemplateStatement.java | 2 +-
.../template/DeactivateTemplateStatement.java | 2 +-
.../template/DropSchemaTemplateStatement.java | 2 +-
.../template/SetSchemaTemplateStatement.java | 2 +-
.../ShowNodesInSchemaTemplateStatement.java | 2 +-
.../template/ShowPathSetTemplateStatement.java | 2 +-
.../template/ShowPathsUsingTemplateStatement.java | 2 +-
.../template/ShowSchemaTemplateStatement.java | 2 +-
.../template/UnsetSchemaTemplateStatement.java | 2 +-
.../db/mpp/plan/statement/sys/AuthorStatement.java | 2 +-
.../plan/statement/sys/ClearCacheStatement.java | 2 +-
.../db/mpp/plan/statement/sys/FlushStatement.java | 2 +-
.../mpp/plan/statement/sys/KillQueryStatement.java | 64 +
.../statement/sys/LoadConfigurationStatement.java | 2 +-
.../db/mpp/plan/statement/sys/MergeStatement.java | 2 +-
.../statement/sys/SetSystemStatusStatement.java | 2 +-
.../plan/statement/sys/ShowQueriesStatement.java | 25 +
.../sys/sync/CreatePipeSinkStatement.java | 2 +-
.../statement/sys/sync/CreatePipeStatement.java | 2 +-
.../statement/sys/sync/DropPipeSinkStatement.java | 2 +-
.../plan/statement/sys/sync/DropPipeStatement.java | 2 +-
.../statement/sys/sync/StartPipeStatement.java | 2 +-
.../plan/statement/sys/sync/StopPipeStatement.java | 2 +-
.../iotdb/db/mpp/statistics/StatisticsManager.java | 2 +-
.../dag/column/ColumnTransformer.java | 2 +-
.../binary/ArithmeticBinaryColumnTransformer.java | 2 +-
.../dag/column/binary/BinaryColumnTransformer.java | 2 +-
.../binary/CompareBinaryColumnTransformer.java | 2 +-
.../binary/LogicBinaryColumnTransformer.java | 2 +-
.../dag/column/leaf/LeafColumnTransformer.java | 2 +-
.../ternary/CompareTernaryColumnTransformer.java | 4 +-
.../column/ternary/TernaryColumnTransformer.java | 2 +-
.../dag/column/unary/UnaryColumnTransformer.java | 2 +-
.../dag/input/TsBlockInputDataSet.java | 6 +-
.../dag/transformer/unary/UnaryTransformer.java | 2 +-
.../db/mpp/transformation/dag/udf/UDTFContext.java | 8 -
.../mpp/transformation/dag/udf/UDTFExecutor.java | 7 +-
.../influxdb/constant/InfluxSQLConstant.java | 64 -
.../influxdb/constant/InfluxSqlConstant.java | 65 +
.../protocol/influxdb/function/InfluxFunction.java | 4 +-
.../influxdb/function/InfluxFunctionFactory.java | 24 +-
.../function/aggregator/InfluxAggregator.java | 2 +-
.../function/aggregator/InfluxCountFunction.java | 4 +-
.../function/aggregator/InfluxMeanFunction.java | 6 +-
.../function/aggregator/InfluxMedianFunction.java | 4 +-
.../function/aggregator/InfluxModeFunction.java | 4 +-
.../function/aggregator/InfluxSpreadFunction.java | 4 +-
.../function/aggregator/InfluxStddevFunction.java | 7 +-
.../function/aggregator/InfluxSumFunction.java | 6 +-
.../function/selector/InfluxFirstFunction.java | 4 +-
.../function/selector/InfluxLastFunction.java | 4 +-
.../function/selector/InfluxMaxFunction.java | 4 +-
.../function/selector/InfluxMinFunction.java | 4 +-
.../influxdb/function/selector/InfluxSelector.java | 2 +-
.../influxdb/handler/AbstractQueryHandler.java | 208 +-
.../protocol/influxdb/handler/NewQueryHandler.java | 25 +-
.../protocol/influxdb/handler/TagQueryHandler.java | 2 +-
.../protocol/influxdb/input/InfluxLineParser.java | 2 +-
.../influxdb/operator/InfluxQueryOperator.java | 38 -
.../influxdb/operator/InfluxSelectComponent.java | 98 -
.../influxdb/parser/InfluxDBAstVisitor.java | 321 ++
.../parser/InfluxDBStatementGenerator.java | 67 +
.../influxdb/sql/InfluxDBLogicalGenerator.java | 66 -
.../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 298 --
.../influxdb/statement/InfluxQueryStatement.java | 57 +
.../influxdb/statement/InfluxSelectComponent.java | 98 +
.../db/protocol/influxdb/util/FilterUtils.java | 20 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 +-
.../db/protocol/mqtt/PayloadFormatManager.java | 19 +-
.../db/protocol/rest/handler/ExceptionHandler.java | 3 +-
.../rest/handler/ExecuteStatementHandler.java | 2 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 6 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 4 +-
.../iotdb/db/qp/constant/FilterConstant.java | 114 -
.../apache/iotdb/db/qp/constant/SQLConstant.java | 285 --
.../org/apache/iotdb/db/qp/logical/Operator.java | 200 -
.../db/qp/logical/crud/BasicFunctionOperator.java | 172 -
.../db/qp/logical/crud/BasicOperatorType.java | 191 -
.../iotdb/db/qp/logical/crud/FilterOperator.java | 295 --
.../iotdb/db/qp/logical/crud/FromComponent.java | 41 -
.../iotdb/db/qp/logical/crud/FunctionOperator.java | 48 -
.../iotdb/db/qp/logical/crud/QueryOperator.java | 106 -
.../iotdb/db/qp/logical/crud/SelectComponent.java | 139 -
.../db/qp/logical/crud/SpecialClauseComponent.java | 162 -
.../iotdb/db/qp/logical/crud/WhereComponent.java | 40 -
.../apache/iotdb/db/qp/strategy/SQLParseError.java | 64 -
.../apache/iotdb/db/qp/utils/DateTimeUtils.java | 757 ----
.../iotdb/db/qp/utils/GroupByLevelController.java | 327 --
.../iotdb/db/query/control/FileReaderManager.java | 13 +-
.../iotdb/db/query/control/QueryFileManager.java | 8 +-
.../db/query/control/QueryResourceManager.java | 14 -
.../query/control/clientsession/ClientSession.java | 2 +-
.../apache/iotdb/db/query/filter/TsFileFilter.java | 31 -
.../query/reader/chunk/DiskAlignedChunkLoader.java | 38 +-
.../db/query/reader/chunk/DiskChunkLoader.java | 23 +-
.../query/reader/chunk/MemAlignedChunkLoader.java | 15 +-
.../db/query/reader/chunk/MemChunkLoader.java | 15 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 114 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 120 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 75 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 76 +-
.../query/reader/series/AlignedSeriesReader.java | 109 -
.../reader/series/SeriesRawDataBatchReader.java | 140 -
.../iotdb/db/query/reader/series/SeriesReader.java | 1430 ------
.../java/org/apache/iotdb/db/service/DataNode.java | 26 +-
.../db/service/DataNodeServerCommandLine.java | 2 +-
.../org/apache/iotdb/db/service/SettleService.java | 5 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 16 +-
.../iotdb/db/service/metrics/FileMetrics.java | 286 +-
.../metrics/IoTDBInternalLocalReporter.java | 157 +
.../db/service/metrics/IoTDBInternalReporter.java | 157 -
.../iotdb/db/service/metrics/ProcessMetrics.java | 31 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 39 +-
.../recorder/CompactionMetricsRecorder.java | 12 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 126 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 55 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 17 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 19 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 6 +-
.../iotdb/db/sync/datasource/AbstractOpBlock.java | 2 +-
.../iotdb/db/sync/datasource/PipeOpManager.java | 8 +-
.../iotdb/db/sync/datasource/PipeOpSgManager.java | 6 +-
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 10 +-
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 4 +-
.../db/sync/externalpipe/ExtPipePluginManager.java | 4 +-
.../db/sync/externalpipe/operation/Operation.java | 2 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 1 +
.../apache/iotdb/db/sync/pipedata/PipeData.java | 4 +-
.../db/sync/pipedata/load/DeletionLoader.java | 4 +-
.../iotdb/db/sync/pipedata/load/ILoader.java | 4 +-
.../iotdb/db/sync/pipedata/load/TsFileLoader.java | 5 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 2 +-
.../db/sync/sender/pipe/ExternalPipeSink.java | 2 +-
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 2 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 2 +-
.../db/sync/transport/client/SenderManager.java | 2 +-
.../db/sync/transport/server/ReceiverManager.java | 6 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 2 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 2 +-
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 2 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 6 +-
.../db/tools/validate/TsFileValidationTool.java | 2 +-
.../db/tools/watermark/WatermarkDetector.java | 9 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 4 +-
.../db/trigger/executor/TriggerFireVisitor.java | 47 +-
.../trigger/service/TriggerInformationUpdater.java | 8 +-
.../iotdb/db/utils/AlignedValueIterator.java | 59 -
.../org/apache/iotdb/db/utils/CommonUtils.java | 10 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 757 ++++
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 -
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 282 +-
.../java/org/apache/iotdb/db/utils/FilesUtils.java | 43 -
.../iotdb/db/utils/IExpressionDeserializeUtil.java | 51 -
.../apache/iotdb/db/utils/ModificationUtils.java | 157 +
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 133 -
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 185 -
.../org/apache/iotdb/db/utils/SchemaUtils.java | 20 +-
.../org/apache/iotdb/db/utils/SetThreadName.java | 5 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 46 +-
.../org/apache/iotdb/db/utils/ValueIterator.java | 56 -
.../db/utils/datastructure/AlignedTVList.java | 4 +-
.../datastructure/FixedPriorityBlockingQueue.java | 4 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../timerangeiterator/AggrWindowIterator.java | 165 -
.../timerangeiterator/ITimeRangeIterator.java | 39 -
.../timerangeiterator/PreAggrWindowIterator.java | 158 -
.../PreAggrWindowWithNaturalMonthIterator.java | 123 -
.../TimeRangeIteratorFactory.java | 69 -
.../allocation/AbstractNodeAllocationStrategy.java | 2 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 3 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 4 +-
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 2 +-
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 2 +
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 2 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 2 +-
.../file/UnsealedTsFileRecoverPerformer.java | 10 +-
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 4 +-
.../wal/utils/listener/AbstractResultListener.java | 2 +-
.../engine/compaction/AbstractCompactionTest.java | 5 +-
.../engine/compaction/CompactionSchedulerTest.java | 10 +-
.../CompactionSchedulerWithFastPerformerTest.java | 10 +-
.../compaction/CompactionTaskComparatorTest.java | 17 +-
.../compaction/CompactionTaskManagerTest.java | 13 +-
.../compaction/FastAlignedCrossCompactionTest.java | 4 +-
.../FastCrossCompactionPerformerTest.java | 340 +-
.../FastInnerCompactionPerformerTest.java | 194 +-
.../FastNonAlignedCrossCompactionTest.java | 4 +-
.../ReadPointCompactionPerformerTest.java | 481 +-
.../db/engine/compaction/TsFileIdentifierUT.java | 4 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 16 +-
.../CrossSpaceCompactionWithFastPerformerTest.java | 30 +-
...eCompactionWithFastPerformerValidationTest.java | 1014 +++--
...sSpaceCompactionWithReadPointPerformerTest.java | 30 +-
...actionWithReadPointPerformerValidationTest.java | 920 ++--
.../engine/compaction/cross/MergeUpgradeTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 123 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 16 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 166 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 166 +-
.../inner/FastCompactionPerformerAlignedTest.java | 35 +-
.../FastCompactionPerformerNoAlignedTest.java | 100 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 7 +-
.../compaction/inner/InnerCompactionLogTest.java | 6 +-
.../inner/InnerCompactionMoreDataTest.java | 32 +-
.../inner/InnerCompactionSchedulerTest.java | 4 +-
.../InnerSeqCompactionWithFastPerformerTest.java | 9 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 9 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 12 +-
.../InnerUnseqCompactionWithFastPerformerTest.java | 8 +-
...rUnseqCompactionWithReadPointPerformerTest.java | 8 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 33 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 98 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 10 +-
.../SizeTieredCompactionRecoverTest.java | 316 +-
.../SizeTieredCompactionSelectorTest.java | 1 +
...eCrossSpaceCompactionRecoverCompatibleTest.java | 4 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 12 +-
.../recover/SizeTieredCompactionRecoverTest.java | 18 +-
.../compaction/utils/CompactionCheckerUtils.java | 26 +-
.../compaction/utils/CompactionClearUtils.java | 2 +-
.../compaction/utils/CompactionConfigRestorer.java | 14 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 2 +-
.../db/engine/storagegroup/DataRegionTest.java | 10 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 31 +-
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 28 -
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 383 --
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 29 +-
.../schemaRegion/SchemaRegionBasicTest.java | 193 +-
.../schemaRegion/SchemaRegionManagementTest.java | 58 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 10 +-
.../schemaRegion/SchemaRegionTestUtil.java | 126 +
.../apache/iotdb/db/metric/MetricServiceTest.java | 4 +-
.../common/schematree/ClusterSchemaTreeTest.java | 192 +-
.../ClusterSchemaTreeTestWithRelease.java | 39 +
.../MockSchemaTreeMeasurementVisitor.java | 105 +
.../exchange/MPPDataExchangeManagerTest.java | 8 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 13 +-
.../mpp/execution/exchange/SourceHandleTest.java | 12 +-
.../mpp/execution/operator/FillOperatorTest.java | 4 +-
.../operator/LastQueryMergeOperatorTest.java | 8 +-
.../execution/operator/LinearFillOperatorTest.java | 14 +-
.../execution/operator/MergeSortOperatorTest.java | 246 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 66 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 192 +
.../operator/schema/CountMergeOperatorTest.java | 139 -
.../operator/schema/SchemaCountOperatorTest.java | 187 +-
.../schema/SchemaQueryScanOperatorTest.java | 83 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 1 +
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 16 +-
.../iotdb/db/mpp/plan/plan/QueryPlannerTest.java | 4 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 2 +-
.../plan/plan/node/process/SortNodeSerdeTest.java | 10 +-
.../influxdb/sql/InfluxDBLogicalGeneratorTest.java | 70 -
.../sql/InfluxDBStatementGeneratorTest.java | 87 +
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 10 +-
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 2 +
.../org/apache/iotdb/db/tools/MLogParserTest.java | 11 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 5 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 12 +-
.../iotdb/db/utils/TimeRangeIteratorTest.java | 298 --
.../iotdb/db/wal/utils/WALFileUtilsTest.java | 26 +
.../datanode1conf/iotdb-datanode.properties | 10 +-
.../datanode2conf/iotdb-datanode.properties | 12 +-
.../datanode3conf/iotdb-datanode.properties | 12 +-
server/src/test/resources/logback-test.xml | 1 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 1 -
.../apache/iotdb/session/SessionConnection.java | 4 +-
.../org/apache/iotdb/session/SessionDataSet.java | 348 ++
.../iotdb/session/pool/SessionDataSetWrapper.java | 114 +
.../org/apache/iotdb/session/pool/SessionPool.java | 16 +-
site/src/main/.vuepress/config.js | 4 +
.../test/java/org/apache/iotdb/db/sql/Cases.java | 1 +
.../src/main/thrift/confignode.thrift | 163 +-
thrift-mlnode/pom.xml | 67 +
thrift-mlnode/src/main/thrift/mlnode.thrift | 57 +
thrift/src/main/thrift/datanode.thrift | 87 +
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../fileInputFactory/FileInputFactory.java | 4 +-
.../fileInputFactory/HDFSInputFactory.java | 11 +-
.../fileInputFactory/LocalFSInputFactory.java | 14 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 12 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 2 +-
.../read/common/block/column/BinaryColumn.java | 11 +-
.../read/common/block/column/BooleanColumn.java | 10 +-
.../tsfile/read/common/block/column/Column.java | 2 +
.../read/common/block/column/DoubleColumn.java | 11 +-
.../read/common/block/column/FloatColumn.java | 11 +-
.../tsfile/read/common/block/column/IntColumn.java | 11 +-
.../read/common/block/column/LongColumn.java | 11 +-
.../read/common/block/column/NullColumn.java | 24 +-
.../block/column/RunLengthEncodedColumn.java | 5 +
.../read/common/block/column/TimeColumn.java | 9 +-
.../iotdb/tsfile/read/common/ColumnTest.java | 12 +
1334 files changed, 45798 insertions(+), 47941 deletions(-)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/RetryFailedTasksThread.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/observer/IEvent.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/observer/NodeStatisticsEvent.java
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/OperatePipeProcedureRollbackProcessor.java
delete mode 100644 docker/src/main/DockerCompose/docker-compose-1c1d.yml
create mode 100644 docker/src/main/DockerCompose/docker-compose-standalone.yml
rename docker/src/main/{Dockerfile-1.0.0-1c1d => Dockerfile-1.0.0-standalone}
(100%)
create mode 100644
docs/UserGuide/Monitor-Alert/Apache-IoTDB-ConfigNode-Dashboard.json
create mode 100644
docs/UserGuide/Monitor-Alert/Apache-IoTDB-DataNode-Dashboard.json
delete mode 100644
example/trigger/src/main/java/org/apache/iotdb/trigger/SimpleTrigger.java
create mode 100644
example/trigger/src/main/java/org/apache/iotdb/trigger/StatisticsUpdaterTrigger.java
delete mode 100644
example/trigger/src/main/java/org/apache/iotdb/trigger/old/AlertingExample.java
delete mode 100644 grafana-metrics-example/Apache IoTDB ConfigNode
Dashboard.json
delete mode 100644 grafana-metrics-example/Apache IoTDB DataNode Dashboard.json
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/AbstractEnv.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/AbstractNodeWrapper.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/Cluster1Env.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/ConfigFactory.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/ConfigNodeWrapper.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/DataNodeWrapper.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/EnvUtils.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/MppConfig.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerConfig.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/SimpleEnv.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/AbstractEnv.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/AbstractNodeWrapper.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/Cluster1Env.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/ConfigNodeWrapper.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/DataNodeWrapper.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/EnvUtils.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppBaseConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppClusterConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppCommonConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppConfigNodeConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppDataNodeConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppSharedCommonConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/SimpleEnv.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteClusterConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteCommonConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteConfigNodeConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteDataNodeConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteServerEnv.java
delete mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/env/ClusterConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/env/CommonConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/env/ConfigNodeConfig.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/env/DataNodeConfig.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnvConfig.java
delete mode 100644
isession/src/main/java/org/apache/iotdb/isession/SessionDataSet.java
create mode 100644
isession/src/main/java/org/apache/iotdb/isession/pool/ISessionDataSetWrapper.java
delete mode 100644
isession/src/main/java/org/apache/iotdb/isession/pool/SessionDataSetWrapper.java
delete mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/InternalIoTDBReporter.java
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/IoTDBInternalMemoryReporter.java
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/IoTDBInternalReporter.java
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/IoTDBSessionReporter.java
delete mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/MemoryInternalIoTDBReporter.java
delete mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/SessionIoTDBReporter.java
create mode 100644
metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/SystemType.java
create mode 100644
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/MicrometerTimerHistogramSnapshot.java
create mode 100644 mlnode/.gitignore
create mode 100644 mlnode/pom.xml
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/AsyncBaseClientFactory.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/BaseClientFactory.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/ClientFactoryProperty.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolProperty.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/ThriftClient.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/exception/BorrowNullClientManagerException.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/exception/ClientManagerException.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/exception/CreateTAsyncClientManagerException.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/factory/AsyncThriftClientFactory.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/factory/BaseClientFactory.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/factory/ThriftClientFactory.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/property/ClientPoolProperty.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/property/ThriftClientProperty.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncThriftClient.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/FAFactory.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/SimpleNFA.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/DFAState.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/PatternDFA.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/graph/Closure.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/graph/DFAGraph.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/graph/NFAGraph.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/transition/AbstractDFATransition.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/transition/DFAPreciseTransition.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/transition/DFAWildcardTransition.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/nfa/SimpleNFA.java
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/AbstractTreeVisitorWithLimitOffset.java
create mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/path/PatternDFATest.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/constant/SqlConstant.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/cache/ChunkCacheMetrics.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/cache/TimeSeriesMetadataCacheMetrics.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionExceptionHandler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionRecoverManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionTaskManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionWorker.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/comparator/DefaultCompactionTaskComparatorImpl.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/comparator/ICompactionTaskComparator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CompactionPriority.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CompactionTaskStatus.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CompactionType.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CrossCompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CrossCompactionSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerSeqCompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerSequenceCompactionSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerUnseqCompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerUnsequenceCompactionSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/ProcessChunkType.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/AbstractCrossSpaceEstimator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/CrossSpaceCompactionTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/ICrossSpaceSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionResource.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/ICrossSpaceCompactionFileSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/FastCompactionPerformerSubTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/ReadPointPerformerSubTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/AbstractCompactionEstimator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/AlignedSeriesCompactionExecutor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/ChunkMetadataElement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/FileElement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/IFileQueryMemMeasurement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/InplaceCompactionEstimator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/NonAlignedSeriesCompactionExecutor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/PageElement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/PointElement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/ReadPointCrossCompactionEstimator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/SeriesCompactionExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/exception/CompactionExceptionHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/ICompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/ICrossCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/ISeqCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/IUnseqCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/constant/CrossCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/constant/InnerSeqCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/constant/InnerUnseqCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/impl/FastCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/impl/ReadChunkCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/performer/impl/ReadPointCompactionPerformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/recover/CompactionRecoverManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/recover/CompactionRecoverTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/task/AbstractCompactionTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/task/CompactionTaskSummary.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/task/CrossSpaceCompactionTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/task/InnerSpaceCompactionTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/task/subtask/FastCompactionPerformerSubTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/task/subtask/ReadPointPerformerSubTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/task/subtask/SubCompactionTaskSummary.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/CompactionUtils.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/MultiTsFileDeviceIterator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/executor/fast/AlignedSeriesCompactionExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/executor/fast/NonAlignedSeriesCompactionExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/executor/fast/SeriesCompactionExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/executor/fast/element/ChunkMetadataElement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/executor/fast/element/FileElement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/executor/fast/element/PageElement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/executor/fast/element/PointElement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/executor/readchunk/AlignedSeriesCompactionExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/executor/readchunk/SingleSeriesCompactionExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/log/CompactionLogAnalyzer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/log/CompactionLogger.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/log/TsFileIdentifier.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/reader/IDataBlockReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/reader/PointPriorityReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/reader/SeriesDataBlockReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/writer/AbstractCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/writer/AbstractCrossCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/writer/AbstractInnerCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/writer/FastCrossCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/writer/FastInnerCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/writer/ReadPointCrossCompactionWriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/utils/writer/ReadPointInnerCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/AbstractInnerSpaceEstimator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/IInnerSeqSpaceSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/IInnerUnseqSpaceSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/sizetiered/SizeTieredCompactionSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/AlignedSeriesCompactionExecutor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/MultiTsFileDeviceIterator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/SingleSeriesCompactionExecutor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/log/CompactionLogAnalyzer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/log/CompactionLogger.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/log/TsFileIdentifier.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ICompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ICrossCompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ISeqCompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/IUnseqCompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/FastCompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/ReadChunkCompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/ReadPointCompactionPerformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/reader/IDataBlockReader.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/reader/PointPriorityReader.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/reader/SeriesDataBlockReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/CompactionScheduler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/CompactionTaskManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/CompactionWorker.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/comparator/DefaultCompactionTaskComparatorImpl.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/comparator/ICompactionTaskComparator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/constant/CompactionPriority.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/constant/CompactionTaskStatus.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/constant/CompactionType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/schedule/constant/ProcessChunkType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/ICompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/ICrossSpaceSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/IInnerSeqSpaceSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/IInnerUnseqSpaceSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/constant/CrossCompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/constant/InnerSequenceCompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/constant/InnerUnsequenceCompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/estimator/AbstractCompactionEstimator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/estimator/AbstractCrossSpaceEstimator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/estimator/AbstractInnerSpaceEstimator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/estimator/IFileQueryMemMeasurement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/estimator/InplaceCompactionEstimator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/estimator/ReadPointCrossCompactionEstimator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/impl/RewriteCrossSpaceCompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/impl/SizeTieredCompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/utils/CrossCompactionTaskResource.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/utils/CrossSpaceCompactionCandidate.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/AbstractCompactionTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/CompactionRecoverTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/CompactionTaskSummary.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/ICompactionSelector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/SubCompactionTaskSummary.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/AbstractCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/AbstractCrossCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/AbstractInnerCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/FastCrossCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/FastInnerCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/ReadPointCrossCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/writer/ReadPointInnerCompactionWriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/index/DistanceMetricException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/index/IllegalIndexParamException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/index/IndexManagerException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/index/IndexRuntimeException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/index/QueryIndexException.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/exception/query/KilledByOthersException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/query/LogicalOperatorException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/query/LogicalOptimizeException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/query/PathNumOverLimitException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/query/UnSupportedFillTypeException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/sql/SQLParserException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/index/common/IndexConstant.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/index/common/IndexType.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/index/common/IndexUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/EntityCounter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MNodeAboveSGLevelCounter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MNodeLevelCounter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MeasurementCounter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MeasurementGroupByLevelCounter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/read/ShowNodesPlanImpl.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/read/IShowNodesPlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/result/ShowNodesResult.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/query/info/IDeviceSchemaInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/query/info/INodeSchemaInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/query/info/ISchemaInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/query/info/ITimeSeriesSchemaInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/query/reader/ISchemaReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/DataNodeEndPoints.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/filter/BasicFilterType.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/filter/BasicFunctionFilter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/filter/FilterDeserializeUtil.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/filter/FunctionFilter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/filter/InFilter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/filter/LikeFilter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/filter/QueryFilter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/filter/RegexpFilter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/SchemaTreeVisitorFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/SchemaTreeVisitorWithLimitOffsetWrapper.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/AbstractOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractProcessOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/CountGroupByLevelMergeOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaCountOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AbstractDataSourceOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AbstractSourceOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/ShowQueriesOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/ChunkCacheMetrics.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/DataExchangeMetricSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/DriverSchedulerMetricSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/QueryExecutionMetricSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/QueryMetricsManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/QueryPlanCostMetricSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/QueryResourceMetricSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/SeriesScanCostMetricSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/TimeSeriesMetadataCacheMetrics.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ISchemaFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/SchemaValidator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/AutoCreateSchemaExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetchExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ISchemaFetcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/SchemaValidator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/constant/DataNodeEndPoints.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/constant/FilterConstant.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/constant/StatementType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowVariablesTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/KillQueryTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/ResultColumn.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/OldIntermediateLayerVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/SqlParseError.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/ShowQueriesNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/VirtualSourceNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/DnfFilterOptimizer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/IFilterOptimizer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/MergeSingleFilterOptimizer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/RemoveNotOptimizer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowVariablesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/KillQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/constant/InfluxSQLConstant.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/constant/InfluxSqlConstant.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/operator/InfluxQueryOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/operator/InfluxSelectComponent.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/parser/InfluxDBAstVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/parser/InfluxDBStatementGenerator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBLogicalGenerator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBSqlVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/statement/InfluxQueryStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/statement/InfluxSelectComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/constant/FilterConstant.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/constant/SQLConstant.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/Operator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/BasicFunctionOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/BasicOperatorType.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/FilterOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/FromComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/FunctionOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/QueryOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SelectComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SpecialClauseComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/WhereComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/strategy/SQLParseError.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/utils/DateTimeUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/utils/GroupByLevelController.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/filter/TsFileFilter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/AlignedSeriesReader.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesRawDataBatchReader.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/metrics/IoTDBInternalLocalReporter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/service/metrics/IoTDBInternalReporter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/AlignedValueIterator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/DateTimeUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/FilesUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/IExpressionDeserializeUtil.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/ModificationUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/QueryUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/ValueIterator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/AggrWindowIterator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/ITimeRangeIterator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowIterator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowWithNaturalMonthIterator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/TimeRangeIteratorFactory.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/ClusterSchemaTreeTestWithRelease.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/MockSchemaTreeMeasurementVisitor.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/CountGroupByLevelMergeOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/CountMergeOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBLogicalGeneratorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBStatementGeneratorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/utils/TimeRangeIteratorTest.java
create mode 100644
session/src/main/java/org/apache/iotdb/session/SessionDataSet.java
create mode 100644
session/src/main/java/org/apache/iotdb/session/pool/SessionDataSetWrapper.java
create mode 100644 thrift-mlnode/pom.xml
create mode 100644 thrift-mlnode/src/main/thrift/mlnode.thrift
