This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch transform-filter-planner
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1bb41f39e9 transform node
add 83590e9f08 [IOTDB-3034] Partial insert in new cluster (#5763)
add de84a863a7 [IOTDB-2845] Implementation of DeviceMergeOperator (#5791)
add 241c36a50b [IOTDB-3096] [Auth] fix default config of user folder and
role folder (#5797)
add 06b9e14ea6 [IOTDB-3080] Implementation of AlignedSeriesScanOperator
(#5792)
add 41a33ffcad Return Option<TsBlock> instead of TsBlock to let caller
clearly be aware of that the method will return null (#5777)
add c98719fb4a [IOTDB-3057]Auto create schema (#5770)
add f9fcfa1fd5 [IOTDB-3084] Support schema fetch across sg (#5795)
add a67a260d23 implement visitSeriesAggregate in localExecutionPlanner
(#5801)
add f9b3b0f8d2 [IOTDB-3104] Add Consensus Module StateMachine Event API
(#5806)
add 38473d1a00 Fix the issue that sometimes the FragmentInstance may stuck
in FLUSHING states (#5808)
add a01199d22c [IOTDB-2987] Optimize ConfigNodeGroup startup process
(#5802)
add 602b4f408d Optimize the logger recording of MPP (#5815)
add bb4ccb3d89 [IOTDB-3103] Implementation of
NonOverlappedMultiColumnMerger (#5805)
add 27390d65f8 push down limit to rawdatasetwithValueFilter (#5813)
add 2031319c2d [IOTDB-3016] do flush when graceful stop IoTDB (#5800)
add e76b727f98 add compaction speed log (#5826)
add be385cd2db [IOTDB-3047] Path does not exist when delete storage group
(#5738)
add 104da23532 [IOTDB-2962] [IOTDB-3079] Refactor SQL parser and
implememtation of complete Analyzer (#5819)
new b080dff453 Merge branch 'master' of github.com:apache/iotdb into
transform-filter-planner
new 35e02aedb6 TransformNode & FilterNode
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:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 67 +-
.../resources/conf/iotdb-confignode.properties | 179 +++--
confignode/src/assembly/resources/conf/logback.xml | 2 +-
...lientPool.java => AsyncDataNodeClientPool.java} | 11 +-
.../client/SyncConfigNodeClientPool.java | 107 +++
.../iotdb/confignode/conf/ConfigNodeConf.java | 126 +--
.../iotdb/confignode/conf/ConfigNodeConfCheck.java | 155 ----
.../iotdb/confignode/conf/ConfigNodeConstant.java | 6 +-
.../confignode/conf/ConfigNodeDescriptor.java | 62 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 356 +++++++++
.../consensus/request/ConfigRequest.java | 38 +-
.../consensus/request/ConfigRequestType.java | 37 +-
.../consensus/request/auth/AuthorReq.java | 68 +-
.../request/read/GetDataPartitionReq.java | 9 +-
.../request/read/GetSchemaPartitionReq.java | 5 +-
...torageGroupReq.java => ApplyConfigNodeReq.java} | 32 +-
.../request/write/CreateDataPartitionReq.java | 13 +-
.../consensus/request/write/CreateRegionsReq.java | 4 +-
.../request/write/CreateSchemaPartitionReq.java | 8 +-
.../consensus/request/write/DeleteRegionsReq.java | 4 +-
.../request/write/RegisterDataNodeReq.java | 4 +-
.../request/write/SetStorageGroupReq.java | 4 +-
.../response/DataNodeConfigurationResp.java | 11 +-
.../statemachine/PartitionRegionStateMachine.java | 4 +-
.../confignode/manager/ClusterSchemaManager.java | 12 +-
.../iotdb/confignode/manager/ConfigManager.java | 83 +-
.../iotdb/confignode/manager/ConsensusManager.java | 67 +-
.../apache/iotdb/confignode/manager/Manager.java | 28 +-
.../{DataNodeManager.java => NodeManager.java} | 74 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 22 +-
.../confignode/persistence/ClusterSchemaInfo.java | 2 +
.../{DataNodeInfo.java => NodeInfo.java} | 126 ++-
.../executor/ConfigRequestExecutor.java | 49 +-
.../iotdb/confignode/service/ConfigNode.java | 30 +-
.../confignode/service/ConfigNodeCommandLine.java | 24 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 37 +-
.../consensus/request/ConfigRequestSerDeTest.java | 62 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 16 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 40 +-
.../org/apache/iotdb/consensus/common/Peer.java | 5 +
.../ratis/ApplicationStateMachineProxy.java | 36 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 53 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 47 +-
.../apache/iotdb/consensus/EmptyStateMachine.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 13 +-
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 2 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 37 +-
.../apache/iotdb/consensus/ratis/UtilsTest.java | 4 +-
.../standalone/StandAloneConsensusTest.java | 2 +-
.../IoTDBSyntaxConventionStringLiteralIT.java | 8 +-
.../IoTDBDeletionVersionAdaptionIT.java | 2 +
.../IoTDBQueryVersionAdaptionIT.java | 2 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 4 +
.../org/apache/iotdb/commons/path/PartialPath.java | 2 +
.../apache/iotdb/commons/utils/CommonUtils.java | 59 --
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 188 +++++
.../commons/utils/ThriftCommonsSerDeUtils.java | 27 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 24 +-
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 62 ++
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 28 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 18 +-
server/src/assembly/resources/sbin/stop-server.sh | 47 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 5 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 +
.../consensus/statemachine/BaseStateMachine.java | 2 +-
.../statemachine/SchemaRegionStateMachine.java | 5 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 19 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 7 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 28 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 14 +
.../iotdb/db/metadata/LocalSchemaProcessor.java | 5 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 151 +---
.../iotdb/db/metadata/cache/SchemaCacheEntity.java | 114 ---
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 58 ++
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 4 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 4 +
.../iotdb/db/mpp/common/header/ColumnHeader.java | 81 +-
.../iotdb/db/mpp/common/header/DatasetHeader.java | 2 +-
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 76 +-
.../db/mpp/common/schematree/PathPatternTree.java | 35 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 74 +-
.../common/schematree/node/SchemaInternalNode.java | 7 +-
.../execution/datatransfer/DataBlockManager.java | 41 +-
.../db/mpp/execution/datatransfer/SinkHandle.java | 71 +-
.../mpp/execution/datatransfer/SourceHandle.java | 78 +-
.../operator/process/DeviceMergeOperator.java | 274 +++++++
.../operator/process/DeviceViewOperator.java | 8 +-
.../execution/operator/process/FilterOperator.java | 12 +-
.../operator/process/TimeJoinOperator.java | 36 +-
.../operator/process/TransformOperator.java | 24 +-
.../operator/process/merge/AscTimeComparator.java | 4 +-
.../operator/process/merge/ColumnMerger.java | 4 +-
.../operator/process/merge/DescTimeComparator.java | 4 +-
.../operator/process/merge/MultiColumnMerger.java | 4 +-
.../merge/NonOverlappedMultiColumnMerger.java | 87 +++
.../operator/process/merge/SingleColumnMerger.java | 28 +-
.../operator/process/merge/TimeComparator.java | 4 +-
.../operator/schema/DevicesSchemaScanOperator.java | 2 +-
...Operator.java => SchemaFetchMergeOperator.java} | 8 +-
...hOperator.java => SchemaFetchScanOperator.java} | 6 +-
...Operator.java => SchemaQueryMergeOperator.java} | 4 +-
...nOperator.java => SchemaQueryScanOperator.java} | 4 +-
.../schema/TimeSeriesSchemaScanOperator.java | 2 +-
.../operator/source/AlignedSeriesScanOperator.java | 149 ++++
.../operator/source/AlignedSeriesScanUtil.java | 10 +-
.../execution/operator/source/SeriesScanUtil.java | 20 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 138 +++-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 656 ++++++++++++++--
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 276 ++++++-
.../plan/analyze/ColumnPaginationController.java | 73 ++
.../db/mpp/plan/analyze/ConcatPathRewriter.java | 135 ++++
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 854 +++++++++++++++++++++
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 242 ++++++
.../mpp/plan/analyze/GroupByLevelController.java | 144 ++++
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 2 +-
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 23 +-
.../db/mpp/plan/execution/IQueryExecution.java | 4 +-
.../db/mpp/plan/execution/QueryExecution.java | 50 +-
.../mpp/plan/execution/config/ConfigExecution.java | 15 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 686 +++--------------
.../db/mpp/plan/parser/StatementGenerator.java | 21 +-
.../db/mpp/plan/planner/DistributionPlanner.java | 82 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 205 ++++-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 53 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 60 +-
.../planner/SimpleFragmentParallelPlanner.java | 6 +-
.../plan/planner/WriteFragmentParallelPlanner.java | 6 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 15 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 22 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 17 +-
.../plan/node/metedata/read/DevicesCountNode.java | 2 +-
.../node/metedata/read/DevicesSchemaScanNode.java | 2 +-
.../metedata/read/LevelTimeSeriesCountNode.java | 2 +-
...emaFetchNode.java => SchemaFetchMergeNode.java} | 45 +-
...hemaFetchNode.java => SchemaFetchScanNode.java} | 55 +-
...emaMergeNode.java => SchemaQueryMergeNode.java} | 20 +-
...chemaScanNode.java => SchemaQueryScanNode.java} | 12 +-
.../node/metedata/read/TimeSeriesCountNode.java | 2 +-
.../metedata/read/TimeSeriesSchemaScanNode.java | 2 +-
.../plan/planner/plan/node/process/FillNode.java | 33 +-
.../plan/planner/plan/node/process/FilterNode.java | 86 +--
.../planner/plan/node/process/TransformNode.java | 125 ++-
.../source/AlignedSeriesAggregationScanNode.java | 5 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +-
.../node/source/SeriesAggregationScanNode.java | 5 +-
.../planner/plan/node/source/SeriesScanNode.java | 4 +-
.../plan/node/write/InsertMultiTabletsNode.java | 11 +-
.../plan/planner/plan/node/write/InsertNode.java | 176 +++--
.../planner/plan/node/write/InsertRowNode.java | 378 +++++----
.../planner/plan/node/write/InsertRowsNode.java | 11 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 11 +-
.../planner/plan/node/write/InsertTabletNode.java | 482 ++++++------
.../planner/plan/parameter/FillDescriptor.java | 30 +-
.../plan/parameter/FilterNullParameter.java | 14 +-
.../plan/parameter/GroupByTimeParameter.java | 11 +
.../plan/planner/plan/parameter/OutputColumn.java | 2 +-
.../plan/rewriter/ColumnPaginationController.java | 145 ----
.../db/mpp/plan/rewriter/ConcatPathRewriter.java | 190 -----
.../db/mpp/plan/rewriter/WildcardsRemover.java | 375 ---------
.../db/mpp/plan/scheduler/ClusterScheduler.java | 14 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 1 -
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 28 +-
.../db/mpp/plan/statement/StatementVisitor.java | 35 -
.../plan/statement/component/FillComponent.java | 25 +-
.../statement/component/GroupByLevelComponent.java | 20 -
.../component/GroupByLevelController.java | 247 ------
.../mpp/plan/statement/component/ResultColumn.java | 113 +--
.../plan/statement/component/SelectComponent.java | 105 +--
.../plan/statement/component/WhereCondition.java | 16 +-
.../statement/crud/AggregationQueryStatement.java | 129 ----
.../plan/statement/crud/FillQueryStatement.java | 79 --
.../statement/crud/GroupByFillQueryStatement.java | 49 --
.../plan/statement/crud/GroupByQueryStatement.java | 61 --
.../plan/statement/crud/LastQueryStatement.java | 74 --
.../db/mpp/plan/statement/crud/QueryStatement.java | 213 ++---
.../plan/statement/crud/UDAFQueryStatement.java | 97 ---
.../plan/statement/crud/UDTFQueryStatement.java | 34 -
.../literal/BooleanLiteral.java} | 44 +-
.../mpp/plan/statement/literal/DoubleLiteral.java | 42 +-
.../db/mpp/plan/statement/literal/Literal.java | 59 ++
.../db/mpp/plan/statement/literal/LongLiteral.java | 42 +-
.../db/mpp/plan/statement/literal/NullLiteral.java | 34 +-
.../mpp/plan/statement/literal/StringLiteral.java | 38 +-
.../iotdb/db/qp/constant/FilterConstant.java | 11 +
.../iotdb/db/qp/logical/crud/InOperator.java | 4 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 451 +++++------
.../dataset/RawQueryDataSetWithValueFilter.java | 6 +-
.../iotdb/db/query/expression/Expression.java | 16 +-
.../iotdb/db/query/expression/ResultColumn.java | 12 +-
.../query/expression/binary/BinaryExpression.java | 42 +-
.../db/query/expression/leaf/ConstantOperand.java | 20 +-
.../query/expression/leaf/TimeSeriesOperand.java | 23 -
.../db/query/expression/leaf/TimestampOperand.java | 17 -
.../query/expression/multi/FunctionExpression.java | 35 -
.../db/query/expression/unary/InExpression.java | 8 +
.../db/query/expression/unary/LikeExpression.java | 8 +
.../query/expression/unary/RegularExpression.java | 8 +
.../db/query/expression/unary/UnaryExpression.java | 26 -
.../db/query/udf/core/executor/UDTFContext.java | 7 +
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 7 +
.../service/thrift/impl/InternalServiceImpl.java | 16 +-
.../db/sync/receiver/collector/Collector.java | 1 +
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 37 +-
.../db/sync/sender/manager/SchemaSyncManager.java | 4 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 6 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 6 +-
.../apache/iotdb/db/wal/utils/WALWriteUtils.java | 17 +
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 105 ++-
.../db/mpp/common/schematree/SchemaTreeTest.java | 3 +-
.../db/mpp/execution/ConfigExecutionTest.java | 23 +-
.../mpp/execution/datatransfer/SinkHandleTest.java | 3 +-
.../execution/datatransfer/SourceHandleTest.java | 1 +
.../operator/AlignedSeriesScanOperatorTest.java | 748 ++++++++++++++++++
.../execution/operator/AlignedSeriesTestUtil.java | 260 +++++++
.../operator/DeviceMergeOperatorTest.java | 547 +++++++++++++
.../execution/operator/DeviceViewOperatorTest.java | 8 +-
.../NonOverlappedMultiColumnMergerTest.java | 230 ++++++
.../execution/operator/TimeJoinOperatorTest.java | 2 +-
...rTest.java => SchemaFetchScanOperatorTest.java} | 12 +-
...rTest.java => SchemaQueryScanOperatorTest.java} | 6 +-
.../{AnalyzerTest.java => AnalyzeFailTest.java} | 7 +-
.../{AnalyzerTest.java => AnalyzeTest.java} | 37 +-
.../db/mpp/plan/plan/DistributionPlannerTest.java | 4 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 6 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 85 +-
.../read/DeviceSchemaScanNodeSerdeTest.java | 5 +-
.../metadata/read/SchemaFetchScanNodeTest.java | 51 ++
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 5 +-
.../plan/plan/node/process/FillNodeSerdeTest.java | 8 +-
.../plan/node/process/FilterNodeSerdeTest.java | 7 +-
.../write/InsertMultiTabletsNodeSerdeTest.java | 10 +-
.../plan/node/write/InsertRowNodeSerdeTest.java | 17 +-
.../plan/node/write/InsertRowsNodeSerdeTest.java | 2 +-
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 2 +-
.../plan/node/write/InsertTabletNodeSerdeTest.java | 16 +-
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 114 +++
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +-
.../java/org/apache/iotdb/session/Session.java | 19 +-
.../src/main/thrift/confignode.thrift | 48 +-
thrift/src/main/thrift/mpp.thrift | 1 +
.../iotdb/tsfile/read/common/block/TsBlock.java | 100 ++-
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 23 +
.../java/org/apache/iotdb/tsfile/utils/Pair.java | 8 +
.../tsfile/write/record/datapoint/DataPoint.java | 10 +-
244 files changed, 9722 insertions(+), 5467 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/{AsyncClientPool.java
=> AsyncDataNodeClientPool.java} (90%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/SyncConfigNodeClientPool.java
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfCheck.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeStartupCheck.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetStorageGroupReq.java
=> ApplyConfigNodeReq.java} (64%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/{DataNodeManager.java
=> NodeManager.java} (66%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/persistence/{DataNodeInfo.java
=> NodeInfo.java} (54%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{service =>
persistence}/executor/ConfigRequestExecutor.java (85%)
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/utils/CommonUtils.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/utils/NodeUrlUtils.java
create mode 100644
node-commons/src/test/java/org/apache/iotdb/commons/utils/NodeUrlUtilsTest.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/cache/SchemaCacheEntity.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/cache/SchemaCacheEntry.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/DeviceMergeOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/merge/NonOverlappedMultiColumnMerger.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{SchemaMergeOperator.java
=> SchemaFetchMergeOperator.java} (95%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{SchemaFetchOperator.java
=> SchemaFetchScanOperator.java} (96%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{SchemaMergeOperator.java
=> SchemaQueryMergeOperator.java} (96%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{SchemaScanOperator.java
=> SchemaQueryScanOperator.java} (96%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AlignedSeriesScanOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ColumnPaginationController.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ConcatPathRewriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ExpressionAnalyzer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ExpressionUtils.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/GroupByLevelController.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{SchemaFetchNode.java
=> SchemaFetchMergeNode.java} (56%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{SchemaFetchNode.java
=> SchemaFetchScanNode.java} (54%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{SeriesSchemaMergeNode.java
=> SchemaQueryMergeNode.java} (72%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{SchemaScanNode.java
=> SchemaQueryScanNode.java} (91%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/ColumnPaginationController.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/ConcatPathRewriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/WildcardsRemover.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/GroupByLevelController.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/AggregationQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/FillQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/GroupByFillQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/GroupByQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/LastQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/UDAFQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/UDTFQueryStatement.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/{planner/plan/parameter/FillDescriptor.java
=> statement/literal/BooleanLiteral.java} (53%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/Peer.java =>
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/literal/DoubleLiteral.java
(53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/literal/Literal.java
copy consensus/src/main/java/org/apache/iotdb/consensus/common/Peer.java =>
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/literal/LongLiteral.java
(54%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/Peer.java =>
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/literal/NullLiteral.java
(57%)
copy consensus/src/main/java/org/apache/iotdb/consensus/common/Peer.java =>
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/literal/StringLiteral.java
(57%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/AlignedSeriesScanOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/AlignedSeriesTestUtil.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/DeviceMergeOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/NonOverlappedMultiColumnMergerTest.java
rename
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/{SchemaFetchOperatorTest.java
=> SchemaFetchScanOperatorTest.java} (94%)
rename
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/{SchemaScanOperatorTest.java
=> SchemaQueryScanOperatorTest.java} (98%)
copy
server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/{AnalyzerTest.java =>
AnalyzeFailTest.java} (93%)
rename
server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/{AnalyzerTest.java =>
AnalyzeTest.java} (52%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/metadata/read/SchemaFetchScanNodeTest.java
