This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch groupbylevelOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 52002fcdbb fix conflict
add 63586ba2cc [IOTDB-2948] ConfigNode supports ClientPool (#5704)
add 6d89eed024 Fix bugs of batch insert (#5714)
add 83c59ef43c [IOTDB-3033] Completing the query and writing interface
compared to java (#5713)
add 01d81e78f7 [IOTDB-3028] Fix PartitionCache when there are ** in path
(#5709)
add 245621ca3b [IOTDB-3032]Fix storage group cache (#5711)
add 4c1abdd894 [IOTDB-3021] Fix sink/source handle memory leak (#5692)
add 3d028a7817 fix root.**.* (#5715)
add 2c1ef036ea ConfignodeClient reconnect without random pick (#5717)
add e438189fa6 [IOTDB-2994] Remove eclipse collection to reduce package
size (#5720)
add d8c06a80d3 [IOTDB-3036][Partition Cache] Add auto create judge when
get deviceToStorageGroupMap (#5719)
add eadc582377 [IOTDB-3030] delete storage group with ** error (#5718)
add 8f8dfa281a Fix NPE (#5722)
add c8d7d8144e [IOTDB-3037] Define all PlanNode in the query logical plan
(#5716)
add d75e5081e4 Predict data type for auto creating timeseries (#5724)
add 8f7fb57661 [IOTDB-3029] The prefix path generated by the select into
target sequence contains * and ** currently unchecked (#5723)
add f1ffc0a054 Support Create aligned timeseries (#5727)
add 5eb2308198 [IOTDB-3027] Feature/count storage group (#5728)
add 2cef18fb9b Fix some bugs (#5725)
add 1ddc50b749 Support order by time desc (#5729)
add be72769252 Add outputColumnNames in ExchangeNode (#5730)
add 8c6b8f82dc [IOTDB-2285] IoTDB Grafana Plugin: Grafana Connector Input
Style (#5661)
add 685ea15ed6 [IOTDB-3025] add permission check (#5699)
add 7cf013bff3 [IOTDB-3046] Fix port binding error in ClientManagerTest
(#5736)
add 76a4e43955 [IOTDB-3018] Fix compation bugs on handling deleted target
file and service shutdown deadlock (#5693)
add 20c527ffd3 [IOTDB-3026] fix cannot load tsfile correctly after restart
iotdb (#5702)
add 512f2ffd54 [IOTDB-3039] Add standalone recovery (#5731)
add 5b045e4864 [IOTDB-2993] Support IN, LIKE, and REGEXP expressions in
Transform Operator (#5739)
add d4647beaef [IOTDB-2803] support AlterTimeseries sql (#5735)
add 2e7812282f [IoTDB-2991] Equal size bucket sampling UDFs:
EQUAL_SIZE_BUCKET_OUTLIER_SAMPLE (#5682)
add 99adc9dae8 Move time partition calculation from StorageEngine to
StorageEngineV2 (#5708)
add 6f953aa7bb [IOTDB-3020][IOTDB-3022]Multi-thread MLog recovery & Fix
SchemaFile dirty page loses (#5695)
add 057a8b96cc [IOTDB-3042] ConfigNode stop process (#5755)
add c410efa8d2 fix restart lossing data when sender shutdonws with data
remain in memtable (#5740)
add 1529577219 [IOTDB-3048] Refactor binary transformer (#5744)
add cce491190e [IOTDB-3056] triggers support multi-level documents (#5759)
add 8a6031a3c1 [IOTDB-2972] implement local sink/source handle (#5732)
add f6abf3d1da move columnToTsBlockIndexMap from LogicalPlanner to
DistributionPlanner (#5733)
add a4a8656cec [IOTDB-2981] Modify antlr, IoTDBSqlVisitor and ASTVisitor
for new syntax convention (#5696)
add 10ab99946a rename package of mpp and confignode (#5758)
add b12aa03e32 [IOTDB-3075] RatisConsensus UUID bugfix (#5765)
add 93aa5b0775 [IOTDB-2870] Unit test of spliting insert node in new
cluster (#5769)
add 0af1aede62 Add SyncThriftClientErrorHandler for proxy to clean the
code (#5710)
add 38ca619b69 [IOTDB-2993][Bugfix] Support IN, LIKE, and REGEXP
expressions in Transform Operator (#5766)
add c58cc7e6b4 [IOTDB-2994] Separate RSchemaEngine into a separate module
(#5737)
add 5e6274c11e [IOTDB-3076]Optimize StandAloneConsensus read/write
performance && consensus modu… (#5768)
add 18053aee25 Fix Reflection can't find constructor bug (#5776)
add f40ae52eb5 Fix concurrent failure of testInsertMultiTabletPlanParallel
(#5767)
add c6f9d0a085 [IOTDB-2844] Implementation of Aggregator and Accumulator
(#5757)
add 60e9f0ced7 Fix conflicts
No new revisions were added by this update.
Summary of changes:
LICENSE | 9 +
README.md | 2 +-
README_ZH.md | 2 +-
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 9 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 139 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 15 +-
client-py/SessionAlignedTimeseriesExample.py | 18 +
client-py/SessionExample.py | 30 +
client-py/iotdb/Session.py | 132 +-
client-py/tests/tablet_performance_comparison.py | 4 +-
client-py/tests/test_one_device.py | 152 ++
.../iotdb/cluster/metadata/CSchemaProcessor.java | 6 +-
.../cluster/query/ClusterDataQueryExecutor.java | 6 +-
.../query/aggregate/ClusterAggregateExecutor.java | 2 +-
.../cluster/query/fill/ClusterFillExecutor.java | 2 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 2 +-
.../cluster/query/reader/ClusterReaderFactory.java | 3 +-
.../cluster/query/reader/ClusterTimeGenerator.java | 4 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 20 +-
.../log/snapshot/PartitionedSnapshotTest.java | 6 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 2 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 15 +-
.../iotdb/confignode/cli/TemporaryClient.java | 202 --
.../iotdb/confignode/client/AsyncClientPool.java | 105 +
.../client/handlers/InitRegionHandler.java | 56 +
.../consensus/request/ConfigRequest.java | 29 +-
.../consensus/request/ConfigRequestType.java | 1 +
.../request/read/CountStorageGroupReq.java | 86 +
.../request/read/GetDataPartitionReq.java | 145 ++
.../request/read/GetOrCountStorageGroupReq.java | 77 -
.../request/read/GetOrCreateDataPartitionReq.java | 119 +-
.../read/GetOrCreateSchemaPartitionReq.java | 76 +-
.../request/read/GetSchemaPartitionReq.java | 102 +
.../consensus/request/read/GetStorageGroupReq.java | 34 +
.../consensus/request/write/CreateRegionsReq.java | 20 +-
.../consensus/request/write/DeleteRegionsReq.java | 79 +
.../request/write/DeleteStorageGroupReq.java | 36 +-
.../request/write/SetStorageGroupReq.java | 4 -
.../statemachine/PartitionRegionStateMachine.java | 2 +-
.../confignode/manager/ClusterSchemaManager.java | 131 +-
.../iotdb/confignode/manager/ConfigManager.java | 35 +-
.../iotdb/confignode/manager/DataNodeManager.java | 4 +
.../iotdb/confignode/manager/LoadManager.java | 34 +
.../apache/iotdb/confignode/manager/Manager.java | 22 +-
.../iotdb/confignode/manager/PartitionManager.java | 6 +-
.../confignode/manager/PermissionManager.java | 11 +
.../iotdb/confignode/persistence/AuthorInfo.java | 128 +-
.../confignode/persistence/ClusterSchemaInfo.java | 44 +-
.../iotdb/confignode/persistence/DataNodeInfo.java | 14 +-
.../confignode/persistence/PartitionInfo.java | 80 +-
.../iotdb/confignode/service/ConfigNode.java | 27 +-
.../confignode/service/balancer/LoadBalancer.java | 37 -
.../service/executor/ConfigRequestExecutor.java | 21 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 29 +-
.../consensus/request/ConfigRequestSerDeTest.java | 89 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 22 +
.../utils/ConfigNodeEnvironmentUtils.java | 134 --
.../apache/iotdb/consensus/ConsensusFactory.java | 1 -
.../org/apache/iotdb/consensus/IStateMachine.java | 94 +
.../exception/IllegalPeerEndpointException.java | 32 +
.../ratis/ApplicationStateMachineProxy.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +-
.../iotdb/consensus/ratis/RequestMessage.java | 4 -
.../iotdb/consensus/ratis/SnapshotStorage.java | 4 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 79 +-
.../consensus/standalone/StandAloneConsensus.java | 102 +-
.../consensus/standalone/StandAloneServerImpl.java | 14 +-
.../consensus/statemachine/EmptyStateMachine.java | 63 -
.../consensus/statemachine/IStateMachine.java | 91 -
.../apache/iotdb/consensus/EmptyStateMachine.java | 63 +
.../apache/iotdb/consensus/ratis/TestUtils.java | 2 +-
.../iotdb/consensus/standalone/RecoveryTest.java | 94 +
.../standalone/StandAloneConsensusTest.java | 22 +-
.../Data-Concept/Data-Model-and-Terminology.md | 35 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 19 +-
docs/UserGuide/Process-Data/Select-Into.md | 6 +-
docs/UserGuide/Process-Data/Triggers.md | 9 +-
docs/UserGuide/Query-Data/Select-Expression.md | 74 +
docs/UserGuide/Query-Data/Without-Null.md | 8 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 453 +++-
.../Data-Concept/Data-Model-and-Terminology.md | 30 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 12 +-
docs/zh/UserGuide/Process-Data/Select-Into.md | 8 +-
docs/zh/UserGuide/Process-Data/Triggers.md | 7 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 76 +
docs/zh/UserGuide/Query-Data/Without-Null.md | 8 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 492 ++++-
.../org/apache/iotdb/DataMigrationExample.java | 2 +-
grafana-plugin/pkg/plugin/plugin.go | 77 +-
grafana-plugin/src/QueryEditor.tsx | 295 ++-
grafana-plugin/src/componments/AggregateFun.tsx | 44 +
grafana-plugin/src/componments/FillValue.tsx | 38 +
grafana-plugin/src/componments/GroupBy.tsx | 58 +
grafana-plugin/src/componments/SelectValue.tsx | 1 +
grafana-plugin/src/componments/TimeSeries.tsx | 82 +
grafana-plugin/src/componments/WhereValue.tsx | 1 +
grafana-plugin/src/datasource.ts | 66 +-
grafana-plugin/src/functions.ts | 3 +-
grafana-plugin/src/types.ts | 30 +-
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 2 +-
.../org/apache/iotdb/db/integration/IoTDBAsIT.java | 2 +-
.../db/integration/IoTDBCreateTimeseriesIT.java | 18 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 16 +-
.../iotdb/db/integration/IoTDBExecuteBatchIT.java | 6 +-
.../db/integration/IoTDBFloatPrecisionIT.java | 2 +-
.../iotdb/db/integration/IoTDBInsertNaNIT.java | 2 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 8 +-
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 23 +
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 24 +-
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 6 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 29 +-
.../integration/IoTDBSortedShowTimeseriesIT.java | 38 +-
.../db/integration/IoTDBSyntaxConventionIT.java | 468 -----
.../IoTDBSyntaxConventionIdentifierIT.java | 838 ++++++++
.../IoTDBSyntaxConventionStringLiteralIT.java | 764 +++++++
.../iotdb/db/integration/IoTDBTagAlterIT.java | 46 +-
.../apache/iotdb/db/integration/IoTDBTagIT.java | 220 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 138 ++
.../aggregation/IoTDBAggregationIT.java | 5 +
.../db/integration/aligned/IoTDBDeletionIT.java | 16 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 56 +-
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 6 +-
.../IoTDBSyntaxConventionVersionAdaptionIT.java | 100 -
.../IoTDBWithoutNullAllFilterIT.java | 16 +-
.../IoTDBWithoutNullAnyFilterIT.java | 8 +-
.../session/IoTDBSessionSyntaxConventionIT.java | 39 +-
node-commons/pom.xml | 6 +
.../apache/iotdb/commons/client/ClientManager.java | 4 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 17 +-
.../sync/SyncDataNodeDataBlockServiceClient.java | 17 +-
.../sync/SyncDataNodeInternalServiceClient.java | 17 +-
.../commons/client/sync/SyncThriftClient.java | 25 +
.../sync/SyncThriftClientWithErrorHandler.java | 64 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 82 +-
.../iotdb/commons/consensus/DataRegionId.java | 39 +-
.../iotdb/commons/consensus/PartitionRegionId.java | 39 +-
.../iotdb/commons/consensus/SchemaRegionId.java | 39 +-
.../iotdb/commons/partition/DataPartition.java | 11 +-
.../iotdb/commons/partition/SchemaPartition.java | 11 +-
.../apache/iotdb/commons/ClientManagerTest.java | 57 +-
.../apache/iotdb/commons/ConsensusGroupIdTest.java | 4 +-
openapi/src/main/openapi3/iotdb-rest.yaml | 23 +
pom.xml | 1 +
schema-engine-rocksdb/README.md | 38 +
schema-engine-rocksdb/pom.xml | 80 +
.../resources/conf/schema-rocksdb.properties | 0
.../src/assembly/schema-engine-rocksdb.xml | 44 +
.../schemaregion/rocksdb/CheckKeyResult.java | 0
.../schemaregion/rocksdb/RSchemaConfLoader.java | 0
.../schemaregion/rocksdb/RSchemaConstants.java | 0
.../schemaregion/rocksdb/RSchemaLogger.java | 0
.../rocksdb/RSchemaReadWriteHandler.java | 0
.../schemaregion/rocksdb/RSchemaRegion.java | 1897 +++++++++++++++++
.../schemaregion/rocksdb/RSchemaUtils.java | 592 ++++++
.../schemaregion/rocksdb/mnode/REntityMNode.java | 0
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 0
.../schemaregion/rocksdb/mnode/RMNode.java | 0
.../schemaregion/rocksdb/mnode/RMNodeType.java | 0
.../rocksdb/mnode/RMNodeValueType.java | 0
.../rocksdb/mnode/RMeasurementMNode.java | 0
.../rocksdb/mnode/RStorageGroupMNode.java | 0
.../metadata}/rocksdb/MRocksDBBenchmark.java | 0
.../metadata}/rocksdb/MRocksDBUnitTest.java | 0
.../rocksdb/RSchemaReadWriteHandlerTest.java | 0
.../rocksdb/RSchemaRegionAdvancedTest.java | 0
.../metadata/rocksdb/RocksDBBenchmarkEngine.java | 153 ++
.../metadata}/rocksdb/RocksDBBenchmarkTask.java | 0
.../metadata}/rocksdb/RocksDBTestUtils.java | 0
server/pom.xml | 5 -
.../resources/conf/iotdb-engine.properties | 4 -
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 138 +-
.../db/auth/authorizer/AuthorizerManager.java | 46 +-
.../db/auth/authorizer/ClusterAuthorizer.java | 63 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 54 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 13 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 19 +-
.../consensus/statemachine/BaseStateMachine.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 16 +-
.../statemachine/SchemaRegionStateMachine.java | 6 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 4 +-
.../engine/compaction/CompactionTaskManager.java | 45 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 2 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 34 +-
.../utils/SingleSeriesCompactionExecutor.java | 2 +-
.../impl/ReadPointCompactionPerformer.java | 5 +-
.../compaction/task/AbstractCompactionTask.java | 19 +-
.../compaction/task/CompactionTaskSummary.java | 32 +
.../iotdb/db/engine/memtable/AbstractMemTable.java | 4 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 4 +-
.../iotdb/db/engine/modification/Modification.java | 2 +-
.../selectinto/InsertTabletPlansIterator.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 17 +-
.../db/engine/storagegroup/TsFileManager.java | 2 +-
.../db/engine/storagegroup/TsFileProcessor.java | 4 +-
.../metadata/SeriesOverflowException.java | 33 +
.../exception/sql/StatementAnalyzeException.java | 2 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 32 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 16 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 4 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 9 +-
.../mtree/store/disk/CachedMNodeContainer.java | 12 +-
.../mtree/store/disk/MTreeFlushTaskManager.java | 6 +-
.../mtree/store/disk/MTreeReleaseTaskManager.java | 3 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 73 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 10 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 13 +-
.../apache/iotdb/db/metadata/path/PartialPath.java | 32 +-
.../metadata/schemaregion/RSchemaRegionLoader.java | 111 +
.../db/metadata/schemaregion/SchemaEngine.java | 93 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 9 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 53 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 1900 -----------------
.../schemaregion/rocksdb/RSchemaUtils.java | 592 ------
.../db/metadata/tree/AbstractTreeVisitor.java | 62 +-
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 17 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 82 +-
.../db/metadata/utils/ResourceByPathUtils.java | 9 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 10 +-
.../iotdb/db/mpp/aggregation/Accumulator.java | 70 +
.../db/mpp/aggregation/AccumulatorFactory.java | 71 +
.../iotdb/db/mpp/aggregation/Aggregator.java | 122 ++
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 180 ++
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 101 +
.../db/mpp/aggregation/ExtremeAccumulator.java | 296 +++
.../db/mpp/aggregation/FirstValueAccumulator.java | 319 +++
.../mpp/aggregation/FirstValueDescAccumulator.java | 91 +
.../db/mpp/aggregation/LastValueAccumulator.java | 305 +++
.../mpp/aggregation/LastValueDescAccumulator.java | 135 ++
.../db/mpp/aggregation/MaxTimeAccumulator.java | 101 +
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 57 +
.../db/mpp/aggregation/MaxValueAccumulator.java | 270 +++
.../db/mpp/aggregation/MinTimeAccumulator.java | 105 +
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 41 +
.../db/mpp/aggregation/MinValueAccumulator.java | 270 +++
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 172 ++
.../iotdb/db/mpp/buffer/DataBlockManager.java | 387 ----
.../iotdb/db/mpp/buffer/DataBlockService.java | 137 --
.../iotdb/db/mpp/buffer/DataBlockServiceMBean.java | 34 -
.../mpp/buffer/DataBlockServiceThriftHandler.java | 44 -
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 73 -
.../db/mpp/buffer/IDataBlockManagerCallback.java | 24 -
.../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 80 -
.../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 60 -
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 417 ----
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 437 ----
.../iotdb/db/mpp/buffer/TsBlockSerdeFactory.java | 31 -
.../iotdb/db/mpp/common/MPPQueryContext.java | 2 +-
.../org/apache/iotdb/db/mpp/common/QueryId.java | 2 +-
.../iotdb/db/mpp/common/ResultNodeContext.java | 2 +-
.../db/mpp/common/filter/BasicFilterType.java | 4 +-
.../db/mpp/common/filter/BasicFunctionFilter.java | 4 +-
.../iotdb/db/mpp/common/filter/FunctionFilter.java | 2 +-
.../iotdb/db/mpp/common/filter/InFilter.java | 2 +-
.../iotdb/db/mpp/common/filter/LikeFilter.java | 2 +-
.../iotdb/db/mpp/common/filter/QueryFilter.java | 4 +-
.../iotdb/db/mpp/common/filter/RegexpFilter.java | 2 +-
.../iotdb/db/mpp/common/header/HeaderConstant.java | 10 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 2 +-
.../apache/iotdb/db/mpp/execution/Coordinator.java | 147 --
.../apache/iotdb/db/mpp/execution/DataDriver.java | 193 --
.../iotdb/db/mpp/execution/DataDriverContext.java | 63 -
.../org/apache/iotdb/db/mpp/execution/Driver.java | 452 ----
.../iotdb/db/mpp/execution/DriverContext.java | 55 -
.../iotdb/db/mpp/execution/ExecutionResult.java | 32 -
.../iotdb/db/mpp/execution/FragmentInfo.java | 44 -
.../db/mpp/execution/FragmentInstanceContext.java | 163 --
.../mpp/execution/FragmentInstanceExecution.java | 118 --
.../execution/FragmentInstanceFailureListener.java | 25 -
.../db/mpp/execution/FragmentInstanceInfo.java | 40 -
.../db/mpp/execution/FragmentInstanceManager.java | 229 ---
.../db/mpp/execution/FragmentInstanceState.java | 80 -
.../execution/FragmentInstanceStateMachine.java | 182 --
.../iotdb/db/mpp/execution/FragmentState.java | 71 -
.../org/apache/iotdb/db/mpp/execution/IDriver.java | 71 -
.../iotdb/db/mpp/execution/IQueryExecution.java | 44 -
.../iotdb/db/mpp/execution/QueryExecution.java | 325 ---
.../iotdb/db/mpp/execution/QueryStateMachine.java | 1 +
.../iotdb/db/mpp/execution/SchemaDriver.java | 45 -
.../db/mpp/execution/SchemaDriverContext.java | 37 -
.../mpp/execution/config/AuthorizerConfigTask.java | 76 -
.../db/mpp/execution/config/ConfigExecution.java | 161 --
.../db/mpp/execution/config/ConfigTaskResult.java | 61 -
.../db/mpp/execution/config/ConfigTaskVisitor.java | 54 -
.../iotdb/db/mpp/execution/config/IConfigTask.java | 26 -
.../mpp/execution/config/SetStorageGroupTask.java | 97 -
.../mpp/execution/config/ShowStorageGroupTask.java | 113 -
.../execution/datatransfer/DataBlockManager.java | 471 +++++
.../execution/datatransfer/DataBlockService.java | 137 ++
.../datatransfer/DataBlockServiceMBean.java | 34 +
.../DataBlockServiceThriftHandler.java | 44 +
.../execution/datatransfer/IDataBlockManager.java | 85 +
.../datatransfer/IDataBlockManagerCallback.java | 24 +
.../db/mpp/execution/datatransfer/ISinkHandle.java | 73 +
.../mpp/execution/datatransfer/ISourceHandle.java | 57 +
.../execution/datatransfer/LocalSinkHandle.java | 146 ++
.../execution/datatransfer/LocalSourceHandle.java | 125 ++
.../execution/datatransfer/SharedTsBlockQueue.java | 152 ++
.../db/mpp/execution/datatransfer/SinkHandle.java | 371 ++++
.../mpp/execution/datatransfer/SourceHandle.java | 400 ++++
.../datatransfer/TsBlockSerdeFactory.java | 31 +
.../iotdb/db/mpp/execution/driver/DataDriver.java | 193 ++
.../db/mpp/execution/driver/DataDriverContext.java | 64 +
.../iotdb/db/mpp/execution/driver/Driver.java | 452 ++++
.../db/mpp/execution/driver/DriverContext.java | 56 +
.../iotdb/db/mpp/execution/driver/IDriver.java | 71 +
.../db/mpp/execution/driver/SchemaDriver.java | 45 +
.../mpp/execution/driver/SchemaDriverContext.java | 38 +
.../db/mpp/execution/fragment/FragmentInfo.java | 44 +
.../fragment/FragmentInstanceContext.java | 164 ++
.../fragment/FragmentInstanceExecution.java | 119 ++
.../fragment/FragmentInstanceFailureListener.java | 25 +
.../execution/fragment/FragmentInstanceInfo.java | 40 +
.../fragment/FragmentInstanceManager.java | 232 +++
.../execution/fragment/FragmentInstanceState.java | 80 +
.../fragment/FragmentInstanceStateMachine.java | 183 ++
.../db/mpp/execution/fragment/FragmentState.java | 71 +
.../mpp/execution/memory/LocalMemoryManager.java | 43 +
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 202 ++
.../iotdb/db/mpp/execution/operator/Operator.java | 55 +
.../db/mpp/execution/operator/OperatorContext.java | 54 +
.../operator/process/AggregateOperator.java | 72 +
.../operator/process/DeviceViewOperator.java | 152 ++
.../execution/operator/process/FillOperator.java | 56 +
.../operator/process/FilterNullOperator.java | 57 +
.../execution/operator/process/FilterOperator.java | 155 ++
.../execution/operator/process/LimitOperator.java | 80 +
.../execution/operator/process/OffsetOperator.java | 57 +
.../operator/process/ProcessOperator.java | 24 +
.../execution/operator/process/SortOperator.java | 57 +
.../operator/process/TimeJoinOperator.java | 233 +++
.../operator/process/TransformOperator.java | 241 +++
.../operator/process/merge/AscTimeComparator.java | 33 +
.../operator/process/merge/ColumnMerger.java | 60 +
.../operator/process/merge/DescTimeComparator.java | 33 +
.../operator/process/merge/MultiColumnMerger.java | 96 +
.../operator/process/merge/SingleColumnMerger.java | 91 +
.../operator/process/merge/TimeComparator.java | 28 +
.../operator/schema/CountMergeOperator.java | 133 ++
.../operator/schema/DevicesCountOperator.java | 90 +
.../operator/schema/DevicesSchemaScanOperator.java | 83 +
.../schema/LevelTimeSeriesCountOperator.java | 100 +
.../operator/schema/SchemaFetchOperator.java | 128 ++
.../operator/schema/SchemaMergeOperator.java | 94 +
.../operator/schema/SchemaScanOperator.java | 112 +
.../operator/schema/TimeSeriesCountOperator.java | 90 +
.../schema/TimeSeriesSchemaScanOperator.java | 125 ++
.../operator/sink/FragmentSinkOperator.java | 66 +
.../mpp/execution/operator/sink/SinkOperator.java | 43 +
.../operator/source/AlignedSeriesScanUtil.java | 85 +
.../operator/source/DataSourceOperator.java | 26 +
.../operator/source/ExchangeOperator.java | 86 +
.../source/SeriesAggregateScanOperator.java | 461 +++++
.../operator/source/SeriesScanOperator.java | 153 ++
.../execution/operator/source/SeriesScanUtil.java | 1426 +++++++++++++
.../execution/operator/source/SourceOperator.java | 27 +
.../execution/schedule/AbstractDriverThread.java | 71 +
.../db/mpp/execution/schedule/DriverScheduler.java | 357 ++++
.../mpp/execution/schedule/DriverTaskThread.java | 85 +
.../schedule/DriverTaskTimeoutSentinelThread.java | 56 +
.../mpp/execution/schedule/ExecutionContext.java | 46 +
.../schedule/FragmentInstanceAbortedException.java | 35 +
.../mpp/execution/schedule/IDriverScheduler.java | 61 +
.../db/mpp/execution/schedule/ITaskScheduler.java | 72 +
.../iotdb/db/mpp/execution/schedule/queue/ID.java | 22 +
.../schedule/queue/IDIndexedAccessible.java | 48 +
.../schedule/queue/IndexedBlockingQueue.java | 201 ++
.../execution/schedule/queue/L1PriorityQueue.java | 102 +
.../execution/schedule/queue/L2PriorityQueue.java | 129 ++
.../db/mpp/execution/schedule/task/DriverTask.java | 217 ++
.../mpp/execution/schedule/task/DriverTaskID.java | 68 +
.../execution/schedule/task/DriverTaskStatus.java | 37 +
.../scheduler/AbstractFragInsStateTracker.java | 97 -
.../mpp/execution/scheduler/ClusterScheduler.java | 159 --
.../scheduler/FixedRateFragInsStateTracker.java | 86 -
.../scheduler/FragInstanceDispatchResult.java | 32 -
.../scheduler/IFragInstanceDispatcher.java | 37 -
.../scheduler/IFragInstanceStateTracker.java | 26 -
.../mpp/execution/scheduler/IQueryTerminator.java | 26 -
.../db/mpp/execution/scheduler/IScheduler.java | 40 -
.../scheduler/SimpleFragInstanceDispatcher.java | 102 -
.../execution/scheduler/SimpleQueryTerminator.java | 99 -
.../execution/scheduler/StandaloneScheduler.java | 113 -
.../iotdb/db/mpp/memory/LocalMemoryManager.java | 43 -
.../org/apache/iotdb/db/mpp/memory/MemoryPool.java | 185 --
.../org/apache/iotdb/db/mpp/operator/Operator.java | 55 -
.../iotdb/db/mpp/operator/OperatorContext.java | 54 -
.../db/mpp/operator/process/AggregateOperator.java | 57 -
.../mpp/operator/process/DeviceViewOperator.java | 152 --
.../db/mpp/operator/process/FillOperator.java | 56 -
.../mpp/operator/process/FilterNullOperator.java | 57 -
.../db/mpp/operator/process/FilterOperator.java | 155 --
.../db/mpp/operator/process/LimitOperator.java | 80 -
.../db/mpp/operator/process/OffsetOperator.java | 57 -
.../db/mpp/operator/process/ProcessOperator.java | 24 -
.../db/mpp/operator/process/SortOperator.java | 57 -
.../db/mpp/operator/process/TimeJoinOperator.java | 227 --
.../db/mpp/operator/process/TransformOperator.java | 241 ---
.../mpp/operator/process/merge/ColumnMerger.java | 60 -
.../operator/process/merge/MultiColumnMerger.java | 96 -
.../operator/process/merge/SingleColumnMerger.java | 124 --
.../db/mpp/operator/schema/CountMergeOperator.java | 133 --
.../mpp/operator/schema/DevicesCountOperator.java | 90 -
.../operator/schema/DevicesSchemaScanOperator.java | 83 -
.../schema/LevelTimeSeriesCountOperator.java | 100 -
.../mpp/operator/schema/SchemaFetchOperator.java | 128 --
.../mpp/operator/schema/SchemaMergeOperator.java | 94 -
.../db/mpp/operator/schema/SchemaScanOperator.java | 112 -
.../operator/schema/TimeSeriesCountOperator.java | 90 -
.../schema/TimeSeriesSchemaScanOperator.java | 125 --
.../db/mpp/operator/sink/FragmentSinkOperator.java | 66 -
.../iotdb/db/mpp/operator/sink/SinkOperator.java | 43 -
.../mpp/operator/source/AlignedSeriesScanUtil.java | 85 -
.../db/mpp/operator/source/DataSourceOperator.java | 26 -
.../db/mpp/operator/source/ExchangeOperator.java | 86 -
.../source/SeriesAggregateScanOperator.java | 476 -----
.../db/mpp/operator/source/SeriesScanOperator.java | 153 --
.../db/mpp/operator/source/SeriesScanUtil.java | 1417 -------------
.../db/mpp/operator/source/SourceOperator.java | 27 -
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 150 ++
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 123 ++
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 522 +++++
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 604 ++++++
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 121 ++
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 158 ++
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 99 +
.../db/mpp/plan/analyze/IPartitionFetcher.java | 43 +
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 44 +
.../iotdb/db/mpp/plan/analyze/QueryType.java | 24 +
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 57 +
.../plan/analyze/StandalonePartitionFetcher.java | 127 ++
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 89 +
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 77 +
.../iotdb/db/mpp/plan/constant/FilterConstant.java | 103 +
.../iotdb/db/mpp/plan/constant/StatementType.java | 139 ++
.../db/mpp/plan/execution/ExecutionResult.java | 32 +
.../db/mpp/plan/execution/IQueryExecution.java | 44 +
.../db/mpp/plan/execution/QueryExecution.java | 328 +++
.../execution/config/AuthorizerConfigTask.java | 76 +
.../mpp/plan/execution/config/ConfigExecution.java | 161 ++
.../plan/execution/config/ConfigTaskResult.java | 61 +
.../plan/execution/config/ConfigTaskVisitor.java | 68 +
.../execution/config/CountStorageGroupTask.java | 97 +
.../db/mpp/plan/execution/config/IConfigTask.java | 26 +
.../plan/execution/config/SetStorageGroupTask.java | 97 +
.../execution/config/ShowStorageGroupTask.java | 113 +
.../db/mpp/plan/optimization/PlanOptimizer.java | 26 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 2175 ++++++++++++++++++++
.../db/mpp/plan/parser/StatementGenerator.java | 409 ++++
.../db/mpp/plan/planner/DistributionPlanner.java | 567 +++++
.../mpp/plan/planner/IFragmentParallelPlaner.java | 38 +
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 584 ++++++
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 226 ++
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 388 ++++
.../planner/SimpleFragmentParallelPlanner.java | 146 ++
.../plan/planner/WriteFragmentParallelPlanner.java | 73 +
.../plan/planner/plan/DistributedQueryPlan.java | 57 +
.../db/mpp/plan/planner/plan/FragmentInstance.java | 177 ++
.../db/mpp/plan/planner/plan/LogicalQueryPlan.java | 45 +
.../db/mpp/plan/planner/plan/PlanFragment.java | 156 ++
.../iotdb/db/mpp/plan/planner/plan/SubPlan.java | 69 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 309 +++
.../db/mpp/plan/planner/plan/node/PlanNode.java | 118 ++
.../db/mpp/plan/planner/plan/node/PlanNodeId.java | 61 +
.../mpp/plan/planner/plan/node/PlanNodeType.java | 197 ++
.../mpp/plan/planner/plan/node/PlanNodeUtil.java | 116 ++
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 184 ++
.../planner/plan/node/SimplePlanNodeRewriter.java | 48 +
.../mpp/plan/planner/plan/node/WritePlanNode.java | 36 +
.../metedata/read/AbstractSchemaMergeNode.java | 61 +
.../node/metedata/read/CountSchemaMergeNode.java | 54 +
.../plan/node/metedata/read/DevicesCountNode.java | 68 +
.../node/metedata/read/DevicesSchemaScanNode.java | 110 +
.../metedata/read/LevelTimeSeriesCountNode.java | 98 +
.../plan/node/metedata/read/SchemaFetchNode.java | 78 +
.../plan/node/metedata/read/SchemaScanNode.java | 155 ++
.../node/metedata/read/SeriesSchemaMergeNode.java | 60 +
.../node/metedata/read/TimeSeriesCountNode.java | 68 +
.../metedata/read/TimeSeriesSchemaScanNode.java | 143 ++
.../node/metedata/write/AlterTimeSeriesNode.java | 298 +++
.../write/CreateAlignedTimeSeriesNode.java | 379 ++++
.../node/metedata/write/CreateTimeSeriesNode.java | 332 +++
.../planner/plan/node/process/AggregationNode.java | 186 ++
.../planner/plan/node/process/DeviceMergeNode.java | 149 ++
.../planner/plan/node/process/DeviceViewNode.java | 166 ++
.../planner/plan/node/process/ExchangeNode.java | 209 ++
.../plan/planner/plan/node/process/FillNode.java | 126 ++
.../plan/planner/plan/node/process/FilterNode.java | 115 ++
.../planner/plan/node/process/FilterNullNode.java | 128 ++
.../plan/node/process/GroupByLevelNode.java | 172 ++
.../planner/plan/node/process/GroupByTimeNode.java | 165 ++
.../plan/planner/plan/node/process/LimitNode.java | 128 ++
.../plan/planner/plan/node/process/OffsetNode.java | 119 ++
.../planner/plan/node/process/ProcessNode.java | 29 +
.../planner/plan/node/process/ProjectNode.java | 115 ++
.../plan/planner/plan/node/process/SortNode.java | 119 ++
.../planner/plan/node/process/TimeJoinNode.java | 135 ++
.../planner/plan/node/sink/FragmentSinkNode.java | 188 ++
.../mpp/plan/planner/plan/node/sink/SinkNode.java | 31 +
.../source/AlignedSeriesAggregationScanNode.java | 267 +++
.../plan/node/source/AlignedSeriesScanNode.java | 264 +++
.../node/source/SeriesAggregationScanNode.java | 317 +++
.../planner/plan/node/source/SeriesScanNode.java | 312 +++
.../plan/planner/plan/node/source/SourceNode.java | 36 +
.../planner/plan/node/write/BatchInsertNode.java | 40 +
.../plan/node/write/InsertMultiTabletsNode.java | 279 +++
.../plan/planner/plan/node/write/InsertNode.java | 252 +++
.../planner/plan/node/write/InsertRowNode.java | 621 ++++++
.../planner/plan/node/write/InsertRowsNode.java | 253 +++
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 289 +++
.../planner/plan/node/write/InsertTabletNode.java | 820 ++++++++
.../plan/parameter/AggregationDescriptor.java | 106 +
.../planner/plan/parameter/AggregationStep.java | 97 +
.../planner/plan/parameter/FillDescriptor.java | 69 +
.../plan/parameter/FilterNullParameter.java | 89 +
.../plan/parameter/GroupByTimeParameter.java | 173 ++
.../plan/planner/plan/parameter/InputLocation.java | 72 +
.../plan/planner/plan/parameter/OutputColumn.java | 91 +
.../plan/rewriter/ColumnPaginationController.java | 145 ++
.../db/mpp/plan/rewriter/ConcatPathRewriter.java | 190 ++
.../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 +
.../db/mpp/plan/rewriter/WildcardsRemover.java | 375 ++++
.../scheduler/AbstractFragInsStateTracker.java | 84 +
.../db/mpp/plan/scheduler/ClusterScheduler.java | 159 ++
.../scheduler/FixedRateFragInsStateTracker.java | 86 +
.../plan/scheduler/FragInstanceDispatchResult.java | 32 +
.../plan/scheduler/IFragInstanceDispatcher.java | 37 +
.../plan/scheduler/IFragInstanceStateTracker.java | 26 +
.../db/mpp/plan/scheduler/IQueryTerminator.java | 26 +
.../iotdb/db/mpp/plan/scheduler/IScheduler.java | 40 +
.../scheduler/SimpleFragInstanceDispatcher.java | 88 +
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 87 +
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 113 +
.../db/mpp/plan/statement/IConfigStatement.java | 36 +
.../iotdb/db/mpp/plan/statement/Statement.java | 67 +
.../iotdb/db/mpp/plan/statement/StatementNode.java | 32 +
.../db/mpp/plan/statement/StatementVisitor.java | 192 ++
.../plan/statement/component/FillComponent.java | 51 +
.../mpp/plan/statement/component/FillPolicy.java | 25 +
.../statement/component/FilterNullComponent.java | 97 +
.../plan/statement/component/FilterNullPolicy.java | 25 +
.../plan/statement/component/FromComponent.java | 42 +
.../statement/component/GroupByLevelComponent.java | 56 +
.../component/GroupByLevelController.java | 247 +++
.../statement/component/GroupByTimeComponent.java | 101 +
.../db/mpp/plan/statement/component/OrderBy.java | 28 +
.../mpp/plan/statement/component/ResultColumn.java | 205 ++
.../plan/statement/component/ResultSetFormat.java | 27 +
.../plan/statement/component/SelectComponent.java | 182 ++
.../plan/statement/component/WhereCondition.java | 43 +
.../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/InsertBaseStatement.java | 78 +
.../crud/InsertMultiTabletsStatement.java | 86 +
.../plan/statement/crud/InsertRowStatement.java | 128 ++
.../crud/InsertRowsOfOneDeviceStatement.java | 90 +
.../plan/statement/crud/InsertRowsStatement.java | 86 +
.../mpp/plan/statement/crud/InsertStatement.java | 101 +
.../plan/statement/crud/InsertTabletStatement.java | 104 +
.../plan/statement/crud/LastQueryStatement.java | 74 +
.../db/mpp/plan/statement/crud/QueryStatement.java | 354 ++++
.../plan/statement/crud/UDAFQueryStatement.java | 97 +
.../plan/statement/crud/UDTFQueryStatement.java | 34 +
.../metadata/AlterTimeSeriesStatement.java | 127 ++
.../statement/metadata/CountDevicesStatement.java | 34 +
.../metadata/CountLevelTimeSeriesStatement.java | 41 +
.../statement/metadata/CountNodesStatement.java | 31 +
.../plan/statement/metadata/CountStatement.java | 55 +
.../metadata/CountStorageGroupStatement.java | 42 +
.../metadata/CountTimeSeriesStatement.java | 34 +
.../metadata/CreateAlignedTimeSeriesStatement.java | 193 ++
.../metadata/CreateTimeSeriesStatement.java | 132 ++
.../statement/metadata/SchemaFetchStatement.java | 64 +
.../metadata/SetStorageGroupStatement.java | 64 +
.../statement/metadata/ShowDevicesStatement.java | 66 +
.../mpp/plan/statement/metadata/ShowStatement.java | 69 +
.../metadata/ShowStorageGroupStatement.java | 64 +
.../metadata/ShowTimeSeriesStatement.java | 87 +
.../db/mpp/plan/statement/sys/AuthorStatement.java | 209 ++
.../db/mpp/schedule/AbstractDriverThread.java | 71 -
.../iotdb/db/mpp/schedule/DriverScheduler.java | 357 ----
.../iotdb/db/mpp/schedule/DriverTaskThread.java | 85 -
.../schedule/DriverTaskTimeoutSentinelThread.java | 56 -
.../iotdb/db/mpp/schedule/ExecutionContext.java | 46 -
.../schedule/FragmentInstanceAbortedException.java | 35 -
.../iotdb/db/mpp/schedule/IDriverScheduler.java | 62 -
.../iotdb/db/mpp/schedule/ITaskScheduler.java | 72 -
.../org/apache/iotdb/db/mpp/schedule/queue/ID.java | 22 -
.../db/mpp/schedule/queue/IDIndexedAccessible.java | 48 -
.../mpp/schedule/queue/IndexedBlockingQueue.java | 201 --
.../db/mpp/schedule/queue/L1PriorityQueue.java | 102 -
.../db/mpp/schedule/queue/L2PriorityQueue.java | 129 --
.../iotdb/db/mpp/schedule/task/DriverTask.java | 217 --
.../iotdb/db/mpp/schedule/task/DriverTaskID.java | 68 -
.../db/mpp/schedule/task/DriverTaskStatus.java | 37 -
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 113 -
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 510 -----
.../mpp/sql/analyze/ClusterPartitionFetcher.java | 615 ------
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 117 --
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 158 --
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 97 -
.../db/mpp/sql/analyze/IPartitionFetcher.java | 43 -
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 44 -
.../apache/iotdb/db/mpp/sql/analyze/QueryType.java | 24 -
.../iotdb/db/mpp/sql/analyze/SchemaValidator.java | 57 -
.../sql/analyze/StandalonePartitionFetcher.java | 127 --
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 89 -
.../iotdb/db/mpp/sql/constant/FilterConstant.java | 103 -
.../iotdb/db/mpp/sql/constant/StatementType.java | 139 --
.../db/mpp/sql/optimization/PlanOptimizer.java | 26 -
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 2107 -------------------
.../db/mpp/sql/parser/StatementGenerator.java | 409 ----
.../db/mpp/sql/planner/DistributionPlanner.java | 562 -----
.../mpp/sql/planner/IFragmentParallelPlaner.java | 38 -
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 523 -----
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 408 ----
.../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 364 ----
.../sql/planner/SimpleFragmentParallelPlanner.java | 145 --
.../sql/planner/WriteFragmentParallelPlanner.java | 73 -
.../mpp/sql/planner/plan/DistributedQueryPlan.java | 57 -
.../db/mpp/sql/planner/plan/FragmentInstance.java | 177 --
.../db/mpp/sql/planner/plan/LogicalQueryPlan.java | 45 -
.../db/mpp/sql/planner/plan/PlanFragment.java | 133 --
.../iotdb/db/mpp/sql/planner/plan/SubPlan.java | 69 -
.../sql/planner/plan/node/PlanGraphPrinter.java | 309 ---
.../db/mpp/sql/planner/plan/node/PlanNode.java | 124 --
.../db/mpp/sql/planner/plan/node/PlanNodeId.java | 61 -
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 180 --
.../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 116 --
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 159 --
.../planner/plan/node/SimplePlanNodeRewriter.java | 48 -
.../mpp/sql/planner/plan/node/WritePlanNode.java | 36 -
.../metedata/read/AbstractSchemaMergeNode.java | 79 -
.../node/metedata/read/CountSchemaMergeNode.java | 54 -
.../plan/node/metedata/read/DevicesCountNode.java | 80 -
.../node/metedata/read/DevicesSchemaScanNode.java | 128 --
.../metedata/read/LevelTimeSeriesCountNode.java | 110 -
.../plan/node/metedata/read/SchemaFetchNode.java | 88 -
.../plan/node/metedata/read/SchemaScanNode.java | 155 --
.../node/metedata/read/SeriesSchemaMergeNode.java | 60 -
.../node/metedata/read/TimeSeriesCountNode.java | 80 -
.../metedata/read/TimeSeriesSchemaScanNode.java | 155 --
.../node/metedata/write/AlterTimeSeriesNode.java | 285 ---
.../write/CreateAlignedTimeSeriesNode.java | 374 ----
.../node/metedata/write/CreateTimeSeriesNode.java | 342 ---
.../planner/plan/node/process/AggregateNode.java | 199 --
.../planner/plan/node/process/DeviceMergeNode.java | 207 --
.../planner/plan/node/process/ExchangeNode.java | 213 --
.../sql/planner/plan/node/process/FillNode.java | 145 --
.../sql/planner/plan/node/process/FilterNode.java | 176 --
.../planner/plan/node/process/FilterNullNode.java | 161 --
.../plan/node/process/GroupByLevelNode.java | 221 --
.../sql/planner/plan/node/process/LimitNode.java | 149 --
.../sql/planner/plan/node/process/OffsetNode.java | 144 --
.../sql/planner/plan/node/process/ProcessNode.java | 29 -
.../sql/planner/plan/node/process/SortNode.java | 156 --
.../planner/plan/node/process/TimeJoinNode.java | 245 ---
.../planner/plan/node/sink/FragmentSinkNode.java | 200 --
.../mpp/sql/planner/plan/node/sink/SinkNode.java | 31 -
.../plan/node/source/SeriesAggregateScanNode.java | 300 ---
.../planner/plan/node/source/SeriesScanNode.java | 323 ---
.../sql/planner/plan/node/source/SourceNode.java | 36 -
.../plan/node/write/InsertMultiTabletsNode.java | 284 ---
.../sql/planner/plan/node/write/InsertNode.java | 252 ---
.../sql/planner/plan/node/write/InsertRowNode.java | 612 ------
.../planner/plan/node/write/InsertRowsNode.java | 258 ---
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 236 ---
.../planner/plan/node/write/InsertTabletNode.java | 809 --------
.../sql/planner/plan/parameter/Aggregation.java | 43 -
.../planner/plan/parameter/AggregationStep.java | 73 -
.../plan/parameter/FilterNullParameter.java | 88 -
.../plan/parameter/GroupByTimeParameter.java | 173 --
.../sql/planner/plan/parameter/InputLocation.java | 72 -
.../sql/planner/plan/parameter/OutputColumn.java | 91 -
.../sql/rewriter/ColumnPaginationController.java | 145 --
.../db/mpp/sql/rewriter/ConcatPathRewriter.java | 190 --
.../db/mpp/sql/rewriter/DnfFilterOptimizer.java | 163 --
.../db/mpp/sql/rewriter/IFilterOptimizer.java | 29 -
.../sql/rewriter/MergeSingleFilterOptimizer.java | 179 --
.../db/mpp/sql/rewriter/RemoveNotOptimizer.java | 103 -
.../db/mpp/sql/rewriter/WildcardsRemover.java | 369 ----
.../db/mpp/sql/statement/IConfigStatement.java | 36 -
.../iotdb/db/mpp/sql/statement/Statement.java | 58 -
.../iotdb/db/mpp/sql/statement/StatementNode.java | 32 -
.../db/mpp/sql/statement/StatementVisitor.java | 188 --
.../mpp/sql/statement/component/FillComponent.java | 51 -
.../db/mpp/sql/statement/component/FillPolicy.java | 23 -
.../statement/component/FilterNullComponent.java | 97 -
.../sql/statement/component/FilterNullPolicy.java | 25 -
.../mpp/sql/statement/component/FromComponent.java | 42 -
.../statement/component/GroupByLevelComponent.java | 56 -
.../component/GroupByLevelController.java | 247 ---
.../statement/component/GroupByTimeComponent.java | 101 -
.../db/mpp/sql/statement/component/OrderBy.java | 26 -
.../mpp/sql/statement/component/ResultColumn.java | 205 --
.../sql/statement/component/ResultSetFormat.java | 27 -
.../sql/statement/component/SelectComponent.java | 182 --
.../sql/statement/component/WhereCondition.java | 43 -
.../statement/crud/AggregationQueryStatement.java | 127 --
.../db/mpp/sql/statement/crud/BatchInsert.java | 37 -
.../mpp/sql/statement/crud/FillQueryStatement.java | 78 -
.../statement/crud/GroupByFillQueryStatement.java | 48 -
.../sql/statement/crud/GroupByQueryStatement.java | 59 -
.../sql/statement/crud/InsertBaseStatement.java | 70 -
.../crud/InsertMultiTabletsStatement.java | 77 -
.../mpp/sql/statement/crud/InsertRowStatement.java | 116 --
.../crud/InsertRowsOfOneDeviceStatement.java | 79 -
.../sql/statement/crud/InsertRowsStatement.java | 77 -
.../db/mpp/sql/statement/crud/InsertStatement.java | 90 -
.../sql/statement/crud/InsertTabletStatement.java | 94 -
.../mpp/sql/statement/crud/LastQueryStatement.java | 72 -
.../db/mpp/sql/statement/crud/QueryStatement.java | 349 ----
.../mpp/sql/statement/crud/UDAFQueryStatement.java | 96 -
.../mpp/sql/statement/crud/UDTFQueryStatement.java | 33 -
.../metadata/AlterTimeSeriesStatement.java | 120 --
.../statement/metadata/CountDevicesStatement.java | 34 -
.../metadata/CountLevelTimeSeriesStatement.java | 41 -
.../statement/metadata/CountNodesStatement.java | 31 -
.../mpp/sql/statement/metadata/CountStatement.java | 47 -
.../metadata/CountStorageGroupStatement.java | 30 -
.../metadata/CountTimeSeriesStatement.java | 34 -
.../metadata/CreateAlignedTimeSeriesStatement.java | 173 --
.../metadata/CreateTimeSeriesStatement.java | 125 --
.../statement/metadata/SchemaFetchStatement.java | 56 -
.../metadata/SetStorageGroupStatement.java | 54 -
.../statement/metadata/ShowDevicesStatement.java | 58 -
.../mpp/sql/statement/metadata/ShowStatement.java | 60 -
.../metadata/ShowStorageGroupStatement.java | 56 -
.../metadata/ShowTimeSeriesStatement.java | 87 -
.../db/mpp/sql/statement/sys/AuthorStatement.java | 148 --
.../db/protocol/influxdb/handler/QueryHandler.java | 2 +-
.../protocol/rest/handler/QueryDataSetHandler.java | 14 +
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 41 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +-
.../db/qp/logical/crud/SelectIntoOperator.java | 15 +
.../db/qp/physical/crud/AlignByDevicePlan.java | 2 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 9 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 357 ++--
.../db/query/control/QueryResourceManager.java | 6 +-
.../groupby/GroupByWithValueFilterDataSet.java | 2 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 2 +-
.../db/query/executor/AggregationExecutor.java | 6 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 4 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 2 +-
.../db/query/executor/RawDataQueryExecutor.java | 4 +-
.../db/query/executor/fill/LastPointReader.java | 6 +-
.../iotdb/db/query/expression/Expression.java | 2 +-
.../expression/binary/AdditionExpression.java | 4 +-
.../query/expression/binary/BinaryExpression.java | 4 +-
.../expression/binary/DivisionExpression.java | 4 +-
.../query/expression/binary/EqualToExpression.java | 4 +-
.../expression/binary/GreaterEqualExpression.java | 4 +-
.../expression/binary/GreaterThanExpression.java | 4 +-
.../expression/binary/LessEqualExpression.java | 4 +-
.../expression/binary/LessThanExpression.java | 4 +-
.../expression/binary/LogicAndExpression.java | 4 +-
.../query/expression/binary/LogicOrExpression.java | 4 +-
.../query/expression/binary/ModuloExpression.java | 4 +-
.../binary/MultiplicationExpression.java | 4 +-
.../expression/binary/NonEqualExpression.java | 4 +-
.../expression/binary/SubtractionExpression.java | 4 +-
.../db/query/expression/leaf/ConstantOperand.java | 2 +-
.../query/expression/leaf/TimeSeriesOperand.java | 2 +-
.../query/expression/multi/FunctionExpression.java | 10 +-
.../db/query/expression/unary/InExpression.java | 11 +-
.../db/query/expression/unary/LikeExpression.java | 80 +-
.../query/expression/unary/LogicNotExpression.java | 2 +-
.../query/expression/unary/NegationExpression.java | 2 +-
.../query/expression/unary/RegularExpression.java | 5 +-
.../db/query/expression/unary/UnaryExpression.java | 2 +-
.../query/reader/chunk/MemAlignedPageReader.java | 2 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 4 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 18 +-
.../query/timegenerator/ServerTimeGenerator.java | 2 +-
.../db/query/udf/builtin/BuiltinFunction.java | 4 +-
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 8 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 834 ++++++++
.../query/udf/core/layer/TsBlockInputDataSet.java | 2 +-
.../transformer/ArithmeticAdditionTransformer.java | 35 -
.../transformer/ArithmeticBinaryTransformer.java | 41 -
.../transformer/ArithmeticDivisionTransformer.java | 35 -
.../transformer/ArithmeticModuloTransformer.java | 35 -
.../ArithmeticMultiplicationTransformer.java | 35 -
.../transformer/ArithmeticNegationTransformer.java | 80 -
.../ArithmeticSubtractionTransformer.java | 35 -
.../udf/core/transformer/BinaryTransformer.java | 182 --
.../core/transformer/CompareBinaryTransformer.java | 41 -
.../transformer/CompareEqualToTransformer.java | 40 -
.../CompareGreaterEqualTransformer.java | 35 -
.../transformer/CompareGreaterThanTransformer.java | 35 -
.../transformer/CompareLessEqualTransformer.java | 35 -
.../transformer/CompareLessThanTransformer.java | 35 -
.../transformer/CompareNonEqualTransformer.java | 40 -
.../udf/core/transformer/LogicAndTransformer.java | 34 -
.../core/transformer/LogicBinaryTransformer.java | 40 -
.../udf/core/transformer/LogicNotTransformer.java | 70 -
.../udf/core/transformer/LogicOrTransformer.java | 34 -
.../db/query/udf/core/transformer/Transformer.java | 2 +-
.../core/transformer/TransparentTransformer.java | 93 -
.../core/transformer/UDFQueryRowTransformer.java | 49 -
.../transformer/UDFQueryRowWindowTransformer.java | 47 -
.../udf/core/transformer/UDFQueryTransformer.java | 111 -
.../binary/ArithmeticAdditionTransformer.java | 35 +
.../binary/ArithmeticBinaryTransformer.java | 49 +
.../binary/ArithmeticDivisionTransformer.java | 35 +
.../binary/ArithmeticModuloTransformer.java | 35 +
.../ArithmeticMultiplicationTransformer.java | 35 +
.../binary/ArithmeticSubtractionTransformer.java | 35 +
.../core/transformer/binary/BinaryTransformer.java | 125 ++
.../binary/CompareBinaryTransformer.java | 49 +
.../binary/CompareEqualToTransformer.java | 56 +
.../binary/CompareGreaterEqualTransformer.java | 35 +
.../binary/CompareGreaterThanTransformer.java | 35 +
.../binary/CompareLessEqualTransformer.java | 35 +
.../binary/CompareLessThanTransformer.java | 35 +
.../binary/CompareNonEqualTransformer.java | 56 +
.../transformer/binary/LogicAndTransformer.java | 33 +
.../transformer/binary/LogicBinaryTransformer.java | 54 +
.../transformer/binary/LogicOrTransformer.java | 34 +
.../transformer/multi/UDFQueryRowTransformer.java | 49 +
.../multi/UDFQueryRowWindowTransformer.java | 47 +
.../transformer/multi/UDFQueryTransformer.java | 112 +
.../unary/ArithmeticNegationTransformer.java | 59 +
.../udf/core/transformer/unary/InTransformer.java | 233 +++
.../transformer/unary/LogicNotTransformer.java | 48 +
.../core/transformer/unary/RegularTransformer.java | 58 +
.../transformer/unary/TransparentTransformer.java | 70 +
.../core/transformer/unary/UnaryTransformer.java | 62 +
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 113 +-
.../service/thrift/impl/InternalServiceImpl.java | 18 +-
.../db/sync/sender/manager/TsFileSyncManager.java | 12 -
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 4 +-
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 13 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 5 +
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 2 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 4 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 2 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 6 +-
.../apache/iotdb/db/wal/buffer/WALEntryType.java | 4 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 4 +-
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 4 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 4 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 6 +-
.../file/UnsealedTsFileRecoverPerformer.java | 4 +-
.../compaction/CompactionTaskManagerTest.java | 2 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 89 +
.../compaction/inner/InnerCompactionTest.java | 63 +-
.../compaction/utils/CompactionCheckerUtils.java | 2 +-
.../utils/CompactionFileGeneratorUtils.java | 6 +-
.../db/engine/storagegroup/DataRegionTest.java | 4 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 2 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 71 +-
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 24 +-
.../rocksdb/RocksDBBenchmarkEngine.java | 153 --
.../iotdb/db/mpp/aggregation/AccumulatorTest.java | 349 ++++
.../apache/iotdb/db/mpp/buffer/SinkHandleTest.java | 526 -----
.../iotdb/db/mpp/buffer/SourceHandleTest.java | 653 ------
.../apache/iotdb/db/mpp/buffer/StubSinkHandle.java | 101 -
.../java/org/apache/iotdb/db/mpp/buffer/Utils.java | 106 -
.../mpp/common/schematree/PathPatternTreeTest.java | 4 +-
.../db/mpp/common/schematree/SchemaTreeTest.java | 51 +
.../db/mpp/execution/ConfigExecutionTest.java | 9 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 32 +-
.../db/mpp/execution/QueryStateMachineTest.java | 1 +
.../datatransfer/DataBlockManagerTest.java | 121 ++
.../datatransfer/LocalSinkHandleTest.java | 153 ++
.../datatransfer/LocalSourceHandleTest.java | 119 ++
.../datatransfer/SharedTsBlockQueueTest.java | 160 ++
.../mpp/execution/datatransfer/SinkHandleTest.java | 527 +++++
.../execution/datatransfer/SourceHandleTest.java | 641 ++++++
.../mpp/execution/datatransfer/StubSinkHandle.java | 99 +
.../iotdb/db/mpp/execution/datatransfer/Utils.java | 112 +
.../db/mpp/execution/memory/MemoryPoolTest.java | 275 +++
.../execution/operator/DeviceViewOperatorTest.java | 198 ++
.../mpp/execution/operator/LimitOperatorTest.java | 188 ++
.../execution/operator/MultiColumnMergerTest.java | 208 ++
.../operator/SeriesAggregateScanOperatorTest.java | 485 +++++
.../execution/operator/SeriesScanOperatorTest.java | 135 ++
.../execution/operator/SingleColumnMergerTest.java | 210 ++
.../execution/operator/TimeJoinOperatorTest.java | 414 ++++
.../operator/schema/CountMergeOperatorTest.java | 193 ++
.../operator/schema/SchemaCountOperatorTest.java | 231 +++
.../operator/schema/SchemaFetchOperatorTest.java | 149 ++
.../operator/schema/SchemaScanOperatorTest.java | 253 +++
.../schedule/DefaultTaskSchedulerTest.java | 399 ++++
.../execution/schedule/DriverSchedulerTest.java | 164 ++
.../DriverTaskTimeoutSentinelThreadTest.java | 269 +++
.../schedule/queue/L1PriorityQueueTest.java | 182 ++
.../schedule/queue/L2PriorityQueueTest.java | 196 ++
.../mpp/execution/schedule/queue/QueueElement.java | 80 +
.../apache/iotdb/db/mpp/memory/MemoryPoolTest.java | 250 ---
.../db/mpp/operator/DeviceViewOperatorTest.java | 198 --
.../iotdb/db/mpp/operator/LimitOperatorTest.java | 186 --
.../db/mpp/operator/MultiColumnMergerTest.java | 208 --
.../operator/SeriesAggregateScanOperatorTest.java | 384 ----
.../db/mpp/operator/SeriesScanOperatorTest.java | 135 --
.../db/mpp/operator/SingleColumnMergerTest.java | 209 --
.../db/mpp/operator/TimeJoinOperatorTest.java | 292 ---
.../operator/schema/CountMergeOperatorTest.java | 193 --
.../operator/schema/SchemaCountOperatorTest.java | 231 ---
.../operator/schema/SchemaFetchOperatorTest.java | 149 --
.../operator/schema/SchemaScanOperatorTest.java | 253 ---
.../iotdb/db/mpp/plan/analyze/AnalyzerTest.java | 62 +
.../iotdb/db/mpp/plan/parser/ASTVisitorTest.java | 41 +
.../db/mpp/plan/parser/StatementGeneratorTest.java | 76 +
.../db/mpp/plan/plan/DistributionPlannerTest.java | 523 +++++
.../db/mpp/plan/plan/FragmentInstanceIdTest.java | 38 +
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 164 ++
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 473 +++++
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 714 +++++++
.../iotdb/db/mpp/plan/plan/QueryPlannerTest.java | 96 +
.../plan/plan/node/PlanNodeDeserializeHelper.java | 37 +
.../read/DeviceSchemaScanNodeSerdeTest.java | 77 +
.../metadata/read/SchemaCountNodeSerdeTest.java | 92 +
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 80 +
.../node/process/AggregationNodeSerdeTest.java | 89 +
.../plan/node/process/DeviceViewNodeSerdeTest.java | 55 +
.../plan/node/process/ExchangeNodeSerdeTest.java | 64 +
.../plan/plan/node/process/FillNodeSerdeTest.java | 58 +
.../plan/node/process/FilterNodeSerdeTest.java | 58 +
.../plan/node/process/FilterNullNodeSerdeTest.java | 58 +
.../node/process/GroupByLevelNodeSerdeTest.java | 106 +
.../plan/plan/node/process/LimitNodeSerdeTest.java | 67 +
.../plan/node/process/OffsetNodeSerdeTest.java | 65 +
.../plan/plan/node/process/SortNodeSerdeTest.java | 66 +
.../plan/node/process/TimeJoinNodeSerdeTest.java | 81 +
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 56 +
.../source/SeriesAggregationScanNodeSerdeTest.java | 79 +
.../plan/node/source/SeriesScanNodeSerdeTest.java | 64 +
.../write/InsertMultiTabletsNodeSerdeTest.java | 101 +
.../plan/node/write/InsertRowNodeSerdeTest.java | 200 ++
.../plan/node/write/InsertRowsNodeSerdeTest.java | 72 +
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 81 +
.../plan/node/write/InsertTabletNodeSerdeTest.java | 176 ++
.../plan/node/write/WritePlanNodeSplitTest.java | 278 +++
.../db/mpp/schedule/DefaultTaskSchedulerTest.java | 399 ----
.../iotdb/db/mpp/schedule/DriverSchedulerTest.java | 164 --
.../DriverTaskTimeoutSentinelThreadTest.java | 269 ---
.../db/mpp/schedule/queue/L1PriorityQueueTest.java | 182 --
.../db/mpp/schedule/queue/L2PriorityQueueTest.java | 196 --
.../iotdb/db/mpp/schedule/queue/QueueElement.java | 80 -
.../iotdb/db/mpp/sql/analyze/AnalyzerTest.java | 62 -
.../iotdb/db/mpp/sql/parser/ASTVisitorTest.java | 41 -
.../db/mpp/sql/parser/StatementGeneratorTest.java | 76 -
.../db/mpp/sql/plan/DistributionPlannerTest.java | 523 -----
.../db/mpp/sql/plan/FragmentInstanceIdTest.java | 38 -
.../db/mpp/sql/plan/FragmentInstanceSerdeTest.java | 175 --
.../iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java | 228 --
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 473 -----
.../db/mpp/sql/plan/QueryLogicalPlanUtil.java | 575 ------
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 96 -
.../sql/plan/node/PlanNodeDeserializeHelper.java | 37 -
.../read/DeviceSchemaScanNodeSerdeTest.java | 77 -
.../metadata/read/SchemaCountNodeSerdeTest.java | 92 -
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 80 -
.../plan/node/process/AggregateNodeSerdeTest.java | 69 -
.../node/process/DeviceMergeNodeSerdeTest.java | 89 -
.../plan/node/process/ExchangeNodeSerdeTest.java | 109 -
.../sql/plan/node/process/FillNodeSerdeTest.java | 92 -
.../sql/plan/node/process/FilterNodeSerdeTest.java | 104 -
.../plan/node/process/FilterNullNodeSerdeTest.java | 112 -
.../node/process/GroupByLevelNodeSerdeTest.java | 127 --
.../sql/plan/node/process/LimitNodeSerdeTest.java | 129 --
.../sql/plan/node/process/OffsetNodeSerdeTest.java | 199 --
.../sql/plan/node/process/SortNodeSerdeTest.java | 139 --
.../plan/node/process/TimeJoinNodeSerdeTest.java | 147 --
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 56 -
.../source/SeriesAggregateScanNodeSerdeTest.java | 76 -
.../plan/node/source/SeriesScanNodeSerdeTest.java | 57 -
.../write/InsertMultiTabletsNodeSerdeTest.java | 101 -
.../plan/node/write/InsertRowNodeSerdeTest.java | 200 --
.../plan/node/write/InsertRowsNodeSerdeTest.java | 72 -
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 74 -
.../plan/node/write/InsertTabletNodeSerdeTest.java | 176 --
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 6 +-
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 2 +-
.../iotdb/db/query/dataset/ListDataSetTest.java | 2 +-
.../iotdb/db/query/dataset/SingleDataSetTest.java | 2 +-
.../query/dataset/groupby/GroupByDataSetTest.java | 4 +-
.../dataset/groupby/GroupByLevelDataSetTest.java | 4 +-
.../iotdb/db/service/InternalServiceImplTest.java | 16 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 2 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 2 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 4 +-
.../src/main/thrift/confignode.thrift | 8 +
tsfile/pom.xml | 5 -
.../tsfile/common/constant/TsFileConstant.java | 1 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 10 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 2 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 45 +-
.../read/common/block/column/BinaryColumn.java | 25 +
.../read/common/block/column/BooleanColumn.java | 25 +
.../tsfile/read/common/block/column/Column.java | 9 +
.../read/common/block/column/DoubleColumn.java | 25 +
.../read/common/block/column/FloatColumn.java | 24 +
.../tsfile/read/common/block/column/IntColumn.java | 24 +
.../read/common/block/column/LongColumn.java | 24 +
.../block/column/RunLengthEncodedColumn.java | 13 +
.../read/common/block/column/TimeColumn.java | 17 +
.../read/controller/MetadataQuerierByFileImpl.java | 8 +-
.../iotdb/tsfile/read/reader/IPageReader.java | 2 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 2 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 3 +-
.../apache/iotdb/tsfile/utils/BitConstructor.java | 3 -
.../apache/iotdb/tsfile/utils/ByteArrayList.java | 135 ++
.../apache/iotdb/tsfile/utils/TsPrimitiveType.java | 146 +-
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 7 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 8 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 2 +-
.../iotdb/tsfile/common/block/TsBlockTest.java | 49 +
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 2 +-
.../iotdb/tsfile/read/common/ColumnTest.java | 322 +++
.../apache/iotdb/tsfile/read/common/PathTest.java | 10 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 6 +-
1022 files changed, 62999 insertions(+), 51166 deletions(-)
create mode 100644 client-py/tests/test_one_device.py
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/cli/TemporaryClient.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/AsyncClientPool.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/InitRegionHandler.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/CountStorageGroupReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetDataPartitionReq.java
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetOrCountStorageGroupReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetSchemaPartitionReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetStorageGroupReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/DeleteRegionsReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/LoadManager.java
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/service/balancer/LoadBalancer.java
delete mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/utils/ConfigNodeEnvironmentUtils.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/IStateMachine.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/exception/IllegalPeerEndpointException.java
delete mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/statemachine/EmptyStateMachine.java
delete mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/statemachine/IStateMachine.java
create mode 100644
consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.java
create mode 100644
consensus/src/test/java/org/apache/iotdb/consensus/standalone/RecoveryTest.java
create mode 100644 grafana-plugin/src/componments/AggregateFun.tsx
create mode 100644 grafana-plugin/src/componments/FillValue.tsx
create mode 100644 grafana-plugin/src/componments/GroupBy.tsx
create mode 100644 grafana-plugin/src/componments/TimeSeries.tsx
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSyntaxConventionIT.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSyntaxConventionIdentifierIT.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSyntaxConventionStringLiteralIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/versionadaption/IoTDBSyntaxConventionVersionAdaptionIT.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncThriftClient.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncThriftClientWithErrorHandler.java
create mode 100644 schema-engine-rocksdb/README.md
create mode 100644 schema-engine-rocksdb/pom.xml
rename {server =>
schema-engine-rocksdb}/src/assembly/resources/conf/schema-rocksdb.properties
(100%)
create mode 100644 schema-engine-rocksdb/src/assembly/schema-engine-rocksdb.xml
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/CheckKeyResult.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaConfLoader.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaConstants.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaLogger.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaReadWriteHandler.java
(100%)
create mode 100644
schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaRegion.java
create mode 100644
schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaUtils.java
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/REntityMNode.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RInternalMNode.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNode.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNodeType.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNodeValueType.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMeasurementMNode.java
(100%)
rename {server =>
schema-engine-rocksdb}/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RStorageGroupMNode.java
(100%)
rename {server/src/test/java/org/apache/iotdb/db/metadata/schemaregion =>
schema-engine-rocksdb/src/test/org.apache.iotdb.db/metadata}/rocksdb/MRocksDBBenchmark.java
(100%)
rename {server/src/test/java/org/apache/iotdb/db/metadata/schemaregion =>
schema-engine-rocksdb/src/test/org.apache.iotdb.db/metadata}/rocksdb/MRocksDBUnitTest.java
(100%)
rename {server/src/test/java/org/apache/iotdb/db/metadata/schemaregion =>
schema-engine-rocksdb/src/test/org.apache.iotdb.db/metadata}/rocksdb/RSchemaReadWriteHandlerTest.java
(100%)
rename {server/src/test/java/org/apache/iotdb/db/metadata/schemaregion =>
schema-engine-rocksdb/src/test/org.apache.iotdb.db/metadata}/rocksdb/RSchemaRegionAdvancedTest.java
(100%)
create mode 100644
schema-engine-rocksdb/src/test/org.apache.iotdb.db/metadata/rocksdb/RocksDBBenchmarkEngine.java
rename {server/src/test/java/org/apache/iotdb/db/metadata/schemaregion =>
schema-engine-rocksdb/src/test/org.apache.iotdb.db/metadata}/rocksdb/RocksDBBenchmarkTask.java
(100%)
rename {server/src/test/java/org/apache/iotdb/db/metadata/schemaregion =>
schema-engine-rocksdb/src/test/org.apache.iotdb.db/metadata}/rocksdb/RocksDBTestUtils.java
(100%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/CompactionTaskSummary.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/exception/metadata/SeriesOverflowException.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/RSchemaRegionLoader.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaRegion.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaUtils.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/Accumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/AccumulatorFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/Aggregator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/AvgAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/CountAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/ExtremeAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/FirstValueAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/FirstValueDescAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/LastValueAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/LastValueDescAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/MaxTimeAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/MaxTimeDescAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/MaxValueAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/MinTimeAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/MinTimeDescAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/MinValueAccumulator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/SumAccumulator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockService.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceMBean.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceThriftHandler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/IDataBlockManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/IDataBlockManagerCallback.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/ISinkHandle.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/ISourceHandle.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/SinkHandle.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/SourceHandle.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/buffer/TsBlockSerdeFactory.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/Coordinator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriver.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriverContext.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/Driver.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/DriverContext.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/ExecutionResult.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceContext.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceExecution.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceFailureListener.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceState.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentInstanceStateMachine.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/FragmentState.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/IDriver.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/IQueryExecution.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryExecution.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriver.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriverContext.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/config/AuthorizerConfigTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ConfigExecution.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ConfigTaskResult.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ConfigTaskVisitor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/config/IConfigTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/config/SetStorageGroupTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ShowStorageGroupTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockService.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockServiceMBean.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockServiceThriftHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/IDataBlockManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/IDataBlockManagerCallback.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/ISinkHandle.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/ISourceHandle.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandle.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSourceHandle.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SharedTsBlockQueue.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SinkHandle.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SourceHandle.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/TsBlockSerdeFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/driver/DataDriver.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/driver/DataDriverContext.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/driver/Driver.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/driver/DriverContext.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/driver/IDriver.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/driver/SchemaDriver.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/driver/SchemaDriverContext.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceContext.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceExecution.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceFailureListener.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceState.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceStateMachine.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentState.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/memory/LocalMemoryManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/memory/MemoryPool.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/Operator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/OperatorContext.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AggregateOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/DeviceViewOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FillOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterNullOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/LimitOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/ProcessOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/SortOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TimeJoinOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/TransformOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/merge/AscTimeComparator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/merge/ColumnMerger.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/merge/DescTimeComparator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/merge/MultiColumnMerger.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/merge/SingleColumnMerger.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/merge/TimeComparator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/CountMergeOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/DevicesCountOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/DevicesSchemaScanOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/LevelTimeSeriesCountOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaFetchOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaMergeOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaScanOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/TimeSeriesCountOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/TimeSeriesSchemaScanOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/sink/FragmentSinkOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/sink/SinkOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AlignedSeriesScanUtil.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/DataSourceOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/ExchangeOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesAggregateScanOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SourceOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/AbstractDriverThread.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverTaskThread.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverTaskTimeoutSentinelThread.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/ExecutionContext.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/FragmentInstanceAbortedException.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/IDriverScheduler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/ITaskScheduler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/ID.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/IDIndexedAccessible.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/IndexedBlockingQueue.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/L1PriorityQueue.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/queue/L2PriorityQueue.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/DriverTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/DriverTaskID.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/DriverTaskStatus.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/AbstractFragInsStateTracker.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/ClusterScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/FixedRateFragInsStateTracker.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/FragInstanceDispatchResult.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/IFragInstanceDispatcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/IFragInstanceStateTracker.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/IQueryTerminator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/IScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleFragInstanceDispatcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/SimpleQueryTerminator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/scheduler/StandaloneScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/memory/LocalMemoryManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/memory/MemoryPool.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/Operator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/OperatorContext.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/AggregateOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/DeviceViewOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/FillOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/FilterNullOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/FilterOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/LimitOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/OffsetOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/ProcessOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/SortOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/TimeJoinOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/TransformOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/merge/ColumnMerger.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/merge/MultiColumnMerger.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/process/merge/SingleColumnMerger.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/CountMergeOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/DevicesCountOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/DevicesSchemaScanOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/LevelTimeSeriesCountOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaFetchOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaMergeOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaScanOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/TimeSeriesCountOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/TimeSeriesSchemaScanOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/sink/FragmentSinkOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/sink/SinkOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/source/AlignedSeriesScanUtil.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/source/DataSourceOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/source/ExchangeOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/source/SeriesAggregateScanOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/source/SeriesScanOperator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/source/SeriesScanUtil.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/operator/source/SourceOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/Analysis.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/Analyzer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterPartitionFetcher.java
create 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/FakePartitionFetcherImpl.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/FakeSchemaFetcherImpl.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/IPartitionFetcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ISchemaFetcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/QueryType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/SchemaValidator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/StandalonePartitionFetcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/StandaloneSchemaFetcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/TypeProvider.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/constant/FilterConstant.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/constant/StatementType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/ExecutionResult.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/IQueryExecution.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/AuthorizerConfigTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ConfigExecution.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ConfigTaskResult.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ConfigTaskVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/CountStorageGroupTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/IConfigTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/SetStorageGroupTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowStorageGroupTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/optimization/PlanOptimizer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/ASTVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/StatementGenerator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/DistributionPlanner.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/IFragmentParallelPlaner.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanBuilder.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanner.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/SimpleFragmentParallelPlanner.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/WriteFragmentParallelPlanner.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/DistributedQueryPlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/FragmentInstance.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/LogicalQueryPlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/PlanFragment.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/SubPlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanGraphPrinter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanNodeId.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanNodeType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanNodeUtil.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/PlanVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/SimplePlanNodeRewriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/WritePlanNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/AbstractSchemaMergeNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/CountSchemaMergeNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/DevicesCountNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/DevicesSchemaScanNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/LevelTimeSeriesCountNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/SchemaFetchNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/SchemaScanNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/SeriesSchemaMergeNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/TimeSeriesCountNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/TimeSeriesSchemaScanNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/AlterTimeSeriesNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/AggregationNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/DeviceMergeNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/DeviceViewNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/ExchangeNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/FillNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/FilterNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/FilterNullNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/GroupByLevelNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/GroupByTimeNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/LimitNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/OffsetNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/ProcessNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/ProjectNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/SortNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/TimeJoinNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/FragmentSinkNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/SinkNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/AlignedSeriesAggregationScanNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/AlignedSeriesScanNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/SeriesAggregationScanNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/SeriesScanNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/SourceNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/BatchInsertNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/InsertMultiTabletsNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/InsertNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/InsertRowNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/InsertRowsNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/InsertRowsOfOneDeviceNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/write/InsertTabletNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/AggregationDescriptor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/AggregationStep.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/FillDescriptor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/FilterNullParameter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/GroupByTimeParameter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/InputLocation.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/OutputColumn.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/ColumnPaginationController.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/ConcatPathRewriter.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/DnfFilterOptimizer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/IFilterOptimizer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/MergeSingleFilterOptimizer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/RemoveNotOptimizer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/rewriter/WildcardsRemover.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/AbstractFragInsStateTracker.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/ClusterScheduler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FixedRateFragInsStateTracker.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragInstanceDispatchResult.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/IFragInstanceDispatcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/IFragInstanceStateTracker.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/IQueryTerminator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/IScheduler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleQueryTerminator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/IConfigStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/Statement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/FillComponent.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/FillPolicy.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/FilterNullComponent.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/FilterNullPolicy.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/FromComponent.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/GroupByLevelComponent.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/GroupByLevelController.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/GroupByTimeComponent.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderBy.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/ResultColumn.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/ResultSetFormat.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/SelectComponent.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/WhereCondition.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/AggregationQueryStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/FillQueryStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/GroupByFillQueryStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/GroupByQueryStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/InsertBaseStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/InsertMultiTabletsStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/InsertRowStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/InsertRowsOfOneDeviceStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/InsertRowsStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/InsertStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/InsertTabletStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/LastQueryStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/QueryStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/UDAFQueryStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/UDTFQueryStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/AlterTimeSeriesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CountDevicesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CountLevelTimeSeriesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CountNodesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CountStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CountStorageGroupStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CountTimeSeriesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CreateAlignedTimeSeriesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CreateTimeSeriesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/SchemaFetchStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/SetStorageGroupStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowDevicesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowStorageGroupStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowTimeSeriesStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/AuthorStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/AbstractDriverThread.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/DriverScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/DriverTaskThread.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/DriverTaskTimeoutSentinelThread.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/ExecutionContext.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceAbortedException.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/IDriverScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/ITaskScheduler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/queue/ID.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/queue/IDIndexedAccessible.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/queue/IndexedBlockingQueue.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/queue/L1PriorityQueue.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/queue/L2PriorityQueue.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/task/DriverTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/task/DriverTaskID.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/schedule/task/DriverTaskStatus.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/Analysis.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/Analyzer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/ClusterPartitionFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/ClusterSchemaFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/FakePartitionFetcherImpl.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/FakeSchemaFetcherImpl.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/IPartitionFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/ISchemaFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/QueryType.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/SchemaValidator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/StandalonePartitionFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/StandaloneSchemaFetcher.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/constant/FilterConstant.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/constant/StatementType.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/optimization/PlanOptimizer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/parser/ASTVisitor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/parser/StatementGenerator.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/DistributionPlanner.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/IFragmentParallelPlaner.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/LocalExecutionPlanner.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/LogicalPlanner.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/QueryPlanBuilder.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/SimpleFragmentParallelPlanner.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/WriteFragmentParallelPlanner.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/DistributedQueryPlan.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/FragmentInstance.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/LogicalQueryPlan.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/PlanFragment.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/SubPlan.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanGraphPrinter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNodeId.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNodeType.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanNodeUtil.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/PlanVisitor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/SimplePlanNodeRewriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/WritePlanNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/AbstractSchemaMergeNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/CountSchemaMergeNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/DevicesCountNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/DevicesSchemaScanNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/LevelTimeSeriesCountNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SchemaFetchNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SchemaScanNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SeriesSchemaMergeNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/TimeSeriesCountNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/TimeSeriesSchemaScanNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AlterTimeSeriesNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/CreateTimeSeriesNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/AggregateNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/DeviceMergeNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/ExchangeNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/FillNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/FilterNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/FilterNullNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/GroupByLevelNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/LimitNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/OffsetNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/ProcessNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/SortNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/TimeJoinNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/FragmentSinkNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/SinkNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/SeriesAggregateScanNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/SeriesScanNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/SourceNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertMultiTabletsNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertRowNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertRowsNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertRowsOfOneDeviceNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertTabletNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/Aggregation.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/AggregationStep.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/FilterNullParameter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/GroupByTimeParameter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/InputLocation.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/OutputColumn.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/ColumnPaginationController.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/ConcatPathRewriter.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/DnfFilterOptimizer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/IFilterOptimizer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/MergeSingleFilterOptimizer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/RemoveNotOptimizer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/WildcardsRemover.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/IConfigStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/Statement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/StatementNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/StatementVisitor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/FillComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/FillPolicy.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/FilterNullComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/FilterNullPolicy.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/FromComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/GroupByLevelComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/GroupByLevelController.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/GroupByTimeComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/OrderBy.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/ResultColumn.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/ResultSetFormat.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/SelectComponent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/component/WhereCondition.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/AggregationQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/BatchInsert.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/FillQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/GroupByFillQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/GroupByQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertBaseStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertMultiTabletsStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowsOfOneDeviceStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowsStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertTabletStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/LastQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/QueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/UDAFQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/UDTFQueryStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/AlterTimeSeriesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/CountDevicesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/CountLevelTimeSeriesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/CountNodesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/CountStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/CountStorageGroupStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/CountTimeSeriesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/CreateAlignedTimeSeriesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/CreateTimeSeriesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/SchemaFetchStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/SetStorageGroupStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/ShowDevicesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/ShowStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/ShowStorageGroupStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/ShowTimeSeriesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/sys/AuthorStatement.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketOutlierSample.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticAdditionTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticBinaryTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticDivisionTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticModuloTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticMultiplicationTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticNegationTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticSubtractionTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/BinaryTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/CompareBinaryTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/CompareEqualToTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/CompareGreaterEqualTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/CompareGreaterThanTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/CompareLessEqualTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/CompareLessThanTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/CompareNonEqualTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/LogicAndTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/LogicBinaryTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/LogicNotTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/LogicOrTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/TransparentTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/UDFQueryRowTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/UDFQueryRowWindowTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/UDFQueryTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/ArithmeticAdditionTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/ArithmeticBinaryTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/ArithmeticDivisionTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/ArithmeticModuloTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/ArithmeticMultiplicationTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/ArithmeticSubtractionTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/BinaryTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/CompareBinaryTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/CompareEqualToTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/CompareGreaterEqualTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/CompareGreaterThanTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/CompareLessEqualTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/CompareLessThanTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/CompareNonEqualTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/LogicAndTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/LogicBinaryTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/binary/LogicOrTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/multi/UDFQueryRowTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/multi/UDFQueryRowWindowTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/multi/UDFQueryTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/unary/ArithmeticNegationTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/unary/InTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/unary/LogicNotTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/unary/RegularTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/unary/TransparentTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/unary/UnaryTransformer.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerCompactionEmptyTsFileTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RocksDBBenchmarkEngine.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/aggregation/AccumulatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/buffer/SinkHandleTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/buffer/SourceHandleTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/buffer/StubSinkHandle.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/buffer/Utils.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockManagerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandleTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSourceHandleTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/SharedTsBlockQueueTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/SinkHandleTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/SourceHandleTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/StubSinkHandle.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/Utils.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/memory/MemoryPoolTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/DeviceViewOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/LimitOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/MultiColumnMergerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/SeriesAggregateScanOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/SeriesScanOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/SingleColumnMergerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/TimeJoinOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/CountMergeOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaCountOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaFetchOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaScanOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/schedule/DefaultTaskSchedulerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/schedule/DriverSchedulerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/schedule/DriverTaskTimeoutSentinelThreadTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/schedule/queue/L1PriorityQueueTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/schedule/queue/L2PriorityQueueTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/schedule/queue/QueueElement.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/memory/MemoryPoolTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/DeviceViewOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/LimitOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/MultiColumnMergerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/SeriesAggregateScanOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/SeriesScanOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/SingleColumnMergerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/TimeJoinOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/CountMergeOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/SchemaCountOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/SchemaFetchOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/SchemaScanOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/parser/ASTVisitorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/parser/StatementGeneratorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/DistributionPlannerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/FragmentInstanceIdTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/FragmentInstanceSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/LogicalPlannerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/QueryLogicalPlanUtil.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/QueryPlannerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/PlanNodeDeserializeHelper.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/metadata/read/DeviceSchemaScanNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/metadata/read/SchemaCountNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/AggregationNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/DeviceViewNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/ExchangeNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/FillNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/FilterNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/FilterNullNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/GroupByLevelNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/LimitNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/OffsetNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/SortNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/process/TimeJoinNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/sink/FragmentSinkNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/source/SeriesAggregationScanNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/source/SeriesScanNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/write/InsertMultiTabletsNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/write/InsertRowNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/write/InsertRowsNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/write/InsertRowsOfOneDeviceNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/write/InsertTabletNodeSerdeTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/write/WritePlanNodeSplitTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/schedule/DefaultTaskSchedulerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/schedule/DriverSchedulerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/schedule/DriverTaskTimeoutSentinelThreadTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/schedule/queue/L1PriorityQueueTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/schedule/queue/L2PriorityQueueTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/schedule/queue/QueueElement.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/analyze/AnalyzerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/parser/ASTVisitorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/parser/StatementGeneratorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/DistributionPlannerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceIdTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/LogicalPlannerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryLogicalPlanUtil.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryPlannerTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/PlanNodeDeserializeHelper.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/DeviceSchemaScanNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/SchemaCountNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/AggregateNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/DeviceMergeNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/ExchangeNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FillNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNullNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/GroupByLevelNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/LimitNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/OffsetNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/SortNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/TimeJoinNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/sink/FragmentSinkNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesAggregateScanNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesScanNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertMultiTabletsNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowsNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowsOfOneDeviceNodeSerdeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertTabletNodeSerdeTest.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/utils/ByteArrayList.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/read/common/ColumnTest.java
