This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch ml/thrift in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 001495757e6833246be5487a8d208e7cb6d9c5ef Merge: f5de3e52b4 0e1dd1b8a2 Author: Minghui Liu <[email protected]> AuthorDate: Sat Dec 24 15:48:13 2022 +0800 Merge remote-tracking branch 'origin/master' into ml/thrift .github/workflows/main-unix.yml | 2 +- .github/workflows/main-win.yml | 2 +- .gitignore | 3 + Jenkinsfile | 2 +- README.md | 48 +- README_ZH.md | 52 +- .../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 6 +- .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 18 +- .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 20 +- cli/src/assembly/resources/sbin/start-cli.bat | 2 +- cli/src/assembly/resources/sbin/start-cli.sh | 2 - cli/src/assembly/resources/tools/export-csv.bat | 2 +- cli/src/assembly/resources/tools/export-csv.sh | 1 - cli/src/assembly/resources/tools/export-tsfile.bat | 2 +- cli/src/assembly/resources/tools/export-tsfile.sh | 1 - cli/src/assembly/resources/tools/import-csv.bat | 2 +- cli/src/assembly/resources/tools/import-csv.sh | 1 - .../org/apache/iotdb/tool/AbstractCsvTool.java | 3 + .../org/apache/iotdb/tool/AbstractTsFileTool.java | 2 + .../main/java/org/apache/iotdb/tool/ExportCsv.java | 18 +- .../java/org/apache/iotdb/tool/ExportTsFile.java | 24 +- .../main/java/org/apache/iotdb/tool/ImportCsv.java | 2 +- client-py/iotdb/Session.py | 26 +- client-py/iotdb/utils/IoTDBRpcDataSet.py | 2 +- client-py/tests/test_delete_data.py | 162 ++ .../assembly/resources/sbin/start-confignode.bat | 55 +- .../assembly/resources/sbin/start-confignode.sh | 22 +- .../assembly/resources/sbin/stop-confignode.bat | 5 +- .../src/assembly/resources/sbin/stop-confignode.sh | 19 +- .../confignode/client/ConfigNodeRequestType.java | 1 + .../client/sync/SyncConfigNodeClientPool.java | 3 + .../iotdb/confignode/conf/ConfigNodeConfig.java | 15 +- .../confignode/conf/ConfigNodeDescriptor.java | 2 + .../confignode/conf/SystemPropertiesUtils.java | 49 +- .../consensus/response/ConfigurationResp.java | 66 + .../consensus/response/DataNodeRegisterResp.java | 67 +- .../iotdb/confignode/manager/ConfigManager.java | 149 +- .../iotdb/confignode/manager/ConsensusManager.java | 4 +- .../apache/iotdb/confignode/manager/IManager.java | 23 + .../manager/node/ClusterNodeStartUtils.java | 380 +++ .../iotdb/confignode/manager/node/NodeManager.java | 159 +- .../persistence/executor/ConfigPlanExecutor.java | 9 +- .../confignode/persistence/node/NodeInfo.java | 27 - .../iotdb/confignode/service/ConfigNode.java | 74 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 50 +- .../request/ConfigPhysicalPlanSerDeTest.java | 7 +- .../persistence/ClusterSchemaInfoTest.java | 26 +- .../confignode/persistence/TemplateTableTest.java | 46 +- .../iotdb/consensus/config/IoTConsensusConfig.java | 55 +- .../apache/iotdb/consensus/config/RatisConfig.java | 45 +- .../exception/RatisRequestFailedException.java | 7 +- .../apache/iotdb/consensus/iot/IoTConsensus.java | 6 +- .../consensus/iot/IoTConsensusServerImpl.java | 27 +- .../consensus/iot/client/DispatchLogHandler.java | 20 +- .../iot/client/IoTConsensusClientPool.java | 7 +- .../{PendingBatch.java => Batch.java} | 32 +- .../iot/logdispatcher/IndexController.java | 43 +- .../consensus/iot/logdispatcher/LogDispatcher.java | 91 +- .../logdispatcher/LogDispatcherThreadMetrics.java | 2 +- .../consensus/iot/logdispatcher/SyncStatus.java | 18 +- .../iot/service/IoTConsensusRPCService.java | 2 +- .../service/IoTConsensusRPCServiceProcessor.java | 41 +- .../apache/iotdb/consensus/ratis/RatisClient.java | 6 +- .../iotdb/consensus/ratis/RatisConsensus.java | 10 +- .../{IoTConsensusTest.java => ReplicateTest.java} | 4 +- .../iot/{RecoveryTest.java => StabilityTest.java} | 46 +- .../iot/logdispatcher/IndexControllerTest.java | 37 +- .../iot/logdispatcher/SyncStatusTest.java | 136 +- .../iotdb/consensus/iot/util/TestStateMachine.java | 2 +- .../iotdb/consensus/ratis/RatisConsensusTest.java | 23 +- cross-tests/pom.xml | 125 - .../tests/tools/importCsv/ExportCsvTestIT.java | 148 -- .../tests/tools/importCsv/ImportCsvTestIT.java | 432 ---- .../tests/tools/tsfile/ExportTsFileTestIT.java | 124 - docker/ReadMe.md | 30 +- docker/src/main/DockerCompose/do-docker-build.sh | 167 ++ .../src/main/DockerCompose/docker-compose-1c1d.yml | 26 +- .../DockerCompose/docker-compose-cluster-1c2d.yml | 69 + .../DockerCompose/docker-compose-cluster-3c3d.yml | 60 + .../DockerCompose/docker-compose-host-3c3d.yml | 58 + .../src/main/DockerCompose/entrypoint.sh | 54 +- .../main/DockerCompose/replace-conf-from-env.sh | 64 + .../src/main/Dockerfile-1.0.0-1c1d | 56 +- docker/src/main/Dockerfile-1.0.0-confignode | 52 + docker/src/main/Dockerfile-1.0.0-datanode | 54 + docs/Development/ContributeGuide.md | 28 +- docs/UserGuide/Cluster/Cluster-Setup.md | 545 ++-- docs/UserGuide/FAQ/FAQ-for-cluster-setup.md | 99 + docs/UserGuide/Maintenance-Tools/CSV-Tool.md | 6 + .../Maintenance-Tools/TsFile-Load-Export-Tool.md | 100 +- docs/UserGuide/Monitor-Alert/Metric-Tool.md | 386 +-- docs/UserGuide/Query-Data/Align-By.md | 7 +- docs/UserGuide/Query-Data/Order-By.md | 111 +- docs/UserGuide/Query-Data/Overview.md | 3 +- docs/UserGuide/QuickStart/ClusterQuickStart.md | 183 ++ docs/UserGuide/QuickStart/WayToGetIoTDB.md | 176 +- docs/UserGuide/Reference/Common-Config-Manual.md | 16 +- docs/UserGuide/Write-Data/Write-Data.md | 2 +- docs/zh/Development/ContributeGuide.md | 11 - docs/zh/UserGuide/Cluster/Cluster-Setup.md | 534 ++-- docs/zh/UserGuide/FAQ/FAQ-for-cluster-setup.md | 99 + docs/zh/UserGuide/Maintenance-Tools/CSV-Tool.md | 6 + .../Maintenance-Tools/TsFile-Load-Export-Tool.md | 98 +- docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 325 +-- docs/zh/UserGuide/Query-Data/Align-By.md | 4 + docs/zh/UserGuide/Query-Data/Order-By.md | 109 +- docs/zh/UserGuide/Query-Data/Overview.md | 7 +- docs/zh/UserGuide/QuickStart/ClusterQuickStart.md | 180 ++ docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 183 +- .../zh/UserGuide/Reference/Common-Config-Manual.md | 16 +- docs/zh/UserGuide/Write-Data/Write-Data.md | 2 +- .../iotdb/AlignedTimeseriesSessionExample.java | 4 +- .../org/apache/iotdb/DataMigrationExample.java | 4 +- .../iotdb/HybridTimeseriesSessionExample.java | 2 +- .../org/apache/iotdb/SessionConcurrentExample.java | 2 +- .../main/java/org/apache/iotdb/SessionExample.java | 8 +- .../java/org/apache/iotdb/SessionPoolExample.java | 4 +- .../iotdb/SyntaxConventionRelatedExample.java | 4 +- .../apache/iotdb/trigger/old/TriggerExample.java | 147 -- .../java/org/apache/iotdb/flink/IoTDBSource.java | 2 +- grafana-plugin/backend-compile.sh | 4 +- .../iotdb/influxdb/session/InfluxDBSession.java | 2 +- integration-test/import-control.xml | 14 + integration-test/pom.xml | 55 +- .../java/org/apache/iotdb/it/env/AbstractEnv.java | 101 +- .../apache/iotdb/it/env/AbstractNodeWrapper.java | 6 +- .../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 11 +- .../org/apache/iotdb/it/env/DataNodeWrapper.java | 5 + .../java/org/apache/iotdb/it/env/MppConfig.java | 9 +- .../org/apache/iotdb/it/env/RemoteServerEnv.java | 59 +- .../org/apache/iotdb/itbase/env/BaseConfig.java | 10 +- .../java/org/apache/iotdb/itbase/env/BaseEnv.java | 40 +- .../org/apache/iotdb/cli/it}/AbstractScript.java | 86 +- .../apache/iotdb/cli/it}/StartClientScriptIT.java | 71 +- .../confignode/it/IoTDBClusterAuthorityIT.java | 62 +- .../confignode/it/IoTDBConfigNodeSnapshotIT.java | 7 +- .../confignode/it/IoTDBSnapshotTransferIT.java | 152 ++ .../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 305 +++ .../IoTDBClusterNodeGetterIT.java} | 15 +- .../it/{ => cluster}/IoTDBClusterRestartIT.java | 2 +- .../IoTDBClusterRegionLeaderBalancingIT.java | 29 +- .../{ => load}/IoTDBConfigNodeSwitchLeaderIT.java | 2 +- .../it/partition/IoTDBPartitionDurableIT.java | 4 +- .../confignode/it/utils/ConfigNodeTestUtils.java | 82 + .../IoTDBOrderByWithAlignByDeviceIT.java | 90 +- .../org/apache/iotdb/db/it/env/StandaloneEnv.java | 63 +- .../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 6 +- .../iotdb/db/it/query/IoTDBNullOperandIT.java | 3 +- .../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 14 + .../org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java | 45 +- .../apache/iotdb/libudf/it/anomaly/AnomalyIT.java | 783 +++--- .../apache/iotdb/libudf/it/dmatch/DMatchIT.java | 533 ++-- .../iotdb/libudf/it/dprofile/DProfileIT.java | 298 +-- .../iotdb/libudf/it/dquality/DQualityIT.java | 203 +- .../apache/iotdb/libudf/it/drepair/DRepairIT.java | 160 +- .../iotdb/libudf/it/frequency/FrequencyIT.java | 180 +- .../apache/iotdb/libudf/it/series/SeriesIT.java | 319 +-- .../apache/iotdb/libudf/it/string/StringIT.java | 124 +- .../iotdb/session/it/IoTDBConnectionInfoIT.java | 2 +- .../session/it/IoTDBSessionAlignedInsertIT.java | 4 +- .../iotdb/session/it/IoTDBSessionComplexIT.java | 4 +- .../it/IoTDBSessionDisableMemControlIT.java | 4 +- .../iotdb/session/it/IoTDBSessionInsertNullIT.java | 4 +- .../IoTDBSessionInsertWithTriggerExecutionIT.java | 2 +- .../session/it/IoTDBSessionSchemaTemplateIT.java | 6 +- .../iotdb/session/it/IoTDBSessionSimpleIT.java | 4 +- .../session/it/IoTDBSessionSyntaxConventionIT.java | 4 +- .../org/apache/iotdb/session/it/SessionIT.java | 4 +- .../iotdb/session/it/pool/SessionPoolIT.java | 6 +- .../org/apache/iotdb/tools/ExportCsvTestIT.java | 198 ++ .../org/apache/iotdb/tools/ExportTsFileTestIT.java | 198 ++ .../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 127 +- .../src/test/resources/logback-test.xml | 2 +- .../iotdb/db/integration/IoTDBAuthorizationIT.java | 1127 --------- .../iotdb/db/integration/IoTDBCheckConfigIT.java | 12 +- .../db/integration/IoTDBEngineTimeGeneratorIT.java | 291 --- .../iotdb/db/integration/IoTDBSelectIntoIT.java | 787 ------ .../db/integration/IoTDBSequenceDataQueryIT.java | 329 --- .../iotdb/db/integration/IoTDBSeriesReaderIT.java | 444 ---- .../aggregation/IoTDBUDFNestAggregationIT.java | 774 ------ .../IoTDBUserDefinedAggregationFunctionIT.java | 732 ------ .../db/integration/aligned/AlignedWriteUtil.java | 149 -- .../db/integration/aligned/IoTDBEmptyDataIT.java | 78 - .../aligned/IoTDBGroupByFillQueryBigDataIT.java | 192 -- .../aligned/IoTDBGroupByFillQueryIT.java | 989 -------- .../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 1037 -------- .../aligned/IoTDBRawQueryWithValueFilter2IT.java | 65 - .../aligned/IoTDBRawQueryWithValueFilterIT.java | 763 ------ ...oTDBRawQueryWithValueFilterWithDeletion2IT.java | 82 - ...IoTDBRawQueryWithValueFilterWithDeletionIT.java | 778 ------ .../db/integration/groupby/IoTDBGroupByFillIT.java | 2657 -------------------- .../groupby/IoTDBGroupByFillMixPathsIT.java | 479 ---- .../groupby/IoTDBGroupByFillWithRangeIT.java | 179 -- .../groupby/IoTDBGroupByNaturalMonthFillIT.java | 273 -- .../session/IoTDBSessionAlignedABDeviceIT.java | 1 + .../session/IoTDBSessionAlignedAggregationIT.java | 1 + .../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 1 + .../iotdb/session/IoTDBSessionIteratorIT.java | 3 +- integration/src/test/resources/logback-test.xml | 2 +- .../Query-Data/Order-By.md => isession/pom.xml | 25 +- .../java/org/apache/iotdb/isession}/ISession.java | 54 +- .../org/apache/iotdb/isession}/SessionConfig.java | 4 +- .../org/apache/iotdb/isession}/SessionDataSet.java | 2 +- .../apache/iotdb/isession/pool/ISessionPool.java | 386 +-- .../isession}/pool/SessionDataSetWrapper.java | 29 +- .../apache/iotdb/isession}/template/Template.java | 2 +- .../iotdb/isession}/template/TemplateNode.java | 2 +- .../apache/iotdb/isession/util/SystemStatus.java | 18 +- .../org/apache/iotdb/isession}/util/Version.java | 2 +- .../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 42 - .../java/org/apache/iotdb/jdbc/ListDataSet.java | 53 - library-udf/pom.xml | 50 +- library-udf/src/assembly/tools/register-UDF.bat | 1 - library-udf/src/assembly/tools/register-UDF.sh | 1 - .../metrics/config/MetricConfigDescriptor.java | 16 +- .../reporter/iotdb/InternalIoTDBReporter.java | 2 +- .../iotdb/MemoryInternalIoTDBReporter.java | 4 +- .../reporter/iotdb/SessionIoTDBReporter.java | 48 +- .../reporter/prometheus/PrometheusReporter.java | 33 +- .../iotdb/metrics/config/MetricConfigTest.java | 28 +- .../micrometer/reporter/MicrometerJmxReporter.java | 6 +- .../resources/conf/iotdb-common.properties | 15 +- .../src/assembly/resources/sbin/iotdb-common.sh | 137 + .../org/apache/iotdb/commons/cluster/NodeType.java | 31 +- .../apache/iotdb/commons/conf/IoTDBConstant.java | 2 + .../iotdb/commons/partition/ExecutorType.java | 4 - .../iotdb/commons/partition/StorageExecutor.java | 11 +- .../apache/iotdb/commons/path/PathPatternTree.java | 4 + .../org/apache/iotdb/commons/path/fa/IFAState.java | 21 +- .../iotdb/commons/path/fa/IFATransition.java | 24 +- .../apache/iotdb/commons/path/fa/IPatternFA.java | 75 + .../apache/iotdb/commons/path/fa/SimpleNFA.java | 522 ++++ .../commons/path/fa/match/IStateMatchInfo.java | 79 + .../commons/path/fa/match/MatchedStateSet.java | 68 + .../commons/path/fa/match/StateMultiMatchInfo.java | 120 + .../path/fa/match/StateSingleMatchInfo.java | 103 + .../commons/schema/tree/AbstractTreeVisitor.java | 804 +++--- .../commons/service/metric/MetricService.java | 7 +- .../iotdb/commons/service/metric/enums/Metric.java | 3 +- .../iotdb/commons/service/metric/enums/Tag.java | 3 +- .../apache/iotdb/commons/udf/builtin/UDTFM4.java | 272 +- .../iotdb/commons/path/PathPatternTreeTest.java | 5 +- pom.xml | 4 +- .../schemaregion/rocksdb/RSchemaRegion.java | 153 +- .../schemaregion/rocksdb/mnode/RMNode.java | 5 + .../rocksdb/RSchemaRegionAdvancedTest.java | 169 -- .../metadata/rocksdb/RocksDBBenchmarkEngine.java | 153 -- .../schemaregion}/rocksdb/MRocksDBBenchmark.java | 8 +- .../schemaregion}/rocksdb/MRocksDBUnitTest.java | 42 +- .../rocksdb/RSchemaReadWriteHandlerTest.java | 6 +- .../rocksdb/RocksDBBenchmarkEngine.java | 144 ++ .../rocksdb/RocksDBBenchmarkTask.java | 0 .../schemaregion}/rocksdb/RocksDBTestUtils.java | 4 +- .../metadata/tagSchemaRegion/TagSchemaRegion.java | 166 +- .../utils/ShowTimeSeriesResultUtils.java | 4 +- .../tagSchemaRegion/TagSchemaRegionTest.java | 18 +- .../idtable/IDTableWithDeviceIDListImplTest.java | 17 +- .../src/assembly/resources/sbin/start-datanode.bat | 103 +- .../src/assembly/resources/sbin/start-datanode.sh | 20 +- .../src/assembly/resources/sbin/stop-datanode.bat | 8 +- .../src/assembly/resources/sbin/stop-datanode.sh | 16 +- .../org/apache/iotdb/db/auth/AuthorityChecker.java | 131 - .../apache/iotdb/db/auth/AuthorizerManager.java | 7 +- .../iotdb/db/auth/ClusterAuthorityFetcher.java | 10 +- .../iotdb/db/auth/StandaloneAuthorityFetcher.java | 125 - .../apache/iotdb/db/client/ConfigNodeClient.java | 75 +- .../ConfigNodeClientManager.java} | 32 +- .../org/apache/iotdb/db/client/ConfigNodeInfo.java | 6 +- .../iotdb/db/client/DataNodeInternalClient.java | 19 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 54 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 26 +- .../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 61 +- .../db/conf/directories/DirectoryChecker.java | 27 + .../db/consensus/DataRegionConsensusImpl.java | 4 +- .../db/consensus/SchemaRegionConsensusImpl.java | 2 +- .../iotdb/db/engine/TsFileMetricManager.java | 54 +- .../engine/compaction/CompactionTaskManager.java | 43 +- .../db/engine/compaction/CompactionUtils.java | 22 +- .../utils/AlignedSeriesCompactionExecutor.java | 8 + .../utils/NonAlignedSeriesCompactionExecutor.java | 2 + .../utils/AlignedSeriesCompactionExecutor.java | 15 +- .../utils/SingleSeriesCompactionExecutor.java | 12 +- .../performer/impl/FastCompactionPerformer.java | 16 +- .../impl/ReadChunkCompactionPerformer.java | 11 + .../impl/ReadPointCompactionPerformer.java | 19 + .../writer/AbstractCompactionWriter.java | 14 +- .../writer/AbstractCrossCompactionWriter.java | 9 + .../writer/AbstractInnerCompactionWriter.java | 5 + .../iotdb/db/engine/flush/MemTableFlushTask.java | 23 +- .../iotdb/db/engine/storagegroup/DataRegion.java | 66 +- .../db/engine/storagegroup/TsFileProcessor.java | 2 - .../trigger/sink/local/LocalIoTDBHandler.java | 94 - .../iotdb/db/localconfignode/LocalConfigNode.java | 9 +- .../db/localconfignode/LocalDataPartitionInfo.java | 1 + .../localconfignode/LocalDataPartitionTable.java | 1 + .../localconfignode/LocalSchemaPartitionTable.java | 1 + .../iotdb/db/metadata/LocalSchemaProcessor.java | 601 +---- .../db/metadata/cache/DataNodeSchemaCache.java | 7 +- .../iotdb/db/metadata/idtable/IDTableManager.java | 27 +- .../idtable/entry/InsertMeasurementMNode.java | 5 + .../iotdb/db/metadata/logfile/MLogReader.java | 75 - .../iotdb/db/metadata/logfile/MLogWriter.java | 254 -- .../org/apache/iotdb/db/metadata/mnode/IMNode.java | 4 + .../iotdb/db/metadata/mnode/InternalMNode.java | 5 + .../iotdb/db/metadata/mnode/MeasurementMNode.java | 10 +- .../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 68 +- .../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 220 +- .../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 181 +- .../mtree/snapshot/MemMTreeSnapshotUtil.java | 4 +- .../mtree/store/disk/schemafile/RecordUtils.java | 2 +- .../mtree/store/disk/schemafile/SchemaFile.java | 23 +- .../traverser/collector/MeasurementCollector.java | 7 + .../plan/schemaregion/SchemaRegionPlanType.java | 7 +- .../impl/SchemaRegionPlanDeserializer.java | 3 +- .../impl/read/AbstractShowSchemaPlanImpl.java | 83 + .../impl/read/SchemaRegionReadPlanFactory.java | 75 + .../impl/read/ShowDevicesPlanImpl.java} | 55 +- .../impl/read/ShowTimeSeriesPlanImpl.java | 91 + .../ActivateTemplateInClusterPlanImpl.java | 6 +- .../{ => write}/AutoCreateDeviceMNodePlanImpl.java | 6 +- .../impl/{ => write}/ChangeAliasPlanImpl.java | 6 +- .../impl/{ => write}/ChangeTagOffsetPlanImpl.java | 6 +- .../CreateAlignedTimeSeriesPlanImpl.java | 6 +- .../impl/{ => write}/CreateTimeSeriesPlanImpl.java | 6 +- .../{ => write}/DeactivateTemplatePlanImpl.java | 6 +- .../impl/{ => write}/DeleteTimeSeriesPlanImpl.java | 6 +- .../{ => write}/PreDeactivateTemplatePlanImpl.java | 6 +- .../{ => write}/PreDeleteTimeSeriesPlanImpl.java | 6 +- .../RollbackPreDeactivateTemplatePlanImpl.java | 6 +- .../RollbackPreDeleteTimeSeriesPlanImpl.java | 6 +- .../SchemaRegionWritePlanFactory.java} | 12 +- .../plan/schemaregion/read/IShowDevicesPlan.java} | 9 +- .../IShowSchemaPlan.java} | 33 +- .../schemaregion/read/IShowTimeSeriesPlan.java} | 18 +- .../schemaregion/result}/ShowDevicesResult.java | 33 +- .../schemaregion/result/ShowSchemaResult.java} | 32 +- .../schemaregion/result/ShowTimeSeriesResult.java | 114 + .../db/metadata/rescon/SchemaResourceManager.java | 4 +- ...rics.java => SchemaResourceManagerMetrics.java} | 41 +- .../db/metadata/schemaregion/ISchemaRegion.java | 162 +- .../schemaregion/SchemaRegionMemoryImpl.java | 388 +-- .../schemaregion/SchemaRegionSchemaFileImpl.java | 338 +-- .../storagegroup/StorageGroupLogWriter.java | 56 - .../storagegroup/StorageGroupSchemaManager.java | 126 +- .../apache/iotdb/db/metadata/tag/TagManager.java | 17 +- .../metadata/template/ClusterTemplateManager.java | 9 +- .../iotdb/db/metadata/template/Template.java | 317 +-- .../apache/iotdb/db/metadata/utils/MetaUtils.java | 35 +- .../db/metadata/utils/ResourceByPathUtils.java | 34 - .../metadata/visitor/SchemaExecutionVisitor.java | 8 +- .../db/mpp/aggregation/AccumulatorFactory.java | 2 +- .../SlidingWindowAggregatorFactory.java | 2 +- .../db/mpp/common/header/ColumnHeaderConstant.java | 18 +- .../db/mpp/common/header/DatasetHeaderFactory.java | 4 + .../mpp/common/schematree/ClusterSchemaTree.java | 1 - .../common/schematree/DeviceGroupSchemaTree.java | 5 - .../db/mpp/common/schematree/ISchemaTree.java | 2 - .../visitor/SchemaTreeDeviceVisitor.java | 2 +- .../visitor/SchemaTreeMeasurementVisitor.java | 76 +- .../schematree/visitor/SchemaTreeVisitor.java | 5 - .../iotdb/db/mpp/execution/driver/Driver.java | 31 +- .../exchange/IMPPDataExchangeManager.java | 2 + .../db/mpp/execution/exchange/ISinkHandle.java | 3 + .../db/mpp/execution/exchange/ISourceHandle.java | 3 + .../db/mpp/execution/exchange/LocalSinkHandle.java | 11 +- .../mpp/execution/exchange/LocalSourceHandle.java | 5 + .../execution/exchange/MPPDataExchangeManager.java | 21 +- .../mpp/execution/exchange/SharedTsBlockQueue.java | 59 +- .../db/mpp/execution/exchange/SinkHandle.java | 50 +- .../db/mpp/execution/exchange/SourceHandle.java | 62 +- .../execution/executor/RegionWriteExecutor.java | 2 +- .../mpp/execution/memory/LocalMemoryManager.java | 2 +- .../iotdb/db/mpp/execution/memory/MemoryPool.java | 218 +- .../operator/process/AbstractIntoOperator.java | 11 +- .../process/last/LastQuerySortOperator.java | 56 +- .../operator/schema/DevicesSchemaScanOperator.java | 17 +- .../schema/TimeSeriesSchemaScanOperator.java | 22 +- .../org/apache/iotdb/db/mpp/plan/Coordinator.java | 2 +- .../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 20 +- .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 289 ++- .../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 12 +- .../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 599 ----- .../db/mpp/plan/analyze/ExpressionAnalyzer.java | 70 + .../plan/analyze/StandalonePartitionFetcher.java | 252 -- .../mpp/plan/analyze/StandaloneSchemaFetcher.java | 227 -- .../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 | 8 +- .../db/mpp/plan/execution/QueryExecution.java | 29 +- .../mpp/plan/execution/config/ConfigExecution.java | 7 +- .../executor/StandaloneConfigTaskExecutor.java | 728 ------ .../plan/execution/memory/MemorySourceHandle.java | 3 + .../iotdb/db/mpp/plan/expression/Expression.java | 27 - .../iotdb/db/mpp/plan/expression/ResultColumn.java | 61 - .../plan/expression/binary/BinaryExpression.java | 96 - .../mpp/plan/expression/leaf/ConstantOperand.java | 26 - .../db/mpp/plan/expression/leaf/NullOperand.java | 27 - .../plan/expression/leaf/TimeSeriesOperand.java | 31 - .../mpp/plan/expression/leaf/TimestampOperand.java | 27 - .../plan/expression/multi/FunctionExpression.java | 49 - .../plan/expression/ternary/TernaryExpression.java | 50 - .../mpp/plan/expression/unary/UnaryExpression.java | 37 - .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 92 +- .../db/mpp/plan/planner/LocalExecutionPlanner.java | 30 + .../db/mpp/plan/planner/LogicalPlanBuilder.java | 8 +- .../db/mpp/plan/planner/LogicalPlanVisitor.java | 9 + .../plan/planner/MemoryDistributionCalculator.java | 465 ++++ .../db/mpp/plan/planner/OperatorTreeGenerator.java | 6 +- .../planner/distribution/ExchangeNodeAdder.java | 6 +- .../distribution/WriteFragmentParallelPlanner.java | 4 +- .../plan/node/process/SingleDeviceViewNode.java | 59 +- .../plan/parameter/AggregationDescriptor.java | 1 - .../planner/plan/parameter}/AggregationType.java | 2 +- .../db/mpp/plan/scheduler/StandaloneScheduler.java | 222 -- .../iotdb/db/mpp/plan/statement/AuthorType.java | 122 + .../db/mpp/plan/statement/StatementVisitor.java | 5 + .../db/mpp/plan/statement/component/SortKey.java | 6 +- .../db/mpp/plan/statement/crud/QueryStatement.java | 15 +- .../db/mpp/plan/statement/sys/AuthorStatement.java | 12 +- .../plan/statement/sys/ShowQueriesStatement.java | 74 + .../mpp/transformation/dag/builder/DAGBuilder.java | 116 - .../dag/input/QueryDataSetInputLayer.java | 41 - .../protocol/influxdb/util/QueryResultUtils.java | 90 - .../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 33 +- .../org/apache/iotdb/db/protocol/mqtt/Message.java | 11 + .../protocol/rest/impl/GrafanaApiServiceImpl.java | 15 +- .../db/protocol/rest/impl/RestApiServiceImpl.java | 15 +- .../main/java/org/apache/iotdb/db/qp/Planner.java | 154 -- .../apache/iotdb/db/qp/executor/IPlanExecutor.java | 55 - .../apache/iotdb/db/qp/executor/PlanExecutor.java | 946 ------- .../org/apache/iotdb/db/qp/logical/Operator.java | 13 - .../qp/logical/crud/AggregationQueryOperator.java | 155 -- .../db/qp/logical/crud/DeleteDataOperator.java | 73 - .../db/qp/logical/crud/FillClauseComponent.java | 49 - .../db/qp/logical/crud/FillQueryOperator.java | 92 - .../db/qp/logical/crud/GroupByClauseComponent.java | 92 - .../logical/crud/GroupByFillClauseComponent.java | 49 - .../qp/logical/crud/GroupByFillQueryOperator.java | 80 - .../db/qp/logical/crud/GroupByQueryOperator.java | 111 - .../iotdb/db/qp/logical/crud/InOperator.java | 212 -- .../iotdb/db/qp/logical/crud/InsertOperator.java | 90 - .../db/qp/logical/crud/LastQueryOperator.java | 64 - .../iotdb/db/qp/logical/crud/LikeOperator.java | 134 - .../iotdb/db/qp/logical/crud/QueryOperator.java | 421 ---- .../iotdb/db/qp/logical/crud/RegexpOperator.java | 133 - .../db/qp/logical/crud/SelectIntoOperator.java | 133 - .../db/qp/logical/crud/UDAFQueryOperator.java | 179 -- .../db/qp/logical/crud/UDTFQueryOperator.java | 48 - .../qp/logical/sys/ActivateTemplateOperator.java | 51 - .../db/qp/logical/sys/AlterTimeSeriesOperator.java | 116 - .../iotdb/db/qp/logical/sys/AuthorOperator.java | 233 -- .../db/qp/logical/sys/ClearCacheOperator.java | 39 - .../iotdb/db/qp/logical/sys/CountOperator.java | 73 - .../sys/CreateAlignedTimeSeriesOperator.java | 184 -- .../logical/sys/CreateContinuousQueryOperator.java | 108 - .../db/qp/logical/sys/CreateFunctionOperator.java | 59 - .../db/qp/logical/sys/CreateIndexOperator.java | 84 - .../db/qp/logical/sys/CreatePipeOperator.java | 61 - .../db/qp/logical/sys/CreatePipeSinkOperator.java | 54 - .../db/qp/logical/sys/CreateTemplateOperator.java | 108 - .../qp/logical/sys/CreateTimeSeriesOperator.java | 127 - .../iotdb/db/qp/logical/sys/DataAuthOperator.java | 51 - .../db/qp/logical/sys/DeletePartitionOperator.java | 61 - .../qp/logical/sys/DeleteStorageGroupOperator.java | 50 - .../qp/logical/sys/DeleteTimeSeriesOperator.java | 51 - .../logical/sys/DropContinuousQueryOperator.java | 50 - .../db/qp/logical/sys/DropFunctionOperator.java | 50 - .../iotdb/db/qp/logical/sys/DropIndexOperator.java | 65 - .../iotdb/db/qp/logical/sys/DropPipeOperator.java | 44 - .../db/qp/logical/sys/DropPipeSinkOperator.java | 43 - .../db/qp/logical/sys/DropTemplateOperator.java | 49 - .../iotdb/db/qp/logical/sys/FlushOperator.java | 62 - .../iotdb/db/qp/logical/sys/KillQueryOperator.java | 52 - .../qp/logical/sys/LoadConfigurationOperator.java | 52 - .../iotdb/db/qp/logical/sys/LoadDataOperator.java | 54 - .../iotdb/db/qp/logical/sys/LoadFilesOperator.java | 92 - .../iotdb/db/qp/logical/sys/MergeOperator.java | 44 - .../db/qp/logical/sys/RemoveFileOperator.java | 49 - .../db/qp/logical/sys/SetStorageGroupOperator.java | 48 - .../db/qp/logical/sys/SetSystemModeOperator.java | 54 - .../iotdb/db/qp/logical/sys/SetTTLOperator.java | 61 - .../db/qp/logical/sys/SetTemplateOperator.java | 65 - .../iotdb/db/qp/logical/sys/SettleOperator.java | 71 - .../db/qp/logical/sys/ShowChildNodesOperator.java | 47 - .../db/qp/logical/sys/ShowChildPathsOperator.java | 47 - .../logical/sys/ShowContinuousQueriesOperator.java | 28 - .../db/qp/logical/sys/ShowDevicesOperator.java | 73 - .../db/qp/logical/sys/ShowFunctionsOperator.java | 38 - .../logical/sys/ShowNodesInTemplateOperator.java | 43 - .../iotdb/db/qp/logical/sys/ShowOperator.java | 64 - .../logical/sys/ShowPathsSetTemplateOperator.java | 43 - .../sys/ShowPathsUsingTemplateOperator.java | 43 - .../iotdb/db/qp/logical/sys/ShowPipeOperator.java | 45 - .../db/qp/logical/sys/ShowPipeSinkOperator.java | 45 - .../qp/logical/sys/ShowPipeSinkTypeOperator.java | 38 - .../qp/logical/sys/ShowQueryResourceOperate.java | 39 - .../qp/logical/sys/ShowStorageGroupOperator.java | 47 - .../iotdb/db/qp/logical/sys/ShowTTLOperator.java | 48 - .../db/qp/logical/sys/ShowTemplatesOperator.java | 27 - .../db/qp/logical/sys/ShowTimeSeriesOperator.java | 103 - .../db/qp/logical/sys/ShowTriggersOperator.java | 38 - .../iotdb/db/qp/logical/sys/StartPipeOperator.java | 44 - .../iotdb/db/qp/logical/sys/StopPipeOperator.java | 44 - .../iotdb/db/qp/logical/sys/TracingOperator.java | 46 - .../iotdb/db/qp/logical/sys/UnSetTTLOperator.java | 52 - .../db/qp/logical/sys/UnloadFileOperator.java | 55 - .../db/qp/logical/sys/UnsetTemplateOperator.java | 65 - .../org/apache/iotdb/db/qp/physical/BatchPlan.java | 73 - .../apache/iotdb/db/qp/physical/PhysicalPlan.java | 563 ----- .../iotdb/db/qp/physical/crud/AggregationPlan.java | 226 -- .../db/qp/physical/crud/AlignByDevicePlan.java | 285 --- .../iotdb/db/qp/physical/crud/FillQueryPlan.java | 61 - .../db/qp/physical/crud/GroupByTimeFillPlan.java | 118 - .../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 138 - .../iotdb/db/qp/physical/crud/LastQueryPlan.java | 87 - .../iotdb/db/qp/physical/crud/MeasurementInfo.java | 62 - .../iotdb/db/qp/physical/crud/QueryIndexPlan.java | 88 - .../iotdb/db/qp/physical/crud/QueryPlan.java | 255 -- .../db/qp/physical/crud/RawDataQueryPlan.java | 217 -- .../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 130 - .../apache/iotdb/db/qp/physical/crud/UDAFPlan.java | 81 - .../apache/iotdb/db/qp/physical/crud/UDFPlan.java | 43 - .../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 149 -- .../sys/ActivateTemplateInClusterPlan.java | 127 - .../db/qp/physical/sys/ActivateTemplatePlan.java | 87 - .../db/qp/physical/sys/AlterTimeSeriesPlan.java | 212 -- .../db/qp/physical/sys/AppendTemplatePlan.java | 218 -- .../iotdb/db/qp/physical/sys/AuthorPlan.java | 406 --- .../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 89 - .../iotdb/db/qp/physical/sys/ChangeAliasPlan.java | 116 - .../db/qp/physical/sys/ChangeTagOffsetPlan.java | 116 - .../iotdb/db/qp/physical/sys/ClearCachePlan.java | 55 - .../apache/iotdb/db/qp/physical/sys/CountPlan.java | 53 - .../physical/sys/CreateAlignedTimeSeriesPlan.java | 446 ---- .../qp/physical/sys/CreateContinuousQueryPlan.java | 156 -- .../db/qp/physical/sys/CreateFunctionPlan.java | 81 - .../iotdb/db/qp/physical/sys/CreateIndexPlan.java | 180 -- .../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 398 --- .../db/qp/physical/sys/CreateTemplatePlan.java | 516 ---- .../db/qp/physical/sys/CreateTimeSeriesPlan.java | 322 --- .../iotdb/db/qp/physical/sys/DataAuthPlan.java | 100 - .../db/qp/physical/sys/DeleteStorageGroupPlan.java | 84 - .../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 139 - .../qp/physical/sys/DropContinuousQueryPlan.java | 63 - .../iotdb/db/qp/physical/sys/DropFunctionPlan.java | 69 - .../iotdb/db/qp/physical/sys/DropIndexPlan.java | 129 - .../iotdb/db/qp/physical/sys/DropTemplatePlan.java | 78 - .../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 244 -- .../iotdb/db/qp/physical/sys/KillQueryPlan.java | 45 - .../db/qp/physical/sys/LoadConfigurationPlan.java | 144 -- .../iotdb/db/qp/physical/sys/LoadDataPlan.java | 73 - .../apache/iotdb/db/qp/physical/sys/LogPlan.java | 75 - .../apache/iotdb/db/qp/physical/sys/MNodePlan.java | 116 - .../db/qp/physical/sys/MeasurementMNodePlan.java | 154 -- .../apache/iotdb/db/qp/physical/sys/MergePlan.java | 59 - .../iotdb/db/qp/physical/sys/OperateFilePlan.java | 119 - .../qp/physical/sys/PreDeleteTimeSeriesPlan.java | 80 - .../db/qp/physical/sys/PruneTemplatePlan.java | 107 - .../sys/RollbackPreDeleteTimeSeriesPlan.java | 81 - .../db/qp/physical/sys/SetStorageGroupPlan.java | 100 - .../db/qp/physical/sys/SetSystemModePlan.java | 76 - .../iotdb/db/qp/physical/sys/SetTTLPlan.java | 102 - .../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 107 - .../db/qp/physical/sys/ShowChildNodesPlan.java | 39 - .../db/qp/physical/sys/ShowChildPathsPlan.java | 39 - .../qp/physical/sys/ShowContinuousQueriesPlan.java | 27 - .../iotdb/db/qp/physical/sys/ShowDevicesPlan.java | 65 - .../db/qp/physical/sys/ShowFunctionsPlan.java | 27 - .../qp/physical/sys/ShowNodesInTemplatePlan.java | 34 - .../qp/physical/sys/ShowPathsSetTemplatePlan.java | 34 - .../physical/sys/ShowPathsUsingTemplatePlan.java | 34 - .../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 131 - .../qp/physical/sys/ShowQueryProcesslistPlan.java | 26 - .../db/qp/physical/sys/ShowQueryResourcePlan.java | 38 - .../db/qp/physical/sys/ShowStorageGroupPlan.java | 36 - .../db/qp/physical/sys/ShowTemplatesPlan.java | 27 - .../db/qp/physical/sys/ShowTimeSeriesPlan.java | 135 - .../db/qp/physical/sys/StorageGroupMNodePlan.java | 110 - .../iotdb/db/qp/physical/sys/TracingPlan.java | 45 - .../db/qp/physical/sys/UnsetTemplatePlan.java | 109 - .../iotdb/db/qp/strategy/LogicalChecker.java | 46 - .../iotdb/db/qp/strategy/LogicalGenerator.java | 131 - .../iotdb/db/qp/strategy/PhysicalGenerator.java | 59 - .../qp/strategy/optimizer/ConcatPathOptimizer.java | 408 --- .../qp/strategy/optimizer/DnfFilterOptimizer.java | 163 -- .../db/qp/strategy/optimizer/IFilterOptimizer.java | 29 - .../qp/strategy/optimizer/ILogicalOptimizer.java | 30 - .../optimizer/MergeSingleFilterOptimizer.java | 179 -- .../qp/strategy/optimizer/RemoveNotOptimizer.java | 104 - .../iotdb/db/qp/utils/EmptyOutputStream.java | 35 - .../apache/iotdb/db/qp/utils/WildcardsRemover.java | 149 -- .../db/query/aggregation/AggregateResult.java | 377 --- .../db/query/aggregation/impl/AvgAggrResult.java | 222 -- .../db/query/aggregation/impl/CountAggrResult.java | 122 - .../query/aggregation/impl/ExtremeAggrResult.java | 175 -- .../aggregation/impl/FirstValueAggrResult.java | 141 -- .../aggregation/impl/FirstValueDescAggrResult.java | 88 - .../aggregation/impl/LastValueAggrResult.java | 131 - .../aggregation/impl/LastValueDescAggrResult.java | 110 - .../query/aggregation/impl/MaxTimeAggrResult.java | 119 - .../aggregation/impl/MaxTimeDescAggrResult.java | 92 - .../query/aggregation/impl/MaxValueAggrResult.java | 126 - .../query/aggregation/impl/MinTimeAggrResult.java | 134 - .../aggregation/impl/MinTimeDescAggrResult.java | 76 - .../query/aggregation/impl/MinValueAggrResult.java | 124 - .../db/query/aggregation/impl/SumAggrResult.java | 172 -- .../iotdb/db/query/context/QueryContext.java | 9 - .../db/query/control/QueryResourceManager.java | 98 +- .../iotdb/db/query/control/QueryTimeManager.java | 151 -- .../iotdb/db/query/control/SessionManager.java | 40 - .../db/query/control/tracing/TracingConstant.java | 30 - .../db/query/control/tracing/TracingInfo.java | 164 -- .../db/query/control/tracing/TracingManager.java | 88 - .../db/query/dataset/AlignByDeviceDataSet.java | 281 --- .../db/query/dataset/DirectAlignByTimeDataSet.java | 34 - .../db/query/dataset/DirectNonAlignDataSet.java | 32 - .../apache/iotdb/db/query/dataset/ListDataSet.java | 61 - .../db/query/dataset/NonAlignEngineDataSet.java | 353 --- .../dataset/RawQueryDataSetWithValueFilter.java | 264 -- .../dataset/RawQueryDataSetWithoutValueFilter.java | 728 ------ .../query/dataset/ShowContinuousQueriesResult.java | 75 - .../apache/iotdb/db/query/dataset/ShowDataSet.java | 69 - .../iotdb/db/query/dataset/ShowDevicesDataSet.java | 86 - .../db/query/dataset/ShowTimeSeriesResult.java | 196 -- .../db/query/dataset/ShowTimeseriesDataSet.java | 109 - .../iotdb/db/query/dataset/SingleDataSet.java | 56 - .../iotdb/db/query/dataset/UDFInputDataSet.java | 67 - .../UDFRawQueryInputDataSetWithoutValueFilter.java | 68 - .../db/query/dataset/UDTFAlignByTimeDataSet.java | 373 --- .../apache/iotdb/db/query/dataset/UDTFDataSet.java | 145 -- .../db/query/dataset/UDTFNonAlignDataSet.java | 216 -- .../query/dataset/groupby/GroupByFillDataSet.java | 340 --- .../query/dataset/groupby/GroupByLevelDataSet.java | 93 - .../query/dataset/groupby/GroupByTimeDataSet.java | 165 -- .../dataset/groupby/GroupByTimeEngineDataSet.java | 93 - .../groupby/GroupByWithValueFilterDataSet.java | 234 -- .../groupby/GroupByWithoutValueFilterDataSet.java | 161 -- .../db/query/executor/AggregationExecutor.java | 706 ------ .../iotdb/db/query/executor/FillQueryExecutor.java | 206 -- .../iotdb/db/query/executor/IQueryRouter.java | 74 - .../iotdb/db/query/executor/LastQueryExecutor.java | 285 --- .../iotdb/db/query/executor/QueryRouter.java | 274 -- .../db/query/executor/RawDataQueryExecutor.java | 185 -- .../iotdb/db/query/executor/UDFQueryExecutor.java | 112 - .../executor/fill/AlignedLastPointReader.java | 58 - .../apache/iotdb/db/query/executor/fill/IFill.java | 150 -- .../db/query/executor/fill/LastPointReader.java | 266 -- .../iotdb/db/query/executor/fill/LinearFill.java | 263 -- .../iotdb/db/query/executor/fill/PreviousFill.java | 138 - .../iotdb/db/query/executor/fill/ValueFill.java | 152 -- .../executor/groupby/AlignedGroupByExecutor.java | 37 - .../db/query/executor/groupby/GroupByExecutor.java | 40 - .../groupby/SlidingWindowGroupByExecutor.java | 66 - .../SlidingWindowGroupByExecutorFactory.java | 117 - .../EmptyQueueSlidingWindowGroupByExecutor.java | 51 - .../groupby/impl/LocalAlignedGroupByExecutor.java | 366 --- .../groupby/impl/LocalGroupByExecutor.java | 367 --- ...MonotonicQueueSlidingWindowGroupByExecutor.java | 73 - .../NormalQueueSlidingWindowGroupByExecutor.java | 61 - .../SmoothQueueSlidingWindowGroupByExecutor.java | 55 - .../db/query/externalsort/ExternalSortJob.java | 43 - .../query/externalsort/ExternalSortJobEngine.java | 52 - .../db/query/externalsort/ExternalSortJobPart.java | 43 - .../externalsort/ExternalSortJobScheduler.java | 40 - .../iotdb/db/query/externalsort/LineMerger.java | 55 - .../MultiSourceExternalSortJobPart.java | 50 - .../externalsort/SimpleExternalSortEngine.java | 178 -- .../SingleSourceExternalSortJobPart.java | 39 - .../adapter/ByTimestampReaderAdapter.java | 73 - .../serialize/IExternalSortFileDeserializer.java | 32 - .../FixLengthIExternalSortFileDeserializer.java | 267 -- .../impl/FixLengthTimeValuePairSerializer.java | 169 -- .../db/query/factory/AggregateResultFactory.java | 150 -- .../iotdb/db/query/pool/QueryTaskManager.java | 90 - .../db/query/pool/RawQueryReadTaskPoolManager.java | 104 - .../pool/RawQueryReadTaskPoolManagerMetrics.java | 92 - .../db/query/reader/chunk/ChunkDataIterator.java | 79 - .../db/query/reader/chunk/ChunkReaderWrap.java | 95 - .../reader/chunk/DiskChunkReaderByTimestamp.java | 82 - .../resource/CachedUnseqResourceMergeReader.java | 43 - .../series/AlignedSeriesAggregateReader.java | 189 -- .../reader/series/BaseManagedSeriesReader.java | 45 - .../db/query/reader/series/IAggregateReader.java | 57 - .../db/query/reader/series/IReaderByTimestamp.java | 47 - .../query/reader/series/ManagedSeriesReader.java | 37 - .../query/reader/series/SeriesAggregateReader.java | 175 -- .../reader/series/SeriesRawDataBatchReader.java | 63 +- .../reader/series/SeriesRawDataPointReader.java | 87 - .../iotdb/db/query/reader/series/SeriesReader.java | 51 - .../reader/series/SeriesReaderByTimestamp.java | 189 -- .../reader/universal/PriorityMergeReader.java | 10 - .../query/timegenerator/ServerTimeGenerator.java | 182 -- .../java/org/apache/iotdb/db/service/DataNode.java | 425 +++- .../db/service/DataNodeServerCommandLine.java | 18 +- .../java/org/apache/iotdb/db/service/IoTDB.java | 251 -- .../org/apache/iotdb/db/service/IoTDBMBean.java | 27 - .../apache/iotdb/db/service/IoTDBShutdownHook.java | 16 +- .../java/org/apache/iotdb/db/service/NewIoTDB.java | 232 -- .../org/apache/iotdb/db/service/NewIoTDBMBean.java | 28 - .../iotdb/db/service/basic/ServiceProvider.java | 100 - .../service/basic/StandaloneServiceProvider.java | 55 - .../iotdb/db/service/metrics/FileMetrics.java | 97 + .../db/service/metrics/IoTDBInternalReporter.java | 39 +- .../service/thrift/impl/ClientRPCServiceImpl.java | 163 +- .../impl/DataNodeInternalRPCServiceImpl.java | 21 +- .../db/service/thrift/impl/TSServiceImpl.java | 1424 ----------- .../java/org/apache/iotdb/db/sync/SyncService.java | 2 +- .../iotdb/db/sync/pipedata/load/ILoader.java | 19 +- .../db/sync/sender/manager/LocalSyncManager.java | 21 +- .../db/sync/transport/server/ReceiverManager.java | 2 +- .../apache/iotdb/db/tools/TsFileSketchTool.java | 5 + .../java/org/apache/iotdb/db/utils/QueryUtils.java | 34 - .../org/apache/iotdb/db/utils/SchemaUtils.java | 72 +- .../iotdb/db/utils/writelog/BatchLogReader.java | 83 - .../apache/iotdb/db/utils/writelog/ILogReader.java | 50 - .../apache/iotdb/db/utils/writelog/LogWriter.java | 19 +- .../db/utils/writelog/MultiFileLogReader.java | 76 - .../db/utils/writelog/SingleFileLogReader.java | 166 -- .../db/wal/recover/file/TsFilePlanRedoer.java | 2 +- .../apache/iotdb/db/auth/AuthorityCheckerTest.java | 264 -- .../iotdb/db/engine/MetadataManagerHelper.java | 6 +- .../iotdb/db/engine/cache/ChunkCacheTest.java | 17 - .../engine/compaction/CompactionSchedulerTest.java | 33 +- .../CompactionSchedulerWithFastPerformerTest.java | 36 +- .../compaction/TestUtilsForAlignedSeries.java | 30 +- ...eCompactionWithFastPerformerValidationTest.java | 100 + .../db/engine/compaction/cross/MergeTest.java | 22 +- .../inner/AbstractInnerSpaceCompactionTest.java | 22 +- .../inner/FastCompactionPerformerAlignedTest.java | 6 +- .../InnerSeqCompactionWithFastPerformerTest.java | 15 - ...nerSeqCompactionWithReadChunkPerformerTest.java | 22 +- .../InnerUnseqCompactionWithFastPerformerTest.java | 17 - ...rUnseqCompactionWithReadPointPerformerTest.java | 22 +- .../ReadChunkCompactionPerformerAlignedTest.java | 6 +- .../inner/sizetiered/SizeTieredCompactionTest.java | 22 +- .../recover/SizeTieredCompactionRecoverTest.java | 22 +- .../compaction/utils/CompactionConfigRestorer.java | 15 +- .../db/engine/storagegroup/DataRegionTest.java | 13 - .../iotdb/db/engine/storagegroup/TTLTest.java | 75 +- .../engine/storagegroup/TsFileProcessorTest.java | 2 - .../LocalConfigNodeMultiDataRegionTest.java | 94 - .../apache/iotdb/db/metadata/MetaUtilsTest.java | 90 + .../iotdb/db/metadata/SchemaAdvancedTest.java | 203 -- .../apache/iotdb/db/metadata/SchemaBasicTest.java | 1295 ---------- .../iotdb/db/metadata/SchemaImproveTest.java | 188 -- .../org/apache/iotdb/db/metadata/TemplateTest.java | 180 -- .../db/metadata/cache/DataNodeSchemaCacheTest.java | 6 +- .../iotdb/db/metadata/idtable/IDTableTest.java | 12 +- .../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 216 +- .../db/metadata/mtree/disk/MemManagerTest.java | 112 - .../db/metadata/multimode/SchemaDiskModeTest.java | 42 - .../metadata/multimode/SchemaFullMemoryTest.java | 29 - .../metadata/multimode/SchemaMemoryModeTest.java | 35 - .../db/metadata/multimode/SchemaNonMemoryTest.java | 29 - .../multimode/SchemaPartialMemoryTest.java | 28 - .../plan/SchemaRegionPlanCompatibilityTest.java | 279 -- .../schemaRegion/AbstractSchemaRegionTest.java | 141 ++ .../schemaRegion/SchemaRegionAliasAndTagTest.java | 528 ++++ .../schemaRegion/SchemaRegionBasicTest.java | 764 +++--- .../schemaRegion/SchemaRegionManagementTest.java | 191 ++ .../schemaRegion/SchemaRegionTemplateTest.java | 180 ++ .../schemaRegion/SchemaRegionTestUtil.java | 139 + .../multimode/SchemaRegionFullMemoryTest.java | 43 - .../multimode/SchemaRegionMemoryTest.java | 46 - .../multimode/SchemaRegionNonMemoryTest.java | 43 - .../multimode/SchemaRegionPartialMemoryTest.java | 43 - .../multimode/SchemaRegionSchemaFileTest.java | 46 - .../iotdb/db/mpp/aggregation/AccumulatorTest.java | 2 +- .../execution/exchange/LocalSinkHandleTest.java | 63 +- .../execution/exchange/LocalSourceHandleTest.java | 4 +- .../execution/exchange/SharedTsBlockQueueTest.java | 5 +- .../db/mpp/execution/exchange/SinkHandleTest.java | 81 +- .../mpp/execution/exchange/SourceHandleTest.java | 10 +- .../db/mpp/execution/exchange/StubSinkHandle.java | 3 + .../iotdb/db/mpp/execution/exchange/Utils.java | 52 +- .../db/mpp/execution/memory/MemoryPoolTest.java | 182 +- .../operator/AggregationOperatorTest.java | 2 +- .../AlignedSeriesAggregationScanOperatorTest.java | 2 +- .../execution/operator/AlignedSeriesTestUtil.java | 86 +- .../mpp/execution/operator/OperatorMemoryTest.java | 12 +- .../operator/RawDataAggregationOperatorTest.java | 2 +- .../SeriesAggregationScanOperatorTest.java | 2 +- .../SlidingWindowAggregationOperatorTest.java | 2 +- .../operator/VerticallyConcatOperatorTest.java | 2 +- .../operator/schema/CountMergeOperatorTest.java | 112 +- .../operator/schema/SchemaCountOperatorTest.java | 66 +- .../schema/SchemaFetchScanOperatorTest.java | 108 +- .../schema/SchemaQueryScanOperatorTest.java | 83 +- .../db/mpp/plan/StandaloneCoordinatorTest.java | 155 -- .../plan/analyze/AggregationDescriptorTest.java | 2 +- .../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 1 + .../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 2 +- .../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 2 +- .../distribution/AggregationDistributionTest.java | 2 +- .../iotdb/db/mpp/plan/plan/distribution/Util.java | 2 +- .../node/process/AggregationNodeSerdeTest.java | 2 +- .../node/process/GroupByLevelNodeSerdeTest.java | 2 +- .../plan/node/process/GroupByTagNodeSerdeTest.java | 2 +- .../process/SingleDeviceViewNodeSerdeTest.java | 61 + .../source/SeriesAggregationScanNodeSerdeTest.java | 2 +- .../plan/scheduler/StandaloneSchedulerTest.java | 547 ---- .../java/org/apache/iotdb/db/qp/PlannerTest.java | 289 --- .../iotdb/db/qp/bench/QueryParseBenchmark.java | 45 - .../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 365 --- .../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 94 - .../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 18 +- .../db/query/aggregation/AggregateResultTest.java | 294 --- .../query/aggregation/DescAggregateResultTest.java | 190 -- .../iotdb/db/query/dataset/ListDataSetTest.java | 164 -- .../db/query/dataset/ShowDevicesResultTest.java | 43 - .../db/query/dataset/ShowTimeSeriesResultTest.java | 70 - .../iotdb/db/query/dataset/SingleDataSetTest.java | 109 - .../query/dataset/UDTFAlignByTimeDataSetTest.java | 694 ----- .../dataset/groupby/GroupByTimeDataSetTest.java | 492 ---- .../query/externalsort/ExternalSortEngineTest.java | 193 -- .../db/query/externalsort/FakeChunkReaderWrap.java | 43 - ...ExternalSortFileSerializerDeserializerTest.java | 131 - .../reader/series/SeriesAggregateReaderTest.java | 141 -- .../reader/series/SeriesReaderByTimestampTest.java | 95 - .../db/query/reader/series/SeriesReaderTest.java | 189 -- .../query/reader/series/SeriesReaderTestUtil.java | 19 +- .../iotdb/db/rescon/ResourceManagerTest.java | 22 +- .../org/apache/iotdb/db/service/DaemonTest.java | 4 +- .../DataNodeInternalRPCServiceImplTest.java | 4 +- .../db/sync/datasource/PipeOpManagerTest.java | 6 +- .../org/apache/iotdb/db/tools/MLogParserTest.java | 86 +- .../iotdb/db/tools/TsFileAndModSettleToolTest.java | 2 - .../iotdb/db/tools/TsFileSketchToolTest.java | 26 +- .../apache/iotdb/db/utils/EnvironmentUtils.java | 82 +- .../org/apache/iotdb/db/utils/SchemaTestUtils.java | 7 +- .../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 16 - .../iotdb/db/utils/TsFileRewriteToolTest.java | 460 ---- .../db/utils/writelog/LogWriterReaderTest.java | 215 -- .../db/utils/writelog/MultiFileLogReaderTest.java | 97 - .../db/wal/recover/WALRecoverManagerTest.java | 61 +- .../db/wal/recover/file/TsFilePlanRedoerTest.java | 87 +- .../file/UnsealedTsFileRecoverPerformerTest.java | 56 +- server/src/test/resources/logback-test.xml | 2 +- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +- session/pom.xml | 6 + .../java/org/apache/iotdb/session/Session.java | 47 +- .../apache/iotdb/session/SessionConnection.java | 24 + .../org/apache/iotdb/session/pool/SessionPool.java | 327 ++- .../iotdb/session/template/InternalNode.java | 1 + .../iotdb/session/template/MeasurementNode.java | 1 + .../apache/iotdb/session/SessionCacheLeaderUT.java | 1 + site/src/main/.vuepress/config.js | 70 +- .../apache/iotdb/spark/db/EnvironmentUtils.java | 6 +- .../org/apache/iotdb/spark/db/IoTDBTest.scala | 9 +- .../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 14 +- .../iotdb/spark/db/unit/DataFrameToolsTest.scala | 11 +- .../test/java/org/apache/iotdb/db/sql/Cases.java | 48 +- .../src/main/thrift/confignode.thrift | 87 +- .../src/main/thrift/iotconsensus.thrift | 20 +- thrift/src/main/thrift/client.thrift | 9 + .../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +- .../tsfile/read/common/block/TsBlockBuilder.java | 2 +- .../tsfile/read/query/dataset/EmptyDataSet.java | 40 - .../tsfile/read/reader/FakedTimeGenerator.java | 83 - zeppelin-interpreter/pom.xml | 51 - .../apache/zeppelin/iotdb/IoTDBInterpreter.java | 4 +- 863 files changed, 17455 insertions(+), 69503 deletions(-)
