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 34f6df5194 open more log for org.apache.iotdb.db.engine
new 2c2323ebc7 add more log to show blocked jenkins task
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 e8104a499e [IOTDB-5277] SchemaRegion throws NPE when loading snapshot
(#8605)
add 30335b3a73 change docker images name from 1c1d to standalone,
including docs (#8596)
new c88028d3cf Merge remote-tracking branch 'origin/master' into
jenkins-disable-integration
The 2 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:
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 29 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 2 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 10 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 8 +-
docker/ReadMe.md | 4 +-
docker/src/main/DockerCompose/do-docker-build.sh | 18 +-
...pose-1c1d.yml => docker-compose-standalone.yml} | 2 +-
...file-1.0.0-1c1d => Dockerfile-1.0.0-standalone} | 0
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 6 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 6 +-
.../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 | 2 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 4 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 6 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 6 +-
.../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 | 2 +-
.../org/apache/iotdb/tools/ExportTsFileTestIT.java | 2 +-
.../session/IoTDBSessionAlignedABDeviceIT.java | 1 +
.../session/IoTDBSessionAlignedAggregationIT.java | 1 +
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 1 +
.../iotdb/session/IoTDBSessionIteratorIT.java | 3 +-
{example/tsfile => isession}/pom.xml | 10 +-
.../java/org/apache/iotdb/isession}/ISession.java | 42 +-
.../org/apache/iotdb/isession}/SessionConfig.java | 4 +-
.../org/apache/iotdb/isession}/SessionDataSet.java | 2 +-
.../apache/iotdb/isession/pool/ISessionPool.java | 388 +++---
.../isession}/pool/SessionDataSetWrapper.java | 29 +-
.../apache/iotdb/isession}/template/Template.java | 2 +-
.../iotdb/isession}/template/TemplateNode.java | 2 +-
.../apache/iotdb/isession/util/SystemStatus.java | 24 +-
.../org/apache/iotdb/isession}/util/Version.java | 2 +-
.../reporter/iotdb/SessionIoTDBReporter.java | 2 +-
.../resources/conf/iotdb-common.properties | 2 +-
.../apache/iotdb/commons/path/PathPatternTree.java | 4 +
.../iotdb/commons/path/PathPatternTreeTest.java | 5 +-
pom.xml | 1 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../iotdb/db/client/DataNodeInternalClient.java | 4 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2 +-
.../org/apache/iotdb/db/constant/SqlConstant.java | 66 +
.../engine/compaction/CompactionTaskManager.java | 5 +
.../db/engine/querycontext/QueryDataSource.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../db/engine/storagegroup/TsFileResource.java | 14 +-
.../exception/index/DistanceMetricException.java | 28 -
.../index/IllegalIndexParamException.java | 28 -
.../db/exception/index/IndexManagerException.java | 34 -
.../db/exception/index/IndexRuntimeException.java | 32 -
.../db/exception/index/QueryIndexException.java | 29 -
.../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 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 4 +
.../db/metadata/cache/DataNodeSchemaCache.java | 4 -
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 4 +-
.../db/metadata/utils/ResourceByPathUtils.java | 151 ---
.../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 --
.../execution/executor/RegionWriteExecutor.java | 2 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 12 +
.../execution/operator/source/SeriesScanUtil.java | 17 +-
.../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 +-
.../plan/planner/MemoryDistributionCalculator.java | 2 +-
.../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 | 4 +-
.../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 ---
.../iotdb/db/qp/logical/crud/WhereComponent.java | 40 -
.../iotdb/db/qp/utils/GroupByLevelController.java | 327 -----
.../db/query/control/QueryResourceManager.java | 14 -
.../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 --------------------
.../db/service/metrics/IoTDBInternalReporter.java | 4 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 4 +-
.../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 | 31 +-
.../engine/storagegroup/TsFileProcessorTest.java | 1 +
.../schemaRegion/SchemaRegionManagementTest.java | 43 +
.../db/mpp/execution/exchange/SinkHandleTest.java | 4 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 10 +-
.../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 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 3 +
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 12 +-
.../iotdb/db/utils/TimeRangeIteratorTest.java | 298 ----
server/src/test/resources/logback-test.xml | 1 +
session/pom.xml | 6 +
.../java/org/apache/iotdb/session/Session.java | 10 +-
.../apache/iotdb/session/SessionConnection.java | 2 +
.../org/apache/iotdb/session/pool/SessionPool.java | 309 +++--
.../iotdb/session/template/InternalNode.java | 1 +
.../iotdb/session/template/MeasurementNode.java | 1 +
.../apache/iotdb/session/SessionCacheLeaderUT.java | 1 +
.../test/java/org/apache/iotdb/db/sql/Cases.java | 2 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 2 +-
285 files changed, 2882 insertions(+), 10739 deletions(-)
rename docker/src/main/DockerCompose/{docker-compose-1c1d.yml =>
docker-compose-standalone.yml} (96%)
rename docker/src/main/{Dockerfile-1.0.0-1c1d => Dockerfile-1.0.0-standalone}
(100%)
copy {example/tsfile => isession}/pom.xml (86%)
copy {session/src/main/java/org/apache/iotdb/session =>
isession/src/main/java/org/apache/iotdb/isession}/ISession.java (94%)
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 (82%)
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
confignode/src/main/java/org/apache/iotdb/confignode/procedure/exception/ProcedureYieldException.java
=> isession/src/main/java/org/apache/iotdb/isession/util/SystemStatus.java
(70%)
rename {session/src/main/java/org/apache/iotdb/session =>
isession/src/main/java/org/apache/iotdb/isession}/util/Version.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/DistanceMetricException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/index/IllegalIndexParamException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/index/IndexManagerException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/index/IndexRuntimeException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/index/QueryIndexException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/query/LogicalOperatorException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/query/LogicalOptimizeException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/query/PathNumOverLimitException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/query/UnSupportedFillTypeException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/exception/sql/SQLParserException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/index/common/IndexConstant.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/index/common/IndexType.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/index/common/IndexUtils.java
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/logical/crud/WhereComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/utils/GroupByLevelController.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/filter/TsFileFilter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/AlignedSeriesReader.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesRawDataBatchReader.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReader.java
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/protocol/influxdb/sql/InfluxDBLogicalGeneratorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/protocol/influxdb/sql/InfluxDBStatementGeneratorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/utils/TimeRangeIteratorTest.java
