You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2023/01/05 12:26:00 UTC
[iotdb] branch pipeline updated (adced0820d -> 5012250382)
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch pipeline
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from adced0820d [IOTDB-5331] implement more pipeline breakers (#8722)
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 f2a0593044 Merge branch 'master' into pipeline
add fd2a90f004 modify retainedSize calculate
add 81b9ec8843 limit the output size of tsblock
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 163692e9cb Fix conflicts
add f96ca920d0 fetch upstream to sync
add 5012250382 reback JDBCExaple and IoTDBConfig
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp.yml | 18 +-
.gitignore | 1 +
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 29 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 15 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 14 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 8 +-
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 | 8 +-
.../assembly/resources/sbin/start-confignode.bat | 4 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 6 +-
.../client/async/AsyncDataNodeClientPool.java | 5 +-
.../async/AsyncDataNodeHeartbeatClientPool.java | 6 +-
.../handlers/rpc/AbstractAsyncRPCHandler.java | 2 +-
.../client/sync/SyncConfigNodeClientPool.java | 6 +-
.../client/sync/SyncDataNodeClientPool.java | 8 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 6 +-
.../confignode/conf/ConfigNodeDescriptor.java | 3 +
.../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 | 133 +-
.../iotdb/confignode/manager/ConsensusManager.java | 2 +-
.../apache/iotdb/confignode/manager/IManager.java | 24 +-
.../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 | 74 -
.../manager/node/heartbeat/BaseNodeCache.java | 6 +-
.../node/heartbeat/ConfigNodeHeartbeatCache.java | 2 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 2 +-
.../iotdb/confignode/manager/observer/IEvent.java | 9 +-
.../manager/observer/NodeStatisticsEvent.java | 29 +-
.../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 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 52 +-
.../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 +-
.../consensus/iot/IoTConsensusServerImpl.java | 17 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 3 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 2 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 13 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 31 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 8 +-
docker/ReadMe.md | 4 +-
docker/src/main/DockerCompose/do-docker-build.sh | 18 +-
...pose-1c1d.yml => docker-compose-standalone.yml} | 2 +-
...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 | 85 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 0
.../Apache-IoTDB-DataNode-Dashboard.json | 0
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 5 +-
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 +-
.../Reference/ConfigNode-Config-Manual.md | 6 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 10 +-
.../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 | 84 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 14 +-
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 +-
.../Reference/ConfigNode-Config-Manual.md | 6 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 10 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 105 +-
.../org/apache/iotdb/trigger/SimpleTrigger.java | 38 -
.../iotdb/trigger/StatisticsUpdaterTrigger.java | 160 +++
.../apache/iotdb/trigger/old/AlertingExample.java | 108 --
grafana-connector/pom.xml | 2 +-
.../web/grafana/interceptor/LoginInterceptor.java | 3 +
integration-test/import-control.xml | 1 +
.../trigger/example/TriggerFireTimesCounter.java | 26 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 28 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 13 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 34 +-
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 5 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 30 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 3 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 13 +-
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 8 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 93 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 80 +-
.../it/cluster/IoTDBClusterRestartIT.java | 7 +-
.../load/IoTDBClusterRegionLeaderBalancingIT.java | 6 +-
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 7 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 4 +-
.../IoTDBCustomRegionGroupExtensionIT.java | 6 +-
.../it/partition/IoTDBPartitionDurableIT.java | 23 +-
.../it/partition/IoTDBPartitionGetterIT.java | 29 +-
.../partition/IoTDBPartitionInheritPolicyIT.java | 13 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 49 +-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 78 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 3 -
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 88 ++
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 7 -
.../db/it/trigger/IoTDBTriggerManagementIT.java | 8 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 10 +-
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 1397 -> 1519 bytes
.../iotdb/db/integration/IoTDBCompactionIT.java | 2 +-
.../integration/IoTDBCompactionWithIDTableIT.java | 2 +-
.../integration/IoTDBSizeTieredCompactionIT.java | 4 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 31 +
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 166 +--
.../dropwizard/DropwizardMetricNameTool.java | 11 +
.../dropwizard/reporter/DropwizardJmxReporter.java | 17 +-
.../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 | 68 +-
.../metrics/config/MetricConfigDescriptor.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 +-
...orter.java => IoTDBInternalMemoryReporter.java} | 2 +-
...TDBReporter.java => IoTDBInternalReporter.java} | 12 +-
.../metrics/reporter/iotdb/IoTDBReporter.java | 12 +-
...oTDBReporter.java => IoTDBSessionReporter.java} | 27 +-
.../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 | 14 +-
.../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 +-
.../iotdb/metrics/config/MetricConfigTest.java | 4 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 8 +-
mlnode/.gitignore | 1 +
mlnode/pom.xml | 160 +++
node-commons/pom.xml | 4 +
.../resources/conf/iotdb-common.properties | 12 +-
.../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/ClientFactoryProperty.java | 7 +-
.../apache/iotdb/commons/client/ClientManager.java | 78 +-
.../iotdb/commons/client/ClientPoolProperty.java | 18 +-
.../iotdb/commons/client/IClientManager.java | 18 +-
.../iotdb/commons/client/IClientPoolFactory.java | 7 +-
.../client/exception/ClientManagerException.java | 8 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../threadpool/WrappedThreadPoolExecutor.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 2 +
.../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 | 7 +-
.../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/dfa/DFAState.java | 44 +-
.../iotdb/commons/path/fa/dfa/PatternDFA.java | 152 +++
.../iotdb/commons/path/fa/dfa/graph/Closure.java | 46 +-
.../iotdb/commons/path/fa/dfa/graph/DFAGraph.java | 173 +++
.../iotdb/commons/path/fa/dfa/graph/NFAGraph.java | 126 ++
.../fa/dfa/transition/AbstractDFATransition.java | 34 +-
.../fa/dfa/transition/DFAPreciseTransition.java | 25 +-
.../fa/dfa/transition/DFAWildcardTransition.java | 38 +-
.../iotdb/commons/path/fa/{ => nfa}/SimpleNFA.java | 12 +-
.../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 | 24 +-
.../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 | 49 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 48 +-
.../utils/ShowTimeSeriesResultUtils.java | 41 +-
.../resources/conf/iotdb-datanode.properties | 12 +-
.../src/assembly/resources/sbin/start-datanode.bat | 8 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 4 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 18 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 63 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 4 +-
.../iotdb/db/client/DataNodeInternalClient.java | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 47 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 33 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 443 +++---
.../org/apache/iotdb/db/constant/SqlConstant.java | 66 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 8 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 4 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 52 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 157 ++-
.../rewrite/CrossSpaceCompactionResource.java | 74 -
.../RewriteCrossSpaceCompactionSelector.java | 422 ------
.../ICrossSpaceCompactionFileSelector.java | 33 -
.../exception}/CompactionExceptionHandler.java | 5 +-
.../performer/ICompactionPerformer.java | 4 +-
.../performer/ICrossCompactionPerformer.java | 3 +-
.../performer/ISeqCompactionPerformer.java | 3 +-
.../performer/IUnseqCompactionPerformer.java | 3 +-
.../constant/CrossCompactionPerformer.java | 8 +-
.../constant/InnerSeqCompactionPerformer.java | 8 +-
.../constant/InnerUnseqCompactionPerformer.java | 8 +-
.../performer/impl/FastCompactionPerformer.java | 36 +-
.../impl/ReadChunkCompactionPerformer.java | 15 +-
.../impl/ReadPointCompactionPerformer.java | 39 +-
.../recover}/CompactionRecoverManager.java | 9 +-
.../recover}/CompactionRecoverTask.java | 15 +-
.../{ => execute}/task/AbstractCompactionTask.java | 6 +-
.../{ => execute}/task/CompactionTaskSummary.java | 2 +-
.../task}/CrossSpaceCompactionTask.java | 26 +-
.../task}/InnerSpaceCompactionTask.java | 20 +-
.../subtask}/FastCompactionPerformerSubTask.java | 9 +-
.../task/subtask}/ReadPointPerformerSubTask.java | 8 +-
.../task/subtask}/SubCompactionTaskSummary.java | 2 +-
.../{ => execute/utils}/CompactionUtils.java | 18 +-
.../utils/MultiTsFileDeviceIterator.java | 15 +-
.../fast}/AlignedSeriesCompactionExecutor.java | 17 +-
.../fast}/NonAlignedSeriesCompactionExecutor.java | 15 +-
.../executor/fast}/SeriesCompactionExecutor.java | 29 +-
.../fast/element}/ChunkMetadataElement.java | 2 +-
.../utils/executor/fast/element}/FileElement.java | 2 +-
.../utils/executor/fast/element}/PageElement.java | 2 +-
.../utils/executor/fast/element}/PointElement.java | 2 +-
.../AlignedSeriesCompactionExecutor.java | 8 +-
.../readchunk}/SingleSeriesCompactionExecutor.java | 13 +-
.../utils}/log/CompactionLogAnalyzer.java | 20 +-
.../{ => execute/utils}/log/CompactionLogger.java | 2 +-
.../{ => execute/utils}/log/TsFileIdentifier.java | 2 +-
.../utils}/reader/IDataBlockReader.java | 2 +-
.../utils}/reader/PointPriorityReader.java | 8 +-
.../utils}/reader/SeriesDataBlockReader.java | 2 +-
.../utils}/writer/AbstractCompactionWriter.java | 8 +-
.../writer/AbstractCrossCompactionWriter.java | 16 +-
.../writer/AbstractInnerCompactionWriter.java | 6 +-
.../utils}/writer/FastCrossCompactionWriter.java | 16 +-
.../utils}/writer/FastInnerCompactionWriter.java | 2 +-
.../writer/ReadPointCrossCompactionWriter.java | 9 +-
.../writer/ReadPointInnerCompactionWriter.java | 2 +-
.../{ => schedule}/CompactionScheduler.java | 20 +-
.../{ => schedule}/CompactionTaskManager.java | 10 +-
.../{ => schedule}/CompactionWorker.java | 8 +-
.../DefaultCompactionTaskComparatorImpl.java | 10 +-
.../comparator/ICompactionTaskComparator.java | 8 +-
.../constant/CompactionPriority.java | 2 +-
.../constant/CompactionTaskStatus.java | 2 +-
.../{ => schedule}/constant/CompactionType.java | 2 +-
.../{ => schedule}/constant/ProcessChunkType.java | 2 +-
.../{task => selector}/ICompactionSelector.java | 16 +-
.../{cross => selector}/ICrossSpaceSelector.java | 8 +-
.../IInnerSeqSpaceSelector.java | 4 +-
.../IInnerUnseqSpaceSelector.java | 4 +-
.../constant/CrossCompactionSelector.java | 6 +-
.../constant/InnerSequenceCompactionSelector.java | 6 +-
.../InnerUnsequenceCompactionSelector.java | 6 +-
.../estimator}/AbstractCompactionEstimator.java | 2 +-
.../estimator}/AbstractCrossSpaceEstimator.java | 3 +-
.../estimator}/AbstractInnerSpaceEstimator.java | 3 +-
.../estimator}/IFileQueryMemMeasurement.java | 2 +-
.../estimator}/InplaceCompactionEstimator.java | 3 +-
.../ReadPointCrossCompactionEstimator.java | 3 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 261 ++++
.../impl}/SizeTieredCompactionSelector.java | 17 +-
.../utils/CrossCompactionTaskResource.java | 119 ++
.../utils/CrossSpaceCompactionCandidate.java | 259 ++++
.../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/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 | 2 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 2 +
.../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/IMTreeBelowSG.java | 53 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 137 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 136 +-
.../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 | 7 +-
.../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 +-
.../counter/MNodeAboveSGLevelCounter.java | 60 -
.../mtree/traverser/counter/MNodeLevelCounter.java | 83 --
.../traverser/counter/MeasurementCounter.java | 73 -
.../counter/MeasurementGroupByLevelCounter.java | 6 +-
.../impl/read/AbstractShowSchemaPlanImpl.java | 2 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 15 +-
.../impl/read/ShowDevicesPlanImpl.java | 20 +-
.../plan/schemaregion/read/IShowDevicesPlan.java | 4 +-
.../schemaregion/result/ShowDevicesResult.java | 21 +-
.../plan/schemaregion/result/ShowSchemaResult.java | 30 +-
.../schemaregion/result/ShowTimeSeriesResult.java | 55 +-
.../query/info/IDeviceSchemaInfo.java} | 9 +-
.../info/ISchemaInfo.java} | 11 +-
.../metadata/query/info/ITimeSeriesSchemaInfo.java | 21 +-
.../db/metadata/query/reader/ISchemaReader.java | 9 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 82 +-
.../db/metadata/schemaregion/SchemaEngine.java | 8 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 105 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 102 +-
.../metadata/template/ClusterTemplateManager.java | 8 +-
.../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 +-
.../constant => common}/DataNodeEndPoints.java | 7 +-
.../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 +-
...eVisitor.java => SchemaTreeVisitorFactory.java} | 43 +-
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 120 ++
.../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 +
.../db/mpp/execution/exchange/SinkHandle.java | 75 +-
.../db/mpp/execution/exchange/SourceHandle.java | 34 +-
.../execution/executor/RegionWriteExecutor.java | 2 +-
.../fragment/FragmentInstanceContext.java | 1 +
.../fragment/FragmentInstanceManager.java | 8 +-
.../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 | 15 +-
.../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 | 46 +-
.../operator/process/join/TimeJoinOperator.java | 41 +-
.../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 +-
.../operator/schema/CountMergeOperator.java | 6 +-
.../operator/schema/DevicesCountOperator.java | 82 +-
.../operator/schema/DevicesSchemaScanOperator.java | 44 +-
.../schema/LevelTimeSeriesCountOperator.java | 2 +-
.../schema/NodeManageMemoryMergeOperator.java | 4 +-
.../operator/schema/NodePathsConvertOperator.java | 4 +-
.../operator/schema/NodePathsCountOperator.java | 4 +-
.../schema/PathsUsingTemplateScanOperator.java | 103 +-
...CountOperator.java => SchemaCountOperator.java} | 83 +-
.../operator/schema/SchemaFetchMergeOperator.java | 6 +-
.../operator/schema/SchemaQueryMergeOperator.java | 6 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 11 +-
.../operator/schema/SchemaQueryScanOperator.java | 60 +-
.../operator/schema/TimeSeriesCountOperator.java | 93 +-
.../schema/TimeSeriesSchemaScanOperator.java | 75 +-
.../source/AbstractDataSourceOperator.java | 25 +-
.../AbstractSeriesAggregationScanOperator.java | 25 +-
.../operator/source/AbstractSourceOperator.java} | 14 +-
.../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 | 383 +++---
.../operator/source/ShowQueriesOperator.java | 140 ++
.../execution/schedule/AbstractDriverThread.java | 11 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 23 +
.../db/mpp/execution/schedule/task/DriverTask.java | 19 +
.../cache => mpp/metric}/ChunkCacheMetrics.java | 6 +-
.../iotdb/db/mpp/metric/DataExchangeMetricSet.java | 195 +++
.../metric/DriverSchedulerMetricSet.java} | 54 +-
.../db/mpp/metric/QueryExecutionMetricSet.java | 132 ++
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 129 ++
.../metric/QueryPlanCostMetricSet.java} | 58 +-
.../metric/QueryResourceMetricSet.java} | 49 +-
.../db/mpp/metric/SeriesScanCostMetricSet.java | 558 ++++++++
.../metric}/TimeSeriesMetadataCacheMetrics.java | 5 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 27 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 65 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 11 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 104 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 13 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 22 +-
.../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 -
.../db/mpp/plan/analyze/cache/PartitionCache.java | 17 +-
.../analyze/cache/StorageGroupCacheResult.java | 2 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 230 ++++
.../analyze/schema/ClusterSchemaFetchExecutor.java | 207 +++
.../plan/analyze/schema/ClusterSchemaFetcher.java | 354 +++++
.../plan/analyze/{ => schema}/ISchemaFetcher.java | 2 +-
.../plan/analyze/{ => schema}/SchemaValidator.java | 2 +-
.../iotdb/db/mpp/plan/constant/FilterConstant.java | 103 --
.../db/mpp/plan/execution/IQueryExecution.java | 7 +
.../db/mpp/plan/execution/QueryExecution.java | 92 +-
.../mpp/plan/execution/config/ConfigExecution.java | 19 +
.../plan/execution/config/ConfigTaskVisitor.java | 16 +-
.../config/executor/ClusterConfigTaskExecutor.java | 90 +-
.../config/executor/IConfigTaskExecutor.java | 2 +
.../config/metadata/ShowClusterDetailsTask.java | 8 +-
.../execution/config/metadata/ShowClusterTask.java | 4 +-
.../config/metadata/ShowVariablesTask.java | 134 ++
.../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 | 241 ++--
.../plan/parser/SqlParseError.java} | 7 +-
.../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 | 482 +++++++
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 101 +-
.../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 +-
.../ShowQueriesNode.java} | 72 +-
.../VirtualSourceNode.java} | 18 +-
.../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 -
.../{constant => statement}/StatementType.java | 2 +-
.../db/mpp/plan/statement/StatementVisitor.java | 5 +
.../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 +-
...LStatement.java => ShowVariablesStatement.java} | 15 +-
.../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 +-
.../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 +-
...fluxSQLConstant.java => InfluxSqlConstant.java} | 15 +-
.../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/parser/InfluxDBAstVisitor.java | 321 +++++
.../InfluxDBStatementGenerator.java} | 25 +-
.../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 298 ----
.../influxdb/statement/InfluxQueryStatement.java | 57 +
.../InfluxSelectComponent.java | 22 +-
.../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 -
.../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 | 4 -
...porter.java => IoTDBInternalLocalReporter.java} | 36 +-
.../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 | 36 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 17 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 19 +-
.../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 | 29 +-
.../trigger/service/TriggerInformationUpdater.java | 2 +-
.../iotdb/db/utils/AlignedValueIterator.java | 59 -
.../org/apache/iotdb/db/utils/CommonUtils.java | 10 +-
.../iotdb/db/{qp => }/utils/DateTimeUtils.java | 2 +-
.../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 -
.../{QueryUtils.java => ModificationUtils.java} | 32 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 133 --
.../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 | 12 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 2 +-
.../db/engine/storagegroup/DataRegionTest.java | 10 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 31 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 57 -
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 29 +-
.../schemaRegion/SchemaRegionBasicTest.java | 98 +-
.../schemaRegion/SchemaRegionManagementTest.java | 58 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 10 +-
.../schemaRegion/SchemaRegionTestUtil.java | 59 +
.../common/schematree/ClusterSchemaTreeTest.java | 192 ++-
.../ClusterSchemaTreeTestWithRelease.java} | 35 +-
.../MockSchemaTreeMeasurementVisitor.java | 105 ++
.../db/mpp/execution/exchange/SinkHandleTest.java | 9 +-
.../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 | 243 +++-
.../mpp/execution/operator/OperatorMemoryTest.java | 56 +-
.../operator/schema/SchemaCountOperatorTest.java | 79 +-
.../schema/SchemaQueryScanOperatorTest.java | 83 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 1 +
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 16 +-
.../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 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 5 +-
.../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 +
.../apache/iotdb/session/SessionConnection.java | 3 +-
site/src/main/.vuepress/config.js | 4 +
.../src/main/thrift/confignode.thrift | 160 ++-
thrift-mlnode/pom.xml | 67 +
thrift-mlnode/src/main/thrift/mlnode.thrift | 57 +
thrift/src/main/thrift/datanode.thrift | 85 ++
.../fileInputFactory/FileInputFactory.java | 4 +-
.../fileInputFactory/HDFSInputFactory.java | 11 +-
.../fileInputFactory/LocalFSInputFactory.java | 14 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 12 +-
.../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 +
968 files changed, 17579 insertions(+), 19025 deletions(-)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/RetryFailedTasksThread.java
copy server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CompactionPriority.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/observer/IEvent.java (86%)
copy server/src/main/java/org/apache/iotdb/db/mpp/statistics/StatisticsManager.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/observer/NodeStatisticsEvent.java (54%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/OperatePipeProcedureRollbackProcessor.java
rename docker/src/main/DockerCompose/{docker-compose-1c1d.yml => docker-compose-standalone.yml} (96%)
rename docker/src/main/{Dockerfile-1.0.0-1c1d => Dockerfile-1.0.0-standalone} (100%)
rename grafana-metrics-example/Apache IoTDB ConfigNode Dashboard.json => docs/UserGuide/Monitor-Alert/Apache-IoTDB-ConfigNode-Dashboard.json (100%)
rename grafana-metrics-example/Apache IoTDB DataNode Dashboard.json => docs/UserGuide/Monitor-Alert/Apache-IoTDB-DataNode-Dashboard.json (100%)
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
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/{MemoryInternalIoTDBReporter.java => IoTDBInternalMemoryReporter.java} (96%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/{InternalIoTDBReporter.java => IoTDBInternalReporter.java} (88%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/{SessionIoTDBReporter.java => IoTDBSessionReporter.java} (87%)
create mode 100644 mlnode/.gitignore
create mode 100644 mlnode/pom.xml
copy confignode/src/main/java/org/apache/iotdb/confignode/exception/ConfigNodeException.java => node-commons/src/main/java/org/apache/iotdb/commons/client/exception/ClientManagerException.java (81%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/path/fa/FAFactory.java
copy server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/read/ShowDevicesPlanImpl.java => node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/DFAState.java (58%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/PatternDFA.java
copy server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/read/ShowDevicesPlanImpl.java => node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/graph/Closure.java (56%)
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
copy server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/read/ShowDevicesPlanImpl.java => node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/transition/AbstractDFATransition.java (58%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusResponse.java => node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/transition/DFAPreciseTransition.java (65%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowContinuousQueriesStatement.java => node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/transition/DFAWildcardTransition.java (50%)
rename node-commons/src/main/java/org/apache/iotdb/commons/path/fa/{ => nfa}/SimpleNFA.java (97%)
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/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
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/exception}/CompactionExceptionHandler.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute}/performer/ICompactionPerformer.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute}/performer/ICrossCompactionPerformer.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute}/performer/ISeqCompactionPerformer.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute}/performer/IUnseqCompactionPerformer.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/performer}/constant/CrossCompactionPerformer.java (81%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/performer}/constant/InnerSeqCompactionPerformer.java (81%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/performer}/constant/InnerUnseqCompactionPerformer.java (81%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute}/performer/impl/FastCompactionPerformer.java (88%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute}/performer/impl/ReadChunkCompactionPerformer.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute}/performer/impl/ReadPointCompactionPerformer.java (88%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/recover}/CompactionRecoverManager.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{task => execute/recover}/CompactionRecoverTask.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute}/task/AbstractCompactionTask.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute}/task/CompactionTaskSummary.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross => execute/task}/CrossSpaceCompactionTask.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner => execute/task}/InnerSpaceCompactionTask.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/rewrite/task => execute/task/subtask}/FastCompactionPerformerSubTask.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/rewrite/task => execute/task/subtask}/ReadPointPerformerSubTask.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{task => execute/task/subtask}/SubCompactionTaskSummary.java (96%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/CompactionUtils.java (96%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner => execute}/utils/MultiTsFileDeviceIterator.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => execute/utils/executor/fast}/AlignedSeriesCompactionExecutor.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => execute/utils/executor/fast}/NonAlignedSeriesCompactionExecutor.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => execute/utils/executor/fast}/SeriesCompactionExecutor.java (96%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => execute/utils/executor/fast/element}/ChunkMetadataElement.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => execute/utils/executor/fast/element}/FileElement.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => execute/utils/executor/fast/element}/PageElement.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => execute/utils/executor/fast/element}/PointElement.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner/utils => execute/utils/executor/readchunk}/AlignedSeriesCompactionExecutor.java (96%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner/utils => execute/utils/executor/readchunk}/SingleSeriesCompactionExecutor.java (96%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/log/CompactionLogAnalyzer.java (83%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/log/CompactionLogger.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/log/TsFileIdentifier.java (99%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/reader/IDataBlockReader.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/reader/PointPriorityReader.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/reader/SeriesDataBlockReader.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/writer/AbstractCompactionWriter.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/writer/AbstractCrossCompactionWriter.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/writer/AbstractInnerCompactionWriter.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/writer/FastCrossCompactionWriter.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/writer/FastInnerCompactionWriter.java (99%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/writer/ReadPointCrossCompactionWriter.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => execute/utils}/writer/ReadPointInnerCompactionWriter.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => schedule}/CompactionScheduler.java (90%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => schedule}/CompactionTaskManager.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => schedule}/CompactionWorker.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => schedule}/comparator/DefaultCompactionTaskComparatorImpl.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => schedule}/comparator/ICompactionTaskComparator.java (79%)
copy server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => schedule}/constant/CompactionPriority.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => schedule}/constant/CompactionTaskStatus.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => schedule}/constant/CompactionType.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => schedule}/constant/ProcessChunkType.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{task => selector}/ICompactionSelector.java (81%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross => selector}/ICrossSpaceSelector.java (80%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner => selector}/IInnerSeqSpaceSelector.java (89%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner => selector}/IInnerUnseqSpaceSelector.java (89%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => selector}/constant/CrossCompactionSelector.java (88%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => selector}/constant/InnerSequenceCompactionSelector.java (87%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => selector}/constant/InnerUnsequenceCompactionSelector.java (87%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => selector/estimator}/AbstractCompactionEstimator.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross => selector/estimator}/AbstractCrossSpaceEstimator.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner => selector/estimator}/AbstractInnerSpaceEstimator.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => selector/estimator}/IFileQueryMemMeasurement.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => selector/estimator}/InplaceCompactionEstimator.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils => selector/estimator}/ReadPointCrossCompactionEstimator.java (98%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/selector/impl/RewriteCrossSpaceCompactionSelector.java
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner/sizetiered => selector/impl}/SizeTieredCompactionSelector.java (92%)
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/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
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/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
rename server/src/main/java/org/apache/iotdb/db/{engine/compaction/constant/CompactionPriority.java => metadata/query/info/IDeviceSchemaInfo.java} (86%)
copy server/src/main/java/org/apache/iotdb/db/metadata/{plan/schemaregion/read/IShowDevicesPlan.java => query/info/ISchemaInfo.java} (81%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/type/Counter.java => server/src/main/java/org/apache/iotdb/db/metadata/query/info/ITimeSeriesSchemaInfo.java (71%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/FileInputFactory.java => server/src/main/java/org/apache/iotdb/db/metadata/query/reader/ISchemaReader.java (77%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{plan/constant => common}/DataNodeEndPoints.java (93%)
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
copy server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/{SchemaTreeVisitor.java => SchemaTreeVisitorFactory.java} (51%)
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
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/Reporter.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractProcessOperator.java (74%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{DevicesCountOperator.java => SchemaCountOperator.java} (63%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MetricLevel.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AbstractDataSourceOperator.java (67%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/planner/plan/node/process/ProcessNode.java => execution/operator/source/AbstractSourceOperator.java} (72%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/ShowQueriesOperator.java
copy server/src/main/java/org/apache/iotdb/db/{engine/cache => mpp/metric}/ChunkCacheMetrics.java (94%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/DataExchangeMetricSet.java
copy server/src/main/java/org/apache/iotdb/db/{engine/cache/TimeSeriesMetadataCacheMetrics.java => mpp/metric/DriverSchedulerMetricSet.java} (52%)
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
copy server/src/main/java/org/apache/iotdb/db/{engine/cache/ChunkCacheMetrics.java => mpp/metric/QueryPlanCostMetricSet.java} (54%)
rename server/src/main/java/org/apache/iotdb/db/{engine/cache/ChunkCacheMetrics.java => mpp/metric/QueryResourceMetricSet.java} (58%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/SeriesScanCostMetricSet.java
rename server/src/main/java/org/apache/iotdb/db/{engine/cache => mpp/metric}/TimeSeriesMetadataCacheMetrics.java (94%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.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
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/{ => schema}/ISchemaFetcher.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/{ => schema}/SchemaValidator.java (98%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/constant/FilterConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowVariablesTask.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
rename server/src/main/java/org/apache/iotdb/db/{qp/strategy/SQLParseError.java => mpp/plan/parser/SqlParseError.java} (93%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/{process/last/LastQueryCollectNode.java => source/ShowQueriesNode.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/{sink/SinkNode.java => source/VirtualSourceNode.java} (63%)
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
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/{constant => statement}/StatementType.java (98%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{UnSetTTLStatement.java => ShowVariablesStatement.java} (75%)
rename server/src/main/java/org/apache/iotdb/db/protocol/influxdb/constant/{InfluxSQLConstant.java => InfluxSqlConstant.java} (92%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/operator/InfluxQueryOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/parser/InfluxDBAstVisitor.java
rename server/src/main/java/org/apache/iotdb/db/protocol/influxdb/{sql/InfluxDBLogicalGenerator.java => parser/InfluxDBStatementGenerator.java} (76%)
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
rename server/src/main/java/org/apache/iotdb/db/protocol/influxdb/{operator => statement}/InfluxSelectComponent.java (83%)
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/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
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{IoTDBInternalReporter.java => IoTDBInternalLocalReporter.java} (83%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/AlignedValueIterator.java
rename server/src/main/java/org/apache/iotdb/db/{qp => }/utils/DateTimeUtils.java (99%)
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
rename server/src/main/java/org/apache/iotdb/db/utils/{QueryUtils.java => ModificationUtils.java} (84%)
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
rename server/src/{main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/EntityCounter.java => test/java/org/apache/iotdb/db/mpp/common/schematree/ClusterSchemaTreeTestWithRelease.java} (53%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/MockSchemaTreeMeasurementVisitor.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 thrift-mlnode/pom.xml
create mode 100644 thrift-mlnode/src/main/thrift/mlnode.thrift