You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hx...@apache.org on 2022/12/24 04:34:42 UTC
[iotdb] branch jenkins-disable-integration updated (4ba008d8b4 -> 165f0cab61)
This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch jenkins-disable-integration
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4ba008d8b4 disable integration in jenkins
add 263fcd40d6 Add the statistics of flush point (#8495)
add 44fcb03428 Fix sonar check fail in IntoOperator
add 5e37220a8a [IOTDB-5216] Fix order by timeseries doesn't take effect in aligned last query
add a320b0280a [IOTDB-5212] Remove deprecated syntax in CQ
add 97b10775ad Fix python ITs (#8502)
add 483f0a5f35 [IOTDB-5117] Introduce MemoryDistributionCalculator for FragmentInstance (#8485)
add 5965a7f10f Keep Session interface compatible (#8504)
add 43319883cb [IOTDB-5233] Correct the message of unsupported thrift interface of schema template (#8506)
add 4a59a2c914 [IOTDB-4816] Show Queries - support antlrParse & analyze process (#8467)
add 688e1fed9c IoTDBClusterRegionLeaderBalancingIT (#8514)
add aaf420318d [IOTDB-5224] SchemaRegion UT Framework (#8516)
add b9033dcb5e [IOTDB-5236] Fix DeleteData Python API cannot work (#8511)
add df6c60916d [IOTDB-5239] UT related to delete timeseries (#8522)
add 968ff58e08 [IOTDB-5242] UT related to MetaUtils (#8521)
add 3ed2d7349c Delete stale query code (#8478)
add 64f3460b88 Upgrade the metric of flush from important to core (#8524)
add 16f73cbdd9 Add getBackupConfiguration() (#8530)
add 8da1c8728e [IOTDB-5205] Construct Cluster Node startup protocol (#8481)
add f929e255e4 [IOTDB-5238] UT related to alias and tags and attributes (#8520)
add 383a36aef7 Eliminate useless schema module code of old standalone (#8536)
add 5e48bbabed rename (#8534)
add 3ec0e99992 [IOTDB-5247] Fix drop tags or attributes throw NPE in SchemaFile (#8537)
add f65389577c [IOTDB-5232] Add schema memory metric (#8545)
add 62b31a9d0a Move zeppelin test to integration-test (#8538)
add 47aac84dc9 Unify the ip/port in datanode (#8541)
add 7e1a670675 Add interface to set datatype of mqtt (#8548)
add 213c88dd6d Start ConfigNode and DataNode successfully when cluster_name is missed (#8547)
add 5da8064359 IOTDB-5227 docker deploy support multiple platforms and fix mistakes (#8542)
add 77c6ad948e merge tsfile md and add export tsfile and csv tool add timeout param (#8546)
add 394ecc0fe6 Modify the default value of `iot_consensus_cache_window_time_in_ms` to 10s (#8553)
add 7b92bd295e [IOTDB-5231]Add the handle of exception when metric reporter failed to start (#8523)
add 57c8a5944b [IOTDB-5240] Add template id to schema region snapshot (#8551)
add 43c1d6ed2d add FAQ-for-cluster-setup (#8558)
add 4376e3548d [IOTDB-5226] Correct the style and reliance of schema operator UT (#8557)
add a8077c40dd [IOTDB-5243] UT related to timeseries and metadata info query (#8564)
add 3bc92acd21 Eliminate schema region device cache (#8563)
add 5020bb1982 [IOTDB-5215]Fix setting chunkPointNumLowerBound in IoTDBDescriptor (#8476)
add 72e4357679 Update some website links to https (#8566)
add 4a1c246384 add export-tsfile it on integration-test (#8531)
add 656d281150 Update FAQ for cluster setup (#8567)
add 87baa0fb32 [IOTDB-5261]support modify the dn_max_connection_for_internal_servic of IoTConsensus (#8565)
add 75e85edfe5 Eliminate physical plan and Refactor SchemaRegionPlan usage
add 0d6e6431f1 remove cross test (#8585)
add 15c0eabcb6 [IOTDB-5117] Fix some issues in MemoryDistributionCalculator (#8580)
add 2c5ddb08d8 change faq in config.js (#8588)
add ae1570a098 Eliminate useless code in SchemaRegion and MTree (#8587)
new 165f0cab61 Merge remote-tracking branch 'origin/master' into jenkins-disable-integration
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 6 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 16 +-
.../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 | 16 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 22 +-
client-py/iotdb/Session.py | 26 +-
client-py/iotdb/utils/IoTDBRpcDataSet.py | 2 +-
client-py/tests/test_delete_data.py | 162 ++
.../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 | 6 +-
.../consensus/response/DataNodeRegisterResp.java | 44 +-
.../iotdb/confignode/manager/ConfigManager.java | 149 +-
.../iotdb/confignode/manager/ConsensusManager.java | 2 +-
.../apache/iotdb/confignode/manager/IManager.java | 22 +-
.../manager/node/ClusterNodeStartUtils.java | 380 +++
.../iotdb/confignode/manager/node/NodeManager.java | 156 +-
.../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 +-
.../consensus/iot/client/DispatchLogHandler.java | 20 +-
.../iot/client/IoTConsensusClientPool.java | 7 +-
.../{PendingBatch.java => Batch.java} | 32 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 88 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 2 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 18 +-
.../iot/service/IoTConsensusRPCService.java | 2 +-
.../service/IoTConsensusRPCServiceProcessor.java | 41 +-
.../apache/iotdb/consensus/iot/StabilityTest.java | 12 +-
.../iot/logdispatcher/SyncStatusTest.java | 121 +-
cross-tests/pom.xml | 125 -
.../tests/tools/importCsv/ExportCsvTestIT.java | 148 --
.../tests/tools/importCsv/ImportCsvTestIT.java | 432 ----
.../tests/tools/tsfile/ExportTsFileTestIT.java | 124 -
.../src/test/resources/iotdb-datanode.properties | 23 -
docker/ReadMe.md | 4 +-
docker/src/main/DockerCompose/do-docker-build.sh | 65 +-
.../src/main/DockerCompose/docker-compose-1c1d.yml | 6 +-
.../DockerCompose/docker-compose-cluster-1c2d.yml | 14 +-
.../DockerCompose/docker-compose-cluster-3c3d.yml | 8 +-
.../DockerCompose/docker-compose-host-3c3d.yml | 4 +-
docker/src/main/Dockerfile-1.0.0-1c1d | 3 +-
docker/src/main/Dockerfile-1.0.0-confignode | 6 +-
docker/src/main/Dockerfile-1.0.0-datanode | 6 +-
docs/Development/ContributeGuide.md | 14 -
docs/UserGuide/Cluster/Cluster-Setup.md | 2 +-
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 | 17 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 9 +-
docs/zh/Development/ContributeGuide.md | 11 -
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 2 +-
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 | 29 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 11 +-
.../apache/iotdb/trigger/old/TriggerExample.java | 147 --
integration-test/import-control.xml | 11 +
integration-test/pom.xml | 41 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 121 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 6 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 11 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 5 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 54 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 34 +-
.../org/apache/iotdb/cli/it}/AbstractScript.java | 86 +-
.../apache/iotdb/cli/it}/StartClientScriptIT.java | 71 +-
.../confignode/it/IoTDBClusterAuthorityIT.java | 62 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 2 +-
.../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 +
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 54 +-
.../org/apache/iotdb/tools/ExportCsvTestIT.java | 198 ++
.../org/apache/iotdb/tools/ExportTsFileTestIT.java | 198 ++
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 127 +-
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 1127 ---------
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 6 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 291 ---
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 796 ------
.../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 --
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 42 -
.../java/org/apache/iotdb/jdbc/ListDataSet.java | 53 -
.../reporter/iotdb/InternalIoTDBReporter.java | 2 +-
.../iotdb/MemoryInternalIoTDBReporter.java | 4 +-
.../reporter/iotdb/SessionIoTDBReporter.java | 46 +-
.../reporter/prometheus/PrometheusReporter.java | 33 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 6 +-
.../resources/conf/iotdb-common.properties | 9 +-
.../org/apache/iotdb/commons/cluster/NodeType.java | 31 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 +
.../commons/service/metric/MetricService.java | 7 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +-
.../iotdb/commons/service/metric/enums/Tag.java | 3 +-
pom.xml | 3 +-
.../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 +-
.../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 | 59 +-
.../ConfigNodeClientManager.java} | 32 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 6 +-
.../iotdb/db/client/DataNodeInternalClient.java | 15 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 35 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 15 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 14 +-
.../db/consensus/DataRegionConsensusImpl.java | 2 +
.../iotdb/db/engine/flush/MemTableFlushTask.java | 23 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 64 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 95 -
.../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 +----
.../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} | 40 +-
.../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 | 382 +--
.../schemaregion/SchemaRegionSchemaFileImpl.java | 332 +--
.../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 +
.../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 +-
.../mpp/execution/memory/LocalMemoryManager.java | 2 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 206 +-
.../operator/process/AbstractIntoOperator.java | 11 +-
.../process/last/LastQuerySortOperator.java | 56 +-
.../operator/schema/DevicesSchemaScanOperator.java | 17 +-
.../schema/TimeSeriesSchemaScanOperator.java | 22 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 20 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 64 +
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 10 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 69 +
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 6 +-
.../plan/analyze/StandalonePartitionFetcher.java | 252 --
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 227 --
.../db/mpp/plan/execution/QueryExecution.java | 27 +-
.../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 | 1 +
.../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/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 | 29 +-
.../org/apache/iotdb/db/protocol/mqtt/Message.java | 11 +
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 11 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 11 +-
.../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 -
.../db/qp/logical/sys/ShowLockInfoOperator.java | 36 -
.../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 | 257 --
.../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 -
.../iotdb/db/qp/physical/sys/ShowLockInfoPlan.java | 36 -
.../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 | 150 --
.../db/query/aggregation/AggregateResult.java | 377 ---
.../aggregation/RemovableAggregateResult.java | 30 -
.../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 | 429 ++--
.../db/service/DataNodeServerCommandLine.java | 18 +-
.../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 -
.../db/service/metrics/IoTDBInternalReporter.java | 35 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 159 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 17 +-
.../db/service/thrift/impl/TSServiceImpl.java | 1424 -----------
.../iotdb/db/sync/pipedata/load/ILoader.java | 15 +-
.../db/sync/sender/manager/LocalSyncManager.java | 21 +-
.../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 --
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 264 --
.../iotdb/db/engine/cache/ChunkCacheTest.java | 19 -
.../InnerSeqCompactionWithFastPerformerTest.java | 17 -
.../InnerUnseqCompactionWithFastPerformerTest.java | 19 -
.../db/engine/storagegroup/DataRegionTest.java | 13 -
.../iotdb/db/engine/storagegroup/TTLTest.java | 76 +-
.../engine/storagegroup/TsFileProcessorTest.java | 2 -
.../LocalConfigNodeMultiDataRegionTest.java | 94 -
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 90 +
.../iotdb/db/metadata/SchemaAdvancedTest.java | 202 --
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 1294 ----------
.../iotdb/db/metadata/SchemaImproveTest.java | 187 --
.../org/apache/iotdb/db/metadata/TemplateTest.java | 180 --
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 216 +-
.../db/metadata/mtree/disk/MemManagerTest.java | 111 -
.../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 | 77 +-
.../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 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 2 +-
.../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 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 2 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 2 +-
.../distribution/AggregationDistributionTest.java | 2 +-
.../node/process/AggregationNodeSerdeTest.java | 2 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 2 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 2 +-
.../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 | 700 ------
.../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 | 21 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 87 +-
.../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 | 4 +-
.../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 | 5 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +-
.../java/org/apache/iotdb/session/ISession.java | 12 +-
.../java/org/apache/iotdb/session/Session.java | 29 +-
.../apache/iotdb/session/SessionConnection.java | 22 +
.../org/apache/iotdb/session/pool/SessionPool.java | 20 +
site/src/main/.vuepress/config.js | 40 +-
.../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 | 46 -
.../src/main/thrift/confignode.thrift | 86 +-
.../src/main/thrift/iotconsensus.thrift | 20 +-
thrift/src/main/thrift/client.thrift | 9 +
.../tsfile/read/query/dataset/EmptyDataSet.java | 40 -
.../tsfile/read/reader/FakedTimeGenerator.java | 83 -
zeppelin-interpreter/pom.xml | 51 -
.../apache/zeppelin/iotdb/IoTDBInterpreter.java | 4 +-
679 files changed, 8736 insertions(+), 64616 deletions(-)
create mode 100644 client-py/tests/test_delete_data.py
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/ClusterNodeStartUtils.java
rename consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/{PendingBatch.java => Batch.java} (75%)
delete mode 100644 cross-tests/pom.xml
delete mode 100644 cross-tests/src/test/java/org/apache/iotdb/cross/tests/tools/importCsv/ExportCsvTestIT.java
delete mode 100644 cross-tests/src/test/java/org/apache/iotdb/cross/tests/tools/importCsv/ImportCsvTestIT.java
delete mode 100644 cross-tests/src/test/java/org/apache/iotdb/cross/tests/tools/tsfile/ExportTsFileTestIT.java
delete mode 100644 cross-tests/src/test/resources/iotdb-datanode.properties
create mode 100644 docs/UserGuide/FAQ/FAQ-for-cluster-setup.md
create mode 100644 docs/zh/UserGuide/FAQ/FAQ-for-cluster-setup.md
delete mode 100644 example/trigger/src/main/java/org/apache/iotdb/trigger/old/TriggerExample.java
rename {cross-tests/src/test/java/org/apache/iotdb/cross/tests/tools/importCsv => integration-test/src/test/java/org/apache/iotdb/cli/it}/AbstractScript.java (50%)
rename {cli/src/test/java/org/apache/iotdb/cli => integration-test/src/test/java/org/apache/iotdb/cli/it}/StartClientScriptIT.java (66%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterNodeErrorStartUpIT.java
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/{IoTDBClusterNodeIT.java => cluster/IoTDBClusterNodeGetterIT.java} (95%)
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/{ => cluster}/IoTDBClusterRestartIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/{ => load}/IoTDBClusterRegionLeaderBalancingIT.java (91%)
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/{ => load}/IoTDBConfigNodeSwitchLeaderIT.java (99%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/tools/ExportCsvTestIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/tools/ExportTsFileTestIT.java
rename zeppelin-interpreter/src/test/java/org/apache/zeppelin/iotdb/IoTDBInterpreterTest.java => integration-test/src/test/java/org/apache/iotdb/zeppelin/it/IoTDBInterpreterIT.java (79%)
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBAuthorizationIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBEngineTimeGeneratorIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSelectIntoIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSequenceDataQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSeriesReaderIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBUDFNestAggregationIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBUserDefinedAggregationFunctionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/AlignedWriteUtil.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBEmptyDataIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByFillQueryBigDataIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByFillQueryIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLoadExternalAlignedTsFileIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithValueFilter2IT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithValueFilterIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithValueFilterWithDeletion2IT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithValueFilterWithDeletionIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByFillIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByFillMixPathsIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByFillWithRangeIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/groupby/IoTDBGroupByNaturalMonthFillIT.java
delete mode 100644 jdbc/src/main/java/org/apache/iotdb/jdbc/ListDataSet.java
rename server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowTTLPlan.java => node-commons/src/main/java/org/apache/iotdb/commons/cluster/NodeType.java (61%)
delete mode 100644 schema-engine-rocksdb/src/test/org.apache.iotdb.db/metadata/rocksdb/RSchemaRegionAdvancedTest.java
delete mode 100644 schema-engine-rocksdb/src/test/org.apache.iotdb.db/metadata/rocksdb/RocksDBBenchmarkEngine.java
rename schema-engine-rocksdb/src/test/{org.apache.iotdb.db/metadata => org/apache/iotdb/db/metadata/schemaregion}/rocksdb/MRocksDBBenchmark.java (92%)
rename schema-engine-rocksdb/src/test/{org.apache.iotdb.db/metadata => org/apache/iotdb/db/metadata/schemaregion}/rocksdb/MRocksDBUnitTest.java (88%)
rename schema-engine-rocksdb/src/test/{org.apache.iotdb.db/metadata => org/apache/iotdb/db/metadata/schemaregion}/rocksdb/RSchemaReadWriteHandlerTest.java (93%)
create mode 100644 schema-engine-rocksdb/src/test/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RocksDBBenchmarkEngine.java
rename schema-engine-rocksdb/src/test/{org.apache.iotdb.db/metadata => org/apache/iotdb/db/metadata/schemaregion}/rocksdb/RocksDBBenchmarkTask.java (100%)
rename schema-engine-rocksdb/src/test/{org.apache.iotdb.db/metadata => org/apache/iotdb/db/metadata/schemaregion}/rocksdb/RocksDBTestUtils.java (95%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/auth/StandaloneAuthorityFetcher.java
rename server/src/main/java/org/apache/iotdb/db/{metadata/storagegroup/StorageGroupLogReader.java => client/ConfigNodeClientManager.java} (56%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/local/LocalIoTDBHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/read/AbstractShowSchemaPlanImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/read/SchemaRegionReadPlanFactory.java
rename server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/SettlePlan.java => metadata/plan/schemaregion/impl/read/ShowDevicesPlanImpl.java} (50%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/read/ShowTimeSeriesPlanImpl.java
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/ActivateTemplateInClusterPlanImpl.java (93%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/AutoCreateDeviceMNodePlanImpl.java (88%)
copy server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/ChangeAliasPlanImpl.java (89%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/ChangeTagOffsetPlanImpl.java (89%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/CreateAlignedTimeSeriesPlanImpl.java (96%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/CreateTimeSeriesPlanImpl.java (96%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/DeactivateTemplatePlanImpl.java (88%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/DeleteTimeSeriesPlanImpl.java (88%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/PreDeactivateTemplatePlanImpl.java (88%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/PreDeleteTimeSeriesPlanImpl.java (88%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/RollbackPreDeactivateTemplatePlanImpl.java (87%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{ => write}/RollbackPreDeleteTimeSeriesPlanImpl.java (87%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/{SchemaRegionPlanFactory.java => write/SchemaRegionWritePlanFactory.java} (92%)
rename server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/ShowTriggersPlan.java => metadata/plan/schemaregion/read/IShowDevicesPlan.java} (83%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/{impl/ChangeAliasPlanImpl.java => read/IShowSchemaPlan.java} (57%)
rename server/src/main/java/org/apache/iotdb/db/{query/externalsort/serialize/IExternalSortFileSerializer.java => metadata/plan/schemaregion/read/IShowTimeSeriesPlan.java} (71%)
rename server/src/main/java/org/apache/iotdb/db/{query/dataset => metadata/plan/schemaregion/result}/ShowDevicesResult.java (64%)
rename server/src/main/java/org/apache/iotdb/db/{query/dataset/ShowResult.java => metadata/plan/schemaregion/result/ShowSchemaResult.java} (58%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/result/ShowTimeSeriesResult.java
rename server/src/main/java/org/apache/iotdb/db/metadata/rescon/{SchemaStatisticsManagerMetrics.java => SchemaResourceManagerMetrics.java} (62%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupLogWriter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/StandalonePartitionFetcher.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/StandaloneSchemaFetcher.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandaloneConfigTaskExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java
rename server/src/main/java/org/apache/iotdb/db/{query/aggregation => mpp/plan/planner/plan/parameter}/AggregationType.java (97%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/AuthorType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/ShowQueriesStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/builder/DAGBuilder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/Planner.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/executor/IPlanExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/AggregationQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/DeleteDataOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/FillClauseComponent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/FillQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/GroupByClauseComponent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/GroupByFillClauseComponent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/GroupByFillQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/GroupByQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/InOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/InsertOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/LastQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/LikeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/RegexpOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SelectIntoOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/UDAFQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/UDTFQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ActivateTemplateOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/AlterTimeSeriesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/AuthorOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ClearCacheOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CountOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreateAlignedTimeSeriesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreateContinuousQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreateFunctionOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreateIndexOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreatePipeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreatePipeSinkOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreateTemplateOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreateTimeSeriesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DataAuthOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DeletePartitionOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DeleteStorageGroupOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DeleteTimeSeriesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropContinuousQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropFunctionOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropIndexOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropPipeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropPipeSinkOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropTemplateOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/FlushOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/KillQueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/LoadConfigurationOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/LoadDataOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/LoadFilesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/MergeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/RemoveFileOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/SetStorageGroupOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/SetSystemModeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/SetTTLOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/SetTemplateOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/SettleOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowChildNodesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowChildPathsOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowContinuousQueriesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowDevicesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowFunctionsOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowLockInfoOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowNodesInTemplateOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPathsSetTemplateOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPathsUsingTemplateOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeSinkOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeSinkTypeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowQueryResourceOperate.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowStorageGroupOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowTTLOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowTemplatesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowTimeSeriesOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowTriggersOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StartPipeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StopPipeOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/TracingOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/UnSetTTLOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/UnloadFileOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/UnsetTemplateOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/BatchPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/PhysicalPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/AggregationPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/AlignByDevicePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/FillQueryPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/GroupByTimeFillPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/GroupByTimePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/LastQueryPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/MeasurementInfo.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/QueryIndexPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/QueryPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/RawDataQueryPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/SelectIntoPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/UDAFPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/UDFPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/UDTFPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ActivateTemplateInClusterPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ActivateTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/AlterTimeSeriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/AppendTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/AuthorPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/AutoCreateDeviceMNodePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ChangeAliasPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ChangeTagOffsetPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ClearCachePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CountPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateContinuousQueryPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateFunctionPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateIndexPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateMultiTimeSeriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateTimeSeriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DataAuthPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DeleteStorageGroupPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DeleteTimeSeriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropContinuousQueryPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropFunctionPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropIndexPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/FlushPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/KillQueryPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/LoadConfigurationPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/LoadDataPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/LogPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/MNodePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/MeasurementMNodePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/MergePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/OperateFilePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/PreDeleteTimeSeriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/PruneTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/RollbackPreDeleteTimeSeriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/SetStorageGroupPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/SetSystemModePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/SetTTLPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/SetTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowChildNodesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowChildPathsPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowContinuousQueriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowDevicesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowFunctionsPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowLockInfoPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowNodesInTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPathsSetTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPathsUsingTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowQueryProcesslistPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowQueryResourcePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowStorageGroupPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowTemplatesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowTimeSeriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/StorageGroupMNodePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/TracingPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/UnsetTemplatePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalChecker.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalGenerator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/PhysicalGenerator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/optimizer/ConcatPathOptimizer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/optimizer/DnfFilterOptimizer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/optimizer/IFilterOptimizer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/optimizer/ILogicalOptimizer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/optimizer/MergeSingleFilterOptimizer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/strategy/optimizer/RemoveNotOptimizer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/utils/EmptyOutputStream.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/utils/WildcardsRemover.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/AggregateResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/RemovableAggregateResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/AvgAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/CountAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/ExtremeAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/FirstValueAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/FirstValueDescAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/LastValueAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/LastValueDescAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MaxTimeAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MaxTimeDescAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MaxValueAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MinTimeAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MinTimeDescAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/MinValueAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/SumAggrResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/QueryTimeManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/tracing/TracingConstant.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/tracing/TracingInfo.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/control/tracing/TracingManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/AlignByDeviceDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/DirectAlignByTimeDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/DirectNonAlignDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/ListDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/NonAlignEngineDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/RawQueryDataSetWithValueFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/RawQueryDataSetWithoutValueFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/ShowContinuousQueriesResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/ShowDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/ShowDevicesDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/ShowTimeSeriesResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/ShowTimeseriesDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/SingleDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/UDFInputDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/UDFRawQueryInputDataSetWithoutValueFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/UDTFAlignByTimeDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/UDTFDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/UDTFNonAlignDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByFillDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByLevelDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeEngineDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithValueFilterDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByWithoutValueFilterDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/AggregationExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/FillQueryExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/IQueryRouter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/QueryRouter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/RawDataQueryExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/UDFQueryExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/fill/AlignedLastPointReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/fill/IFill.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/fill/LastPointReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/fill/LinearFill.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/fill/PreviousFill.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/fill/ValueFill.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/AlignedGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/GroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/SlidingWindowGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/SlidingWindowGroupByExecutorFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/EmptyQueueSlidingWindowGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/LocalAlignedGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/LocalGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/MonotonicQueueSlidingWindowGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/NormalQueueSlidingWindowGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/groupby/impl/SmoothQueueSlidingWindowGroupByExecutor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/ExternalSortJob.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/ExternalSortJobEngine.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/ExternalSortJobPart.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/ExternalSortJobScheduler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/LineMerger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/MultiSourceExternalSortJobPart.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/SimpleExternalSortEngine.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/SingleSourceExternalSortJobPart.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/adapter/ByTimestampReaderAdapter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/serialize/IExternalSortFileDeserializer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/serialize/impl/FixLengthIExternalSortFileDeserializer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/externalsort/serialize/impl/FixLengthTimeValuePairSerializer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/factory/AggregateResultFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/pool/QueryTaskManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/pool/RawQueryReadTaskPoolManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/pool/RawQueryReadTaskPoolManagerMetrics.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/chunk/ChunkDataIterator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/chunk/ChunkReaderWrap.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/chunk/DiskChunkReaderByTimestamp.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/resource/CachedUnseqResourceMergeReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/AlignedSeriesAggregateReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/BaseManagedSeriesReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/IAggregateReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/IReaderByTimestamp.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/ManagedSeriesReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesRawDataPointReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReaderByTimestamp.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/timegenerator/ServerTimeGenerator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/NewIoTDB.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/NewIoTDBMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/basic/ServiceProvider.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/basic/StandaloneServiceProvider.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/TSServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/BatchLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/ILogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/MultiFileLogReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/writelog/SingleFileLogReader.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/auth/AuthorityCheckerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/localconfignode/LocalConfigNodeMultiDataRegionTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/SchemaAdvancedTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/SchemaBasicTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/SchemaImproveTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/TemplateTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/disk/MemManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaDiskModeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaFullMemoryTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaMemoryModeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaNonMemoryTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaPartialMemoryTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/plan/SchemaRegionPlanCompatibilityTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/AbstractSchemaRegionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionAliasAndTagTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionManagementTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionTemplateTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionTestUtil.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionFullMemoryTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionMemoryTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionNonMemoryTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionPartialMemoryTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/multimode/SchemaRegionSchemaFileTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/StandaloneCoordinatorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneSchedulerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/PlannerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/bench/QueryParseBenchmark.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/logical/LogicalPlanSmallTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/other/TSPlanContextAuthorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/aggregation/AggregateResultTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/aggregation/DescAggregateResultTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/ListDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/ShowDevicesResultTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/ShowTimeSeriesResultTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/SingleDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/UDTFAlignByTimeDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/groupby/GroupByTimeDataSetTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/externalsort/ExternalSortEngineTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/externalsort/FakeChunkReaderWrap.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/externalsort/IExternalSortFileSerializerDeserializerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesAggregateReaderTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderByTimestampTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/query/reader/series/SeriesReaderTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/utils/TsFileRewriteToolTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/utils/writelog/LogWriterReaderTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/utils/writelog/MultiFileLogReaderTest.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/dataset/EmptyDataSet.java
delete mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/FakedTimeGenerator.java
[iotdb] 01/01: Merge remote-tracking branch 'origin/master' into jenkins-disable-integration
Posted by hx...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hxd pushed a commit to branch jenkins-disable-integration
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 165f0cab612fb951c8a5a70f8f4af3d70b2c3d56
Merge: 4ba008d8b4 ae1570a098
Author: xiangdong huang <hx...@timecho.com>
AuthorDate: Fri Dec 23 08:59:26 2022 +0800
Merge remote-tracking branch 'origin/master' into jenkins-disable-integration
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 6 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 16 +-
.../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 | 16 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 22 +-
client-py/iotdb/Session.py | 26 +-
client-py/iotdb/utils/IoTDBRpcDataSet.py | 2 +-
client-py/tests/test_delete_data.py | 162 ++
.../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 | 6 +-
.../consensus/response/DataNodeRegisterResp.java | 44 +-
.../iotdb/confignode/manager/ConfigManager.java | 149 +-
.../iotdb/confignode/manager/ConsensusManager.java | 2 +-
.../apache/iotdb/confignode/manager/IManager.java | 22 +-
.../manager/node/ClusterNodeStartUtils.java | 380 +++
.../iotdb/confignode/manager/node/NodeManager.java | 156 +-
.../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 +-
.../consensus/iot/client/DispatchLogHandler.java | 20 +-
.../iot/client/IoTConsensusClientPool.java | 7 +-
.../{PendingBatch.java => Batch.java} | 32 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 88 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 2 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 18 +-
.../iot/service/IoTConsensusRPCService.java | 2 +-
.../service/IoTConsensusRPCServiceProcessor.java | 41 +-
.../apache/iotdb/consensus/iot/StabilityTest.java | 12 +-
.../iot/logdispatcher/SyncStatusTest.java | 121 +-
cross-tests/pom.xml | 125 -
.../tests/tools/importCsv/ExportCsvTestIT.java | 148 --
.../tests/tools/importCsv/ImportCsvTestIT.java | 432 ----
.../tests/tools/tsfile/ExportTsFileTestIT.java | 124 -
.../src/test/resources/iotdb-datanode.properties | 23 -
docker/ReadMe.md | 4 +-
docker/src/main/DockerCompose/do-docker-build.sh | 65 +-
.../src/main/DockerCompose/docker-compose-1c1d.yml | 6 +-
.../DockerCompose/docker-compose-cluster-1c2d.yml | 14 +-
.../DockerCompose/docker-compose-cluster-3c3d.yml | 8 +-
.../DockerCompose/docker-compose-host-3c3d.yml | 4 +-
docker/src/main/Dockerfile-1.0.0-1c1d | 3 +-
docker/src/main/Dockerfile-1.0.0-confignode | 6 +-
docker/src/main/Dockerfile-1.0.0-datanode | 6 +-
docs/Development/ContributeGuide.md | 14 -
docs/UserGuide/Cluster/Cluster-Setup.md | 2 +-
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 | 17 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 9 +-
docs/zh/Development/ContributeGuide.md | 11 -
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 2 +-
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 | 29 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 11 +-
.../apache/iotdb/trigger/old/TriggerExample.java | 147 --
integration-test/import-control.xml | 11 +
integration-test/pom.xml | 41 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 121 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 6 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 11 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 5 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 54 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 34 +-
.../org/apache/iotdb/cli/it}/AbstractScript.java | 86 +-
.../apache/iotdb/cli/it}/StartClientScriptIT.java | 71 +-
.../confignode/it/IoTDBClusterAuthorityIT.java | 62 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 2 +-
.../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 +
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 54 +-
.../org/apache/iotdb/tools/ExportCsvTestIT.java | 198 ++
.../org/apache/iotdb/tools/ExportTsFileTestIT.java | 198 ++
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 127 +-
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 1127 ---------
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 6 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 291 ---
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 796 ------
.../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 --
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 42 -
.../java/org/apache/iotdb/jdbc/ListDataSet.java | 53 -
.../reporter/iotdb/InternalIoTDBReporter.java | 2 +-
.../iotdb/MemoryInternalIoTDBReporter.java | 4 +-
.../reporter/iotdb/SessionIoTDBReporter.java | 46 +-
.../reporter/prometheus/PrometheusReporter.java | 33 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 6 +-
.../resources/conf/iotdb-common.properties | 9 +-
.../org/apache/iotdb/commons/cluster/NodeType.java | 31 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 +
.../commons/service/metric/MetricService.java | 7 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +-
.../iotdb/commons/service/metric/enums/Tag.java | 3 +-
pom.xml | 3 +-
.../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 +-
.../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 | 59 +-
.../ConfigNodeClientManager.java} | 32 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 6 +-
.../iotdb/db/client/DataNodeInternalClient.java | 15 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 35 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 15 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 14 +-
.../db/consensus/DataRegionConsensusImpl.java | 2 +
.../iotdb/db/engine/flush/MemTableFlushTask.java | 23 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 64 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 95 -
.../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 +----
.../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} | 40 +-
.../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 | 382 +--
.../schemaregion/SchemaRegionSchemaFileImpl.java | 332 +--
.../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 +
.../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 +-
.../mpp/execution/memory/LocalMemoryManager.java | 2 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 206 +-
.../operator/process/AbstractIntoOperator.java | 11 +-
.../process/last/LastQuerySortOperator.java | 56 +-
.../operator/schema/DevicesSchemaScanOperator.java | 17 +-
.../schema/TimeSeriesSchemaScanOperator.java | 22 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 20 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 64 +
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 10 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 69 +
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 6 +-
.../plan/analyze/StandalonePartitionFetcher.java | 252 --
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 227 --
.../db/mpp/plan/execution/QueryExecution.java | 27 +-
.../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 | 1 +
.../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/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 | 29 +-
.../org/apache/iotdb/db/protocol/mqtt/Message.java | 11 +
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 11 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 11 +-
.../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 -
.../db/qp/logical/sys/ShowLockInfoOperator.java | 36 -
.../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 | 257 --
.../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 -
.../iotdb/db/qp/physical/sys/ShowLockInfoPlan.java | 36 -
.../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 | 150 --
.../db/query/aggregation/AggregateResult.java | 377 ---
.../aggregation/RemovableAggregateResult.java | 30 -
.../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 | 429 ++--
.../db/service/DataNodeServerCommandLine.java | 18 +-
.../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 -
.../db/service/metrics/IoTDBInternalReporter.java | 35 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 159 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 17 +-
.../db/service/thrift/impl/TSServiceImpl.java | 1424 -----------
.../iotdb/db/sync/pipedata/load/ILoader.java | 15 +-
.../db/sync/sender/manager/LocalSyncManager.java | 21 +-
.../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 --
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 264 --
.../iotdb/db/engine/cache/ChunkCacheTest.java | 19 -
.../InnerSeqCompactionWithFastPerformerTest.java | 17 -
.../InnerUnseqCompactionWithFastPerformerTest.java | 19 -
.../db/engine/storagegroup/DataRegionTest.java | 13 -
.../iotdb/db/engine/storagegroup/TTLTest.java | 76 +-
.../engine/storagegroup/TsFileProcessorTest.java | 2 -
.../LocalConfigNodeMultiDataRegionTest.java | 94 -
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 90 +
.../iotdb/db/metadata/SchemaAdvancedTest.java | 202 --
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 1294 ----------
.../iotdb/db/metadata/SchemaImproveTest.java | 187 --
.../org/apache/iotdb/db/metadata/TemplateTest.java | 180 --
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 216 +-
.../db/metadata/mtree/disk/MemManagerTest.java | 111 -
.../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 | 77 +-
.../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 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 2 +-
.../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 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 2 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 2 +-
.../distribution/AggregationDistributionTest.java | 2 +-
.../node/process/AggregationNodeSerdeTest.java | 2 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 2 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 2 +-
.../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 | 700 ------
.../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 | 21 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 87 +-
.../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 | 4 +-
.../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 | 5 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +-
.../java/org/apache/iotdb/session/ISession.java | 12 +-
.../java/org/apache/iotdb/session/Session.java | 29 +-
.../apache/iotdb/session/SessionConnection.java | 22 +
.../org/apache/iotdb/session/pool/SessionPool.java | 20 +
site/src/main/.vuepress/config.js | 40 +-
.../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 | 46 -
.../src/main/thrift/confignode.thrift | 86 +-
.../src/main/thrift/iotconsensus.thrift | 20 +-
thrift/src/main/thrift/client.thrift | 9 +
.../tsfile/read/query/dataset/EmptyDataSet.java | 40 -
.../tsfile/read/reader/FakedTimeGenerator.java | 83 -
zeppelin-interpreter/pom.xml | 51 -
.../apache/zeppelin/iotdb/IoTDBInterpreter.java | 4 +-
679 files changed, 8736 insertions(+), 64616 deletions(-)