You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/12/25 17:06:06 UTC
[iotdb] branch lmh/addQueryMetrics updated (6bfd996b56 -> 24024b3f81)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/addQueryMetrics
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6bfd996b56 fix UT
add d98417554c add STATEMENT_EXECUTION
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)
add b203af5e33 [IOTDB-5127]Separate ISession and ISessionPool as a module (#8583)
add fd52a2f378 [IOTDB-5269] Fix PathPatternTree.getAllDevicePatterns (#8589)
add 9b4e8eda57 remove (#8597)
add 424528495c Turn down the max capacity of tsblock from scanOperator (#8599)
add 0e1dd1b8a2 Refine the inner structure of ClusterSchemaFetcher (#8603)
add 82ceb3586f Delete more stale query code (#8600)
add e5096bba7d Merge remote-tracking branch 'origin/master' into lmh/addQueryMetrics
add 24024b3f81 merge master
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 29 +-
cli/src/assembly/resources/tools/export-csv.bat | 2 +-
cli/src/assembly/resources/tools/export-csv.sh | 1 -
cli/src/assembly/resources/tools/export-tsfile.bat | 2 +-
cli/src/assembly/resources/tools/export-tsfile.sh | 1 -
cli/src/assembly/resources/tools/import-csv.bat | 2 +-
cli/src/assembly/resources/tools/import-csv.sh | 1 -
.../org/apache/iotdb/tool/AbstractCsvTool.java | 3 +
.../org/apache/iotdb/tool/AbstractTsFileTool.java | 2 +
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 18 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 24 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 10 +-
.../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 | 136 +-
.../iotdb/confignode/manager/ConsensusManager.java | 2 +-
.../apache/iotdb/confignode/manager/IManager.java | 19 +-
.../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 | 36 +-
.../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 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 8 +-
cross-tests/pom.xml | 125 --
.../tests/tools/importCsv/AbstractScript.java | 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/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 | 16 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 9 +-
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 | 16 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 11 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 4 +-
.../org/apache/iotdb/DataMigrationExample.java | 4 +-
.../iotdb/HybridTimeseriesSessionExample.java | 2 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 8 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 4 +-
.../iotdb/SyntaxConventionRelatedExample.java | 4 +-
.../java/org/apache/iotdb/flink/IoTDBSource.java | 2 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 2 +-
integration-test/import-control.xml | 12 +
integration-test/pom.xml | 36 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 105 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 2 +
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 11 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 5 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 36 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 32 +-
.../org/apache/iotdb/cli/it/AbstractScript.java | 4 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 2 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 305 +++++
.../IoTDBClusterNodeGetterIT.java} | 15 +-
.../it/{ => cluster}/IoTDBClusterRestartIT.java | 2 +-
.../IoTDBClusterRegionLeaderBalancingIT.java | 4 +-
.../{ => load}/IoTDBConfigNodeSwitchLeaderIT.java | 2 +-
.../it/partition/IoTDBPartitionDurableIT.java | 4 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 82 ++
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 40 +-
.../iotdb/session/it/IoTDBConnectionInfoIT.java | 2 +-
.../session/it/IoTDBSessionAlignedInsertIT.java | 4 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 4 +-
.../it/IoTDBSessionDisableMemControlIT.java | 4 +-
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 4 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 2 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 6 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 4 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 4 +-
.../org/apache/iotdb/session/it/SessionIT.java | 4 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 6 +-
.../org/apache/iotdb/tools/ExportCsvTestIT.java | 198 +++
.../org/apache/iotdb/tools/ExportTsFileTestIT.java | 198 +++
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 127 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 6 +-
.../session/IoTDBSessionAlignedABDeviceIT.java | 1 +
.../session/IoTDBSessionAlignedAggregationIT.java | 1 +
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 1 +
.../iotdb/session/IoTDBSessionIteratorIT.java | 3 +-
isession/pom.xml | 37 +
.../java/org/apache/iotdb/isession}/ISession.java | 46 +-
.../org/apache/iotdb/isession}/SessionConfig.java | 4 +-
.../org/apache/iotdb/isession}/SessionDataSet.java | 2 +-
.../apache/iotdb/isession/pool/ISessionPool.java | 392 +++---
.../isession}/pool/SessionDataSetWrapper.java | 29 +-
.../apache/iotdb/isession}/template/Template.java | 2 +-
.../iotdb/isession}/template/TemplateNode.java | 2 +-
.../apache/iotdb/isession/util/SystemStatus.java | 20 +-
.../org/apache/iotdb/isession}/util/Version.java | 2 +-
.../reporter/iotdb/InternalIoTDBReporter.java | 2 +-
.../iotdb/MemoryInternalIoTDBReporter.java | 4 +-
.../reporter/iotdb/SessionIoTDBReporter.java | 48 +-
.../reporter/prometheus/PrometheusReporter.java | 33 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 6 +-
.../resources/conf/iotdb-common.properties | 11 +-
.../org/apache/iotdb/commons/cluster/NodeType.java | 29 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 +
.../apache/iotdb/commons/path/PathPatternTree.java | 4 +
.../commons/service/metric/MetricService.java | 7 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +-
.../iotdb/commons/service/metric/enums/Tag.java | 3 +-
.../iotdb/commons/path/PathPatternTreeTest.java | 5 +-
pom.xml | 4 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 153 +--
.../schemaregion/rocksdb/mnode/RMNode.java | 5 +
.../rocksdb/RSchemaRegionAdvancedTest.java | 169 ---
.../schemaregion}/rocksdb/MRocksDBBenchmark.java | 8 +-
.../schemaregion}/rocksdb/MRocksDBUnitTest.java | 42 +-
.../rocksdb/RSchemaReadWriteHandlerTest.java | 6 +-
.../rocksdb/RocksDBBenchmarkEngine.java | 16 +-
.../rocksdb/RocksDBBenchmarkTask.java | 0
.../schemaregion}/rocksdb/RocksDBTestUtils.java | 4 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 163 +--
.../utils/ShowTimeSeriesResultUtils.java | 4 +-
.../tagSchemaRegion/TagSchemaRegionTest.java | 10 +-
.../idtable/IDTableWithDeviceIDListImplTest.java | 17 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 37 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 6 +-
.../iotdb/db/client/DataNodeInternalClient.java | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 30 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 15 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 14 +-
.../db/consensus/DataRegionConsensusImpl.java | 2 +
.../org/apache/iotdb/db/constant/SqlConstant.java | 66 +
.../iotdb/db/engine/flush/MemTableFlushTask.java | 4 +-
.../db/engine/querycontext/QueryDataSource.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../db/engine/storagegroup/TsFileResource.java | 14 +-
.../db/exception/index/IndexManagerException.java | 34 -
.../db/exception/index/IndexRuntimeException.java | 32 -
.../db/exception/index/QueryIndexException.java | 29 -
.../exception/query/LogicalOperatorException.java | 54 -
.../exception/query/LogicalOptimizeException.java | 46 -
.../db/exception/query/OutOfTTLException.java | 2 +-
.../exception/query/PathNumOverLimitException.java | 33 -
.../query/UnSupportedFillTypeException.java | 33 -
.../iotdb/db/exception/sql/SQLParserException.java | 35 -
.../exception/sql/StatementAnalyzeException.java | 13 -
.../iotdb/db/index/common/IndexConstant.java | 36 -
.../apache/iotdb/db/index/common/IndexType.java | 78 --
.../apache/iotdb/db/index/common/IndexUtils.java | 35 -
.../iotdb/db/localconfignode/LocalConfigNode.java | 2 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 595 +-------
.../db/metadata/cache/DataNodeSchemaCache.java | 4 -
.../idtable/entry/InsertMeasurementMNode.java | 5 +
.../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} | 45 +-
.../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} | 10 +-
.../IShowSchemaPlan.java} | 33 +-
.../schemaregion/read/IShowTimeSeriesPlan.java} | 20 +-
.../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 | 153 +--
.../schemaregion/SchemaRegionMemoryImpl.java | 382 +-----
.../schemaregion/SchemaRegionSchemaFileImpl.java | 332 +----
.../apache/iotdb/db/metadata/tag/TagManager.java | 17 +-
.../metadata/template/ClusterTemplateManager.java | 9 +-
.../iotdb/db/metadata/template/Template.java | 298 +---
.../db/metadata/utils/ResourceByPathUtils.java | 151 ---
.../metadata/visitor/SchemaExecutionVisitor.java | 8 +-
.../timerangeiterator/AggrWindowIterator.java | 4 +-
.../TimeRangeIteratorFactory.java | 2 +-
.../constant => common}/DataNodeEndPoints.java | 7 +-
.../db/mpp/common/filter/BasicFilterType.java | 189 ---
.../db/mpp/common/filter/BasicFunctionFilter.java | 191 ---
.../mpp/common/filter/FilterDeserializeUtil.java | 63 -
.../iotdb/db/mpp/common/filter/FunctionFilter.java | 91 --
.../iotdb/db/mpp/common/filter/InFilter.java | 230 ----
.../iotdb/db/mpp/common/filter/LikeFilter.java | 152 ---
.../iotdb/db/mpp/common/filter/QueryFilter.java | 354 -----
.../iotdb/db/mpp/common/filter/RegexpFilter.java | 150 --
.../db/mpp/common/header/ColumnHeaderConstant.java | 6 +-
.../execution/executor/RegionWriteExecutor.java | 2 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 12 +
.../operator/schema/DevicesSchemaScanOperator.java | 17 +-
.../schema/TimeSeriesSchemaScanOperator.java | 22 +-
.../execution/operator/source/SeriesScanUtil.java | 15 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 4 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 38 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 2 +
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 599 --------
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 10 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 230 ++++
.../analyze/schema/ClusterSchemaFetchExecutor.java | 207 +++
.../plan/analyze/schema/ClusterSchemaFetcher.java | 354 +++++
.../plan/analyze/{ => schema}/ISchemaFetcher.java | 2 +-
.../plan/analyze/{ => schema}/SchemaValidator.java | 2 +-
.../iotdb/db/mpp/plan/constant/FilterConstant.java | 103 --
.../db/mpp/plan/execution/QueryExecution.java | 4 +-
.../execution/config/sys/sync/ShowPipeTask.java | 2 +-
.../iotdb/db/mpp/plan/expression/ResultColumn.java | 146 --
.../visitor/OldIntermediateLayerVisitor.java | 461 -------
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 216 ++-
.../plan/parser/SqlParseError.java} | 7 +-
.../db/mpp/plan/parser/StatementGenerator.java | 13 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 2 +-
.../plan/planner/MemoryDistributionCalculator.java | 57 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 2 +-
.../SimpleFragmentParallelPlanner.java | 2 +-
.../db/mpp/plan/rewriter/DnfFilterOptimizer.java | 163 ---
.../db/mpp/plan/rewriter/IFilterOptimizer.java | 29 -
.../plan/rewriter/MergeSingleFilterOptimizer.java | 179 ---
.../db/mpp/plan/rewriter/RemoveNotOptimizer.java | 103 --
.../iotdb/db/mpp/plan/statement/Statement.java | 1 -
.../{constant => statement}/StatementType.java | 2 +-
.../plan/statement/component/SelectComponent.java | 2 +-
.../plan/statement/crud/DeleteDataStatement.java | 2 +-
.../crud/InsertMultiTabletsStatement.java | 2 +-
.../plan/statement/crud/InsertRowStatement.java | 2 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 2 +-
.../plan/statement/crud/InsertRowsStatement.java | 2 +-
.../mpp/plan/statement/crud/InsertStatement.java | 2 +-
.../plan/statement/crud/InsertTabletStatement.java | 2 +-
.../plan/statement/crud/LoadTsFileStatement.java | 2 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 2 +-
.../InternalCreateTimeSeriesStatement.java | 2 +-
.../statement/internal/SchemaFetchStatement.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 2 +-
.../plan/statement/metadata/CountStatement.java | 2 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 2 +-
.../metadata/CreateContinuousQueryStatement.java | 2 +-
.../metadata/CreateFunctionStatement.java | 2 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 2 +-
.../metadata/CreateTimeSeriesStatement.java | 2 +-
.../statement/metadata/CreateTriggerStatement.java | 2 +-
.../metadata/DeleteStorageGroupStatement.java | 2 +-
.../metadata/DeleteTimeSeriesStatement.java | 2 +-
.../metadata/DropContinuousQueryStatement.java | 2 +-
.../statement/metadata/DropFunctionStatement.java | 2 +-
.../statement/metadata/DropTriggerStatement.java | 2 +-
.../metadata/SetStorageGroupStatement.java | 2 +-
.../plan/statement/metadata/SetTTLStatement.java | 2 +-
.../metadata/ShowContinuousQueriesStatement.java | 2 +-
.../mpp/plan/statement/metadata/ShowStatement.java | 2 +-
.../plan/statement/metadata/UnSetTTLStatement.java | 2 +-
.../template/ActivateTemplateStatement.java | 2 +-
.../template/CreateSchemaTemplateStatement.java | 2 +-
.../template/DeactivateTemplateStatement.java | 2 +-
.../template/DropSchemaTemplateStatement.java | 2 +-
.../template/SetSchemaTemplateStatement.java | 2 +-
.../ShowNodesInSchemaTemplateStatement.java | 2 +-
.../template/ShowPathSetTemplateStatement.java | 2 +-
.../template/ShowPathsUsingTemplateStatement.java | 2 +-
.../template/ShowSchemaTemplateStatement.java | 2 +-
.../template/UnsetSchemaTemplateStatement.java | 2 +-
.../db/mpp/plan/statement/sys/AuthorStatement.java | 2 +-
.../plan/statement/sys/ClearCacheStatement.java | 2 +-
.../db/mpp/plan/statement/sys/FlushStatement.java | 2 +-
.../statement/sys/LoadConfigurationStatement.java | 2 +-
.../db/mpp/plan/statement/sys/MergeStatement.java | 2 +-
.../statement/sys/SetSystemStatusStatement.java | 2 +-
.../sys/sync/CreatePipeSinkStatement.java | 2 +-
.../statement/sys/sync/CreatePipeStatement.java | 2 +-
.../statement/sys/sync/DropPipeSinkStatement.java | 2 +-
.../plan/statement/sys/sync/DropPipeStatement.java | 2 +-
.../statement/sys/sync/StartPipeStatement.java | 2 +-
.../plan/statement/sys/sync/StopPipeStatement.java | 2 +-
.../db/mpp/transformation/dag/udf/UDTFContext.java | 8 -
...fluxSQLConstant.java => InfluxSqlConstant.java} | 15 +-
.../influxdb/function/InfluxFunctionFactory.java | 24 +-
.../function/aggregator/InfluxCountFunction.java | 4 +-
.../function/aggregator/InfluxMeanFunction.java | 4 +-
.../function/aggregator/InfluxMedianFunction.java | 4 +-
.../function/aggregator/InfluxModeFunction.java | 4 +-
.../function/aggregator/InfluxSpreadFunction.java | 4 +-
.../function/aggregator/InfluxStddevFunction.java | 4 +-
.../function/aggregator/InfluxSumFunction.java | 4 +-
.../function/selector/InfluxFirstFunction.java | 4 +-
.../function/selector/InfluxLastFunction.java | 4 +-
.../function/selector/InfluxMaxFunction.java | 4 +-
.../function/selector/InfluxMinFunction.java | 4 +-
.../influxdb/handler/AbstractQueryHandler.java | 202 +--
.../protocol/influxdb/handler/NewQueryHandler.java | 20 +-
.../protocol/influxdb/input/InfluxLineParser.java | 2 +-
.../influxdb/operator/InfluxQueryOperator.java | 38 -
.../influxdb/parser/InfluxDBAstVisitor.java | 321 +++++
.../InfluxDBStatementGenerator.java} | 25 +-
.../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 298 ----
.../influxdb/statement/InfluxQueryStatement.java | 57 +
.../InfluxSelectComponent.java | 21 +-
.../db/protocol/influxdb/util/FilterUtils.java | 20 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 22 +-
.../org/apache/iotdb/db/protocol/mqtt/Message.java | 11 +
.../db/protocol/mqtt/PayloadFormatManager.java | 19 +-
.../db/protocol/rest/handler/ExceptionHandler.java | 3 +-
.../rest/handler/ExecuteStatementHandler.java | 2 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 4 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 4 +-
.../iotdb/db/qp/constant/FilterConstant.java | 114 --
.../apache/iotdb/db/qp/constant/SQLConstant.java | 285 ----
.../org/apache/iotdb/db/qp/logical/Operator.java | 200 ---
.../db/qp/logical/crud/BasicFunctionOperator.java | 172 ---
.../db/qp/logical/crud/BasicOperatorType.java | 191 ---
.../iotdb/db/qp/logical/crud/FilterOperator.java | 295 ----
.../iotdb/db/qp/logical/crud/FromComponent.java | 41 -
.../iotdb/db/qp/logical/crud/FunctionOperator.java | 48 -
.../iotdb/db/qp/logical/crud/QueryOperator.java | 106 --
.../iotdb/db/qp/logical/crud/SelectComponent.java | 139 --
.../db/qp/logical/crud/SpecialClauseComponent.java | 162 ---
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 310 -----
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 380 ------
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 287 ----
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 131 --
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 121 --
.../iotdb/db/qp/utils/GroupByLevelController.java | 327 -----
.../db/query/control/QueryResourceManager.java | 14 -
.../db/query/dataset/ShowTimeSeriesResult.java | 196 ---
.../apache/iotdb/db/query/filter/TsFileFilter.java | 31 -
.../query/reader/series/AlignedSeriesReader.java | 109 --
.../reader/series/SeriesRawDataBatchReader.java | 140 --
.../iotdb/db/query/reader/series/SeriesReader.java | 1430 --------------------
.../java/org/apache/iotdb/db/service/DataNode.java | 421 ++++--
.../db/service/DataNodeServerCommandLine.java | 18 +-
.../db/service/metrics/IoTDBInternalReporter.java | 28 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 99 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../thrift/impl/NewInfluxDBServiceImpl.java | 17 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 4 +-
.../iotdb/db/sync/pipedata/load/ILoader.java | 4 +-
.../db/sync/transport/server/ReceiverManager.java | 2 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 2 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 2 +-
.../db/tools/watermark/WatermarkDetector.java | 9 +-
.../iotdb/db/utils/AlignedValueIterator.java | 59 -
.../org/apache/iotdb/db/utils/CommonUtils.java | 10 +-
.../iotdb/db/{qp => }/utils/DateTimeUtils.java | 2 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 -
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 15 -
.../java/org/apache/iotdb/db/utils/FilesUtils.java | 43 -
.../iotdb/db/utils/IExpressionDeserializeUtil.java | 51 -
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 133 --
.../org/apache/iotdb/db/utils/SchemaUtils.java | 20 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 46 +-
.../org/apache/iotdb/db/utils/ValueIterator.java | 56 -
.../timerangeiterator/AggrWindowIterator.java | 165 ---
.../timerangeiterator/ITimeRangeIterator.java | 39 -
.../timerangeiterator/PreAggrWindowIterator.java | 158 ---
.../PreAggrWindowWithNaturalMonthIterator.java | 123 --
.../TimeRangeIteratorFactory.java | 69 -
.../db/wal/recover/file/TsFilePlanRedoer.java | 2 +-
.../FastCrossCompactionPerformerTest.java | 71 +-
.../ReadPointCompactionPerformerTest.java | 66 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 163 +--
...sSpaceCompactionWithReadPointPerformerTest.java | 163 +--
.../inner/InnerCompactionMoreDataTest.java | 28 +-
.../SizeTieredCompactionRecoverTest.java | 230 ++--
.../compaction/utils/CompactionCheckerUtils.java | 24 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 104 +-
.../iotdb/db/metadata/SchemaAdvancedTest.java | 202 ---
.../iotdb/db/metadata/SchemaImproveTest.java | 187 ---
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 216 +--
.../db/metadata/mtree/disk/MemManagerTest.java | 111 --
.../schemaRegion/AbstractSchemaRegionTest.java | 2 +-
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 497 ++++++-
.../schemaRegion/SchemaRegionBasicTest.java | 458 ++++++-
.../schemaRegion/SchemaRegionManagementTest.java | 56 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 77 +-
.../schemaRegion/SchemaRegionTestUtil.java | 139 ++
.../db/mpp/execution/exchange/SinkHandleTest.java | 4 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 10 +-
.../operator/schema/CountMergeOperatorTest.java | 114 +-
.../operator/schema/SchemaCountOperatorTest.java | 68 +-
.../schema/SchemaFetchScanOperatorTest.java | 108 +-
.../schema/SchemaQueryScanOperatorTest.java | 85 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 1 +
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 2 +-
.../influxdb/sql/InfluxDBLogicalGeneratorTest.java | 70 -
.../sql/InfluxDBStatementGeneratorTest.java | 87 ++
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 10 +-
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 2 +
.../db/query/dataset/ShowDevicesResultTest.java | 43 -
.../db/query/dataset/ShowTimeSeriesResultTest.java | 70 -
.../iotdb/db/query/dataset/SingleDataSetTest.java | 109 --
.../org/apache/iotdb/db/tools/MLogParserTest.java | 87 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 3 +
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 12 +-
.../iotdb/db/utils/TimeRangeIteratorTest.java | 298 ----
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +-
session/pom.xml | 6 +
.../java/org/apache/iotdb/session/Session.java | 17 +-
.../apache/iotdb/session/SessionConnection.java | 24 +
.../org/apache/iotdb/session/pool/SessionPool.java | 327 +++--
.../iotdb/session/template/InternalNode.java | 1 +
.../iotdb/session/template/MeasurementNode.java | 1 +
.../apache/iotdb/session/SessionCacheLeaderUT.java | 1 +
site/src/main/.vuepress/config.js | 40 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 2 +-
.../src/main/thrift/confignode.thrift | 78 +-
.../src/main/thrift/iotconsensus.thrift | 20 +-
thrift/src/main/thrift/client.thrift | 9 +
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 2 +-
zeppelin-interpreter/pom.xml | 51 -
.../apache/zeppelin/iotdb/IoTDBInterpreter.java | 4 +-
463 files changed, 8524 insertions(+), 18100 deletions(-)
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/AbstractScript.java
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
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 (99%)
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%)
create mode 100644 isession/pom.xml
copy {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/ISession.java (93%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/SessionConfig.java (96%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/SessionDataSet.java (99%)
rename session/src/main/java/org/apache/iotdb/session/ISession.java => isession/src/main/java/org/apache/iotdb/isession/pool/ISessionPool.java (81%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/pool/SessionDataSetWrapper.java (80%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/template/Template.java (98%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/template/TemplateNode.java (97%)
copy server/src/main/java/org/apache/iotdb/db/exception/index/DistanceMetricException.java => isession/src/main/java/org/apache/iotdb/isession/util/SystemStatus.java (69%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/util/Version.java (95%)
rename server/src/main/java/org/apache/iotdb/db/qp/logical/crud/WhereComponent.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
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%)
rename schema-engine-rocksdb/src/test/{org.apache.iotdb.db/metadata => org/apache/iotdb/db/metadata/schemaregion}/rocksdb/RocksDBBenchmarkEngine.java (92%)
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%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/constant/SqlConstant.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/index/IndexManagerException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/index/IndexRuntimeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/index/QueryIndexException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/query/LogicalOperatorException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/query/LogicalOptimizeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/query/PathNumOverLimitException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/query/UnSupportedFillTypeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sql/SQLParserException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/index/common/IndexConstant.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/index/common/IndexType.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/index/common/IndexUtils.java
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/ShowDevicesPlan.java => metadata/plan/schemaregion/impl/read/ShowDevicesPlanImpl.java} (54%)
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%)
rename 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%)
copy 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/{exception/index/DistanceMetricException.java => metadata/plan/schemaregion/read/IShowDevicesPlan.java} (75%)
rename server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/{impl/RollbackPreDeleteTimeSeriesPlanImpl.java => read/IShowSchemaPlan.java} (57%)
rename server/src/main/java/org/apache/iotdb/db/{exception/index/IllegalIndexParamException.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%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{plan/constant => common}/DataNodeEndPoints.java (93%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/BasicFilterType.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/BasicFunctionFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/FilterDeserializeUtil.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/FunctionFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/InFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/LikeFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/QueryFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/RegexpFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/AutoCreateSchemaExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetchExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetcher.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/{ => schema}/ISchemaFetcher.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/{ => schema}/SchemaValidator.java (98%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/constant/FilterConstant.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/ResultColumn.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/visitor/OldIntermediateLayerVisitor.java
rename server/src/main/java/org/apache/iotdb/db/{qp/strategy/SQLParseError.java => mpp/plan/parser/SqlParseError.java} (93%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/DnfFilterOptimizer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/IFilterOptimizer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/MergeSingleFilterOptimizer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/RemoveNotOptimizer.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/{constant => statement}/StatementType.java (98%)
rename server/src/main/java/org/apache/iotdb/db/protocol/influxdb/constant/{InfluxSQLConstant.java => InfluxSqlConstant.java} (92%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/operator/InfluxQueryOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/parser/InfluxDBAstVisitor.java
rename server/src/main/java/org/apache/iotdb/db/protocol/influxdb/{sql/InfluxDBLogicalGenerator.java => parser/InfluxDBStatementGenerator.java} (76%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBSqlVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/influxdb/statement/InfluxQueryStatement.java
rename server/src/main/java/org/apache/iotdb/db/protocol/influxdb/{operator => statement}/InfluxSelectComponent.java (83%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/constant/FilterConstant.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/constant/SQLConstant.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/Operator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/BasicFunctionOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/BasicOperatorType.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/FilterOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/FromComponent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/FunctionOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/QueryOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SelectComponent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SpecialClauseComponent.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/PhysicalPlan.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/CreateTimeSeriesPlan.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/ShowTimeSeriesPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/utils/GroupByLevelController.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/ShowTimeSeriesResult.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/filter/TsFileFilter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/AlignedSeriesReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesRawDataBatchReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/AlignedValueIterator.java
rename server/src/main/java/org/apache/iotdb/db/{qp => }/utils/DateTimeUtils.java (99%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/FilesUtils.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/IExpressionDeserializeUtil.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/ValueIterator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/AggrWindowIterator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/ITimeRangeIterator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowIterator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/PreAggrWindowWithNaturalMonthIterator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/timerangeiterator/TimeRangeIteratorFactory.java
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/SchemaImproveTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/disk/MemManagerTest.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/protocol/influxdb/sql/InfluxDBLogicalGeneratorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBStatementGeneratorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/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/utils/TimeRangeIteratorTest.java