You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/04/15 02:28:38 UTC
[iotdb] branch seriesAggregateOperator updated (7450fba10c -> 71c1c0d286)
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch seriesAggregateOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7450fba10c Fix group by testts
add fbe1bf2daf [IOTDB-2876] Definition of common thrift struct (#5471)
add 1c2886899d [IOTDB-2559][IOTDB-1840][IOTDB-2215][IOTDB-2216] Persistent Schema Management (#4732)
add 22fadbfc9c implement serialize and deserialize of SchemaTree (#5474)
add 9640b41e79 [IOTDB-2868] Construct ExchangeOperator in LocalExecutionPlanner (#5466)
add 703a64d2da [IOTDB-2687] Base partition policy of data (#5464)
add 5b24dcba37 [IOTDB-2878] Add getLeader interface to IConsensus (#5472)
add d160be9c22 [IOTDB-2800] Add plannode serialization/deserialization (#5455)
add e6e0d7407e Implement serialize and deserialize method for PathPatternTree (#5476)
add 8282f94043 [IOTDB-2727] tsblock serde (#5459)
add 45631f8e38 Add the ignored CMakeLists.txt (#5483)
add 1ab2e73108 [IOTDB-2881] add author serialize and deserialize and add serialize and deserialize test (#5475)
add c6634a0df3 Rocksdb-based metadata storage (#5295)
add 6fc6b11263 [IOTDB-2867] Response leader redirect when the current ConfigNode is not leader (#5481)
add 5d5f67f3dd [IoTDB-2666] Implement the RPC of Fragment dispatch and status track (#5478)
add c889624e3e [IOTDB-2817] Clear Compaction Framework (#5437)
add 506def32b0 [IOTDB-2804] DataRegion consensus state machine (#5479)
add 53089cee1f [IOTDB-2803] Implement create timeseries metadata operation through consensus layer in MPP framework (#5403)
add d3b30cf654 [IOTDB-2889] Add method converting TsBlock to TSQueryDataSet in QueryDataSetUtils (#5490)
add f33ee814b8 [IOTDB-2890] Dynamic port support for DataBlockManager (#5491)
add f0ff5510a6 [IOTDB-2879] Add influxdb-protocol module into the root pom (#5473)
add 0ec17d79eb fix StorageEngineV2 cannot start (#5484)
add ce4f2b25e4 [IOTDB-2886] refact LocalConfigManager and finish createSchemaRegion (#5486)
add 4fc9c7da54 [IOTDB-2803][new cluster] Adapt show timeseries to mpp (#5418)
add c368467c20 [IOTDB-2866] Support get or create SchemaPartition with PatternTree in config node (#5493)
add fc0313ed8b Fix compile error (#5500)
add 9e1a508be4 [IOTDB-2897] Fix wal recover deadlock (#5499)
add f60c584f4d New sync framework with TsFileSync (#5353)
add 47e2af285a [IOTDB-2871] Data node client to connect with config node (#5488)
add 4cf195c2b5 Update the deviceId in c rest example (#5504)
add 62365feb64 [IOTDB-2882] Fixed display of unary expression (#5485)
add 6139151e78 Consensus dep (#5507)
add 51b10a2679 [IOTDB-2910] Fix Count aggregate is not right after delete sg bug (#5511)
add 40585a34d4 [IOTDB-2805] Create data region (#5509)
add 984f1986d1 [IOTDB-2903] fix last value fetch failure during show timesereis (#5508)
add 8ade542133 Make some modifications according to talking for recent PRs of SchemaRegion (#5498)
add f3dc12ff59 [IOTDB-2896] Fix warning of illegal cross compaction strategy (#5503)
add 7cc2a739b4 [IOTDB-2911][Part 1: Underlying Data Structures] TransformOperator: operator implementation for nested expression evaluation (#5513)
add cc30e64dc2 fix ci (#5519)
add 4de7d70fe1 [IOTDB-2901] Refine codes of DataTypeMismatchException and checkDataTypeMatch (#5501)
add a0b1f19a88 Generate dataset header for query result set —— simple raw data query (#5522)
add 60fc7fc0da Add DistributionPlanner for WRITE operation (#5515)
add becb89fe61 [IOTDB-2905] IoTDBRecoverUnclosedIT failed in ci (#5514)
add 2bd55ae2f4 [IOTDB-2899] Feature/set storage group (#5510)
add 07a407be6f fix NPE when stop IoTDB and MLogTxtWriter parsing CreateAlignedTimeseriesPlan error (#5525)
add 25dc043b17 get time partition interval from config node (#5523)
add 627e479c3b [IOTDB-2779] TemporaryClient for ConfigNode to connect DataNode (#5530)
add 74df66decc [IOTDB-2847] Implementation of PartitionFetcher (#5516)
add a8c8acbc94 Generate header of result set: show timeseries/devices/sg (#5531)
add 976d041b76 [IOTDB-2896] Fix warning of illegal seq compaction performer (#5534)
add 12e3eb74a0 add some news for community/about (#5535)
add 8c09a47c5d Implement basic SchemaFetcher (#5494)
add d1278f8507 [IOTDB-2863] Serialize and deserialize of insert node (#5517)
add 1efdab36b5 Add getSeriesPartitionExecutor() in node-commons (#5528)
add 91dad5be71 fix DataRegionId directory name bug (#5547)
add 2d8a821592 [IOTDB-2921] Fix WALNodeTest of concurrently accessing ArrayList (#5543)
add 3309707399 [IOTDB-2909] ColumnEncoder(s) for BOOLEAN and TEXT (#5512)
add 51b7199ab0 [IOTDB-2888] Unable to select an unary expression followed by a constant expression (#5521)
add d808d844d6 [IOTDB-2913] Add InfluxDB Protocol Test Framework (#5546)
add 60e688841f Fix repeated flip() && Fix configNode's failure for addConsensusGroup && Improve DataNode's joining ConfigNode (#5544)
add 0c50e6c890 [IOTDB-2861] Improve Cross compaction selector file number restrict (#5532)
add 3f2846011c add comment for max_cross_compaction_candidate_file_nul (#5549)
add 0d83f7a894 Open Optimize ConfigNode redirect and create region process (#5550)
add 71c1c0d286 Fix conflicts
No new revisions were added by this update.
Summary of changes:
.github/workflows/influxdb-protocol.yml | 4 +-
.github/workflows/main-unix.yml | 3 +-
.github/workflows/main-win.yml | 3 +-
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 3 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 67 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +
client-cpp/pom.xml | 4 +
.../java/org/apache/iotdb/cluster/ClientMain.java | 2 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 1 -
.../cluster/client/sync/SyncClientAdaptor.java | 2 +-
.../iotdb/cluster/coordinator/Coordinator.java | 4 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 4 +-
.../iotdb/cluster/metadata/CSchemaProcessor.java | 5 +-
.../apache/iotdb/cluster/query/ClusterPlanner.java | 1 +
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 2 +-
.../server/basic/ClusterServiceProvider.java | 2 +-
.../handlers/forwarder/ForwardPlanHandler.java | 2 +-
.../cluster/server/member/DataGroupMember.java | 4 +-
.../cluster/server/member/MetaGroupMember.java | 4 +-
.../iotdb/cluster/server/member/RaftMember.java | 4 +-
.../cluster/server/service/BaseAsyncService.java | 4 +-
.../cluster/server/service/BaseSyncService.java | 2 +-
.../server/service/DataGroupServiceImpls.java | 2 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 10 +-
.../cluster/client/sync/SyncClientAdaptorTest.java | 2 +-
.../iotdb/cluster/common/TestAsyncDataClient.java | 2 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 2 +-
.../handlers/forwarder/ForwardPlanHandlerTest.java | 2 +-
.../cluster/server/member/MetaGroupMemberTest.java | 2 +-
confignode/pom.xml | 5 -
confignode/src/assembly/confignode.xml | 9 +-
.../resources/conf/iotdb-confignode.properties | 43 +-
.../iotdb/confignode/cli/TemporaryClient.java | 202 ++
.../iotdb/confignode/conf/ConfigNodeConf.java | 50 +-
.../iotdb/confignode/conf/ConfigNodeConfCheck.java | 29 +-
.../confignode/conf/ConfigNodeDescriptor.java | 17 +-
.../response/DataNodeConfigurationDataSet.java | 66 +
.../consensus/response/DataNodesInfoDataSet.java | 33 +-
.../consensus/response/DataPartitionDataSet.java | 88 +-
.../consensus/response/SchemaPartitionDataSet.java | 94 +-
.../response/StorageGroupSchemaDataSet.java | 27 +-
.../statemachine/PartitionRegionStateMachine.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 199 +-
.../iotdb/confignode/manager/ConsensusManager.java | 41 +-
.../iotdb/confignode/manager/DataNodeManager.java | 94 +-
.../apache/iotdb/confignode/manager/Manager.java | 94 +-
.../iotdb/confignode/manager/PartitionManager.java | 227 +-
.../confignode/manager/PermissionManager.java | 2 +-
.../iotdb/confignode/manager/RegionManager.java | 147 +-
.../iotdb/confignode/partition/DataRegionInfo.java | 66 -
.../confignode/partition/SchemaRegionInfo.java | 59 -
.../confignode/partition/StorageGroupSchema.java | 86 +-
.../persistence/AuthorInfoPersistence.java | 2 +-
.../persistence/DataNodeInfoPersistence.java | 135 +-
.../persistence/PartitionInfoPersistence.java | 166 +-
.../persistence/RegionInfoPersistence.java | 229 +-
.../iotdb/confignode/physical/PhysicalPlan.java | 33 +-
.../confignode/physical/PhysicalPlanType.java | 12 +-
.../physical/crud/CreateDataPartitionPlan.java | 127 +
.../physical/crud/CreateRegionsPlan.java | 95 +
.../physical/crud/CreateSchemaPartitionPlan.java | 99 +
.../crud/GetOrCreateDataPartitionPlan.java | 141 +
.../crud/GetOrCreateSchemaPartitionPlan.java | 96 +
.../iotdb/confignode/physical/sys/AuthorPlan.java | 20 +
.../confignode/physical/sys/DataPartitionPlan.java | 78 -
.../physical/sys/QueryDataNodeInfoPlan.java | 14 +
.../physical/sys/RegisterDataNodePlan.java | 22 +-
.../physical/sys/SchemaPartitionPlan.java | 98 -
.../physical/sys/SetStorageGroupPlan.java | 43 +-
.../confignode/service/executor/PlanExecutor.java | 29 +-
.../server/ConfigNodeRPCServerProcessor.java | 242 +-
.../iotdb/confignode/cli/TemporaryClientDemo.java | 74 +
.../confignode/consensus/RatisConsensusDemo.java | 43 +-
.../manager/ConfigManagerManualTest.java | 31 +-
.../hash/DeviceGroupHashExecutorManualTest.java | 7 +-
.../physical/SerializeDeserializeUT.java | 404 +++
.../server/ConfigNodeRPCServerProcessorTest.java | 506 ++-
consensus/pom.xml | 8 +-
.../org/apache/iotdb/consensus/IConsensus.java | 2 +
.../common/response/ConsensusWriteResponse.java | 6 +-
.../ratis/ApplicationStateMachineProxy.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 31 +-
.../iotdb/consensus/ratis/RequestMessage.java | 2 +-
.../iotdb/consensus/ratis/ResponseMessage.java | 2 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 14 +-
.../consensus/standalone/StandAloneConsensus.java | 10 +-
.../consensus/standalone/StandAloneServerImpl.java | 2 +-
.../consensus/statemachine/EmptyStateMachine.java | 2 +-
.../consensus/statemachine/IStateMachine.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 7 +-
.../standalone/StandAloneConsensusTest.java | 2 +-
distribution/pom.xml | 6 +
docker/src/main/Dockerfile-single-influxdb | 46 +
docs/UserGuide/API/InfluxDB-Protocol.md | 5 +-
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 396 +-
docs/zh/Community/About.md | 66 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 4 +-
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 493 ++-
example/rest-client-c-example/CMakeLists.txt | 25 +
example/rest-client-c-example/main.c | 14 +-
influxdb-protocol/pom.xml | 38 +-
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 1 +
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 20 +-
.../protocol/impl/IoTDBInfluxDBService.java | 12 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 42 +-
.../influxdb/integration/IoTDBInfluxDBIT.java | 34 +-
.../db/integration/IoTDBDeleteStorageGroupIT.java | 23 +
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 38 +
.../db/integration/IoTDBRecoverUnclosedIT.java | 17 +-
.../iotdb/db/integration/IoTDBSelectSchemaIT.java | 127 +
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 2 +-
.../sync/IoTDBSyncReceiverCollectorIT.java | 513 +++
.../db/integration/sync/IoTDBSyncReceiverIT.java | 357 ++
.../sync/IoTDBSyncReceiverLoaderIT.java | 210 ++
.../db/integration/sync/IoTDBSyncSenderIT.java | 304 ++
.../iotdb/db/integration/sync/SyncTestUtil.java | 203 ++
.../db/integration/sync/TransportClientMock.java | 69 +
.../IoTDBQueryVersionAdaptionIT.java | 1 -
.../session/IoTDBSessionDisableMemControlIT.java | 8 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 4 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 4 +-
.../src/test/resources/iotdb-engine.properties | 3 +-
integration/src/test/resources/logback-test.xml | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBSQLException.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 2 +-
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 2 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 2 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 2 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 1 +
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 2 +-
metrics/dropwizard-metrics/pom.xml | 2 +-
.../iotdb/commons/cluster/DataNodeLocation.java | 81 +
.../org/apache/iotdb/commons/cluster/Endpoint.java | 6 +-
.../commons/concurrent/IoTDBThreadPoolFactory.java | 12 +
.../iotdb/commons/concurrent/ThreadName.java | 6 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 15 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 32 +-
.../iotdb/commons/consensus/DataRegionId.java | 5 +
.../iotdb/commons/consensus/PartitionRegionId.java | 5 +
.../iotdb/commons/consensus/SchemaRegionId.java | 5 +
.../apache/iotdb/commons/hash/APHashExecutor.java | 42 -
.../iotdb/commons/hash/BKDRHashExecutor.java | 40 -
.../commons/hash/DeviceGroupHashExecutor.java | 31 -
.../apache/iotdb/commons/hash/JSHashExecutor.java | 40 -
.../iotdb/commons/hash/SDBMHashExecutor.java | 38 -
.../iotdb/commons/partition/DataNodeLocation.java | 104 -
.../iotdb/commons/partition/DataPartition.java | 167 +-
.../iotdb/commons/partition/RegionReplicaSet.java | 80 +-
.../iotdb/commons/partition/SchemaPartition.java | 137 +-
.../commons/partition/SeriesPartitionSlot.java | 35 +-
.../iotdb/commons/partition/TimePartitionSlot.java | 33 +
.../executor/SeriesPartitionExecutor.java | 52 +
.../partition/executor/hash/APHashExecutor.java | 45 +
.../partition/executor/hash/BKDRHashExecutor.java | 43 +
.../partition/executor/hash/JSHashExecutor.java | 43 +
.../partition/executor/hash/SDBMHashExecutor.java | 41 +
.../apache/iotdb/commons/service/ServiceType.java | 2 +
.../apache/iotdb/commons/utils/CommonUtils.java | 4 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 223 ++
.../apache/iotdb/commons/ConsensusGroupIdTest.java | 53 +
pom.xml | 18 +-
server/pom.xml | 26 +-
.../resources/conf/iotdb-engine.properties | 91 +-
.../resources/conf/iotdb-sync-client.properties | 35 -
.../assembly/resources/tools/rocksdb-transfer.bat | 126 +
.../assembly/resources/tools/rocksdb-transfer.sh | 82 +
.../assembly/resources/tools/start-sync-client.bat | 71 -
.../assembly/resources/tools/start-sync-client.sh | 54 -
.../assembly/resources/tools/stop-sync-client.bat | 23 -
.../assembly/resources/tools/stop-sync-client.sh | 30 -
.../apache/iotdb/db/client/ConfigNodeClient.java | 321 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 245 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 121 +-
.../consensus/statemachine/BaseStateMachine.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 46 +-
.../statemachine/SchemaRegionStateMachine.java | 22 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 18 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 81 +-
.../compaction/CompactionExceptionHandler.java | 247 ++
.../compaction/CompactionMetricsManager.java | 12 +-
.../compaction/CompactionRecoverManager.java | 119 +
.../db/engine/compaction/CompactionScheduler.java | 165 +-
.../compaction/CompactionTaskComparator.java | 112 -
.../engine/compaction/CompactionTaskManager.java | 5 +-
.../db/engine/compaction/CompactionUtils.java | 371 +-
.../db/engine/compaction/TsFileIdentifier.java | 229 --
.../DefaultCompactionTaskComparatorImpl.java | 110 +
.../comparator/ICompactionTaskComparator.java | 35 +
.../constant/CrossCompactionPerformer.java | 41 +
.../constant/CrossCompactionSelector.java | 47 +
.../constant/InnerSeqCompactionPerformer.java | 41 +
.../constant/InnerSequenceCompactionSelector.java | 48 +
.../constant/InnerUnseqCompactionPerformer.java | 41 +
.../InnerUnsequenceCompactionSelector.java | 48 +
.../AbstractCrossSpaceCompactionSelector.java | 56 -
.../cross/AbstractCrossSpaceCompactionTask.java | 113 -
.../compaction/cross/CrossCompactionStrategy.java | 79 -
.../compaction/cross/CrossSpaceCompactionTask.java | 290 ++
.../cross/CrossSpaceCompactionTaskFactory.java | 49 -
.../compaction/cross/ICrossSpaceSelector.java | 30 +
.../RewriteCrossSpaceCompactionResource.java | 206 ++
.../RewriteCrossSpaceCompactionSelector.java | 60 +-
.../manage/CrossSpaceCompactionResource.java | 206 --
.../selector/ICrossSpaceMergeFileSelector.java | 2 -
.../cross/rewrite/selector/IMergePathSelector.java | 31 -
.../cross/rewrite/selector/MergeFileStrategy.java | 27 -
.../cross/rewrite/selector/NaivePathSelector.java | 55 -
.../selector/RewriteCompactionFileSelector.java | 19 +-
.../rewrite/task/ReadPointPerformerSubTask.java | 107 +
.../task/RewriteCrossSpaceCompactionTask.java | 254 --
.../cross/rewrite/task/SubCompactionTask.java | 107 -
.../AbstractInnerSpaceCompactionSelector.java | 59 -
.../inner/AbstractInnerSpaceCompactionTask.java | 160 -
.../compaction/inner/IInnerSeqSpaceSelector.java | 28 +
.../compaction/inner/IInnerUnseqSpaceSelector.java | 28 +
.../compaction/inner/InnerCompactionStrategy.java | 80 -
.../compaction/inner/InnerSpaceCompactionTask.java | 378 ++
.../inner/InnerSpaceCompactionTaskFactory.java | 48 -
.../sizetiered/SizeTieredCompactionSelector.java | 70 +-
.../inner/sizetiered/SizeTieredCompactionTask.java | 280 --
.../inner/utils/InnerSpaceCompactionUtils.java | 302 --
.../compaction/log/CompactionLogAnalyzer.java | 162 +
.../db/engine/compaction/log/CompactionLogger.java | 83 +
.../db/engine/compaction/log/TsFileIdentifier.java | 234 ++
.../compaction/performer/ICompactionPerformer.java | 49 +
.../performer/ICrossCompactionPerformer.java | 27 +
.../performer/ISeqCompactionPerformer.java | 27 +
.../performer/IUnseqCompactionPerformer.java | 27 +
.../impl/ReadChunkCompactionPerformer.java | 166 +
.../impl/ReadPointCompactionPerformer.java | 360 ++
.../task/AbstractCompactionSelector.java | 29 -
.../compaction/task/AbstractCompactionTask.java | 7 +-
.../task/CompactionExceptionHandler.java | 248 --
.../compaction/task/CompactionRecoverManager.java | 118 -
.../compaction/task/CompactionRecoverTask.java | 6 +-
.../compaction/task/ICompactionSelector.java | 54 +
.../utils/log/CompactionLogAnalyzer.java | 163 -
.../compaction/utils/log/CompactionLogger.java | 84 -
.../iotdb/db/engine/modification/Deletion.java | 23 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 203 +-
.../db/engine/storagegroup/TsFileManager.java | 38 +
.../db/engine/storagegroup/TsFileProcessor.java | 25 +-
.../dataregion/StorageGroupManager.java | 10 +
.../service/TriggerRegistrationService.java | 10 +-
.../iotdb/db/exception/BatchProcessException.java | 2 +-
.../SyncDeviceOwnerConflictException.java | 40 -
.../metadata/AcquireLockTimeoutException.java | 26 +
.../metadata/DataTypeMismatchException.java | 6 +-
.../metadata/DifferentTemplateException.java | 33 -
.../metadata/DuplicatedTemplateException.java | 31 -
.../metadata/NoTemplateOnMNodeException.java | 33 -
.../metadata/StorageGroupNotSetException.java | 6 +
.../metadata/TemplateImcompatibeException.java | 40 -
.../metadata/TemplateIsInUseException.java | 33 -
.../metadata/UndefinedTemplateException.java | 31 -
.../metadata/cache/MNodeNotCachedException.java | 28 +
.../metadata/cache/MNodeNotPinnedException.java | 29 +
.../schemafile/RecordDuplicatedException.java | 34 +
.../metadata/schemafile/SchemaFileNotExists.java | 34 +
.../schemafile/SchemaPageOverflowException.java | 34 +
.../schemafile/SegmentNotFoundException.java | 41 +
.../schemafile/SegmentOverflowException.java | 41 +
.../template/DifferentTemplateException.java | 34 +
.../template/DuplicatedTemplateException.java | 32 +
.../template/NoTemplateOnMNodeException.java | 34 +
.../template/TemplateImcompatibeException.java | 41 +
.../template/TemplateIsInUseException.java | 34 +
.../template/UndefinedTemplateException.java | 32 +
.../exception/sql/StatementAnalyzeException.java | 13 +-
.../sync/PipeDataLoadBearableException.java | 25 +
.../db/exception/sync/PipeDataLoadException.java | 25 +
.../sync/PipeDataLoadUnbearableException.java | 25 +
.../iotdb/db/exception/sync/PipeException.java | 36 +
.../db/exception/sync/PipeServerException.java | 34 +
.../iotdb/db/exception/sync/PipeSinkException.java | 42 +
.../iotdb/db/metadata/Executor/SchemaVisitor.java | 96 +
.../iotdb/db/metadata/LocalConfigManager.java | 785 ----
.../apache/iotdb/db/metadata/LocalConfigNode.java | 757 ++++
.../db/metadata/LocalSchemaPartitionTable.java | 4 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 99 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 4 +
.../db/metadata/idtable/IDTableHashmapImpl.java | 50 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 19 +-
.../iotdb/db/metadata/idtable/entry/IDeviceID.java | 4 +
.../idtable/entry/InsertMeasurementMNode.java | 23 +-
.../db/metadata/idtable/entry/PlainDeviceID.java | 12 +
.../db/metadata/idtable/entry/SHA256DeviceID.java | 21 +
.../db/metadata/lastCache/LastCacheManager.java | 8 +-
.../iotdb/db/metadata/logfile/MLogTxtWriter.java | 11 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 8 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 17 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 29 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 25 +-
.../apache/iotdb/db/metadata/mnode/MNodeUtils.java | 1 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 16 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 11 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 8 +
.../metadata/mnode/container/IMNodeContainer.java | 25 +
.../mnode/container/MNodeContainerMapImpl.java | 26 +
.../metadata/mnode/container/MNodeContainers.java | 103 +
.../mnode/estimator/BasicMNodSizeEstimator.java | 117 +
.../mnode/estimator/IMNodeSizeEstimator.java | 38 +
.../db/metadata/mnode/iterator/IMNodeIterator.java | 28 +
.../db/metadata/mnode/iterator/MNodeIterator.java | 48 +
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 46 +-
.../iotdb/db/metadata/mtree/MTreeBelowSG.java | 855 +++--
.../db/metadata/mtree/store/CachedMTreeStore.java | 590 +++
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 61 +
.../db/metadata/mtree/store/MemMTreeStore.java | 170 +
.../mtree/store/disk/CachedMNodeContainer.java | 428 +++
.../mtree/store/disk/ICachedMNodeContainer.java | 80 +
.../mtree/store/disk/MTreeFlushTaskManager.java | 75 +
.../mtree/store/disk/MTreeReleaseTaskManager.java | 74 +
.../db/metadata/mtree/store/disk/SegmentLock.java | 91 +
.../mtree/store/disk/cache/CacheEntry.java | 48 +
.../mtree/store/disk/cache/CacheManager.java | 537 +++
.../mtree/store/disk/cache/ICacheManager.java | 52 +
.../mtree/store/disk/cache/LRUCacheManager.java | 256 ++
.../mtree/store/disk/cache/PlainCacheManager.java | 72 +
.../disk/memcontrol/CachedMNodeSizeEstimator.java | 71 +
.../mtree/store/disk/memcontrol/IMemManager.java | 52 +
.../store/disk/memcontrol/MemManagerHolder.java | 41 +
.../MemManagerNodeEstimatedSizeBasedImpl.java | 132 +
.../memcontrol/MemManagerNodeNumBasedImpl.java | 105 +
.../mtree/store/disk/schemafile/ISchemaFile.java | 63 +
.../mtree/store/disk/schemafile/ISchemaPage.java | 125 +
.../mtree/store/disk/schemafile/ISegment.java | 95 +
.../store/disk/schemafile/MockSchemaFile.java | 235 ++
.../mtree/store/disk/schemafile/RecordUtils.java | 339 ++
.../mtree/store/disk/schemafile/SchemaFile.java | 937 +++++
.../mtree/store/disk/schemafile/SchemaPage.java | 623 ++++
.../mtree/store/disk/schemafile/Segment.java | 708 ++++
.../db/metadata/mtree/traverser/Traverser.java | 169 +-
.../traverser/collector/CollectorTraverser.java | 11 +-
.../mtree/traverser/collector/EntityCollector.java | 11 +-
.../traverser/collector/MNodeAboveSGCollector.java | 6 +-
.../mtree/traverser/collector/MNodeCollector.java | 6 +-
.../traverser/collector/MeasurementCollector.java | 15 +-
.../traverser/collector/StorageGroupCollector.java | 6 +-
.../mtree/traverser/counter/CounterTraverser.java | 6 +-
.../mtree/traverser/counter/EntityCounter.java | 6 +-
.../counter/MNodeAboveSGLevelCounter.java | 6 +-
.../mtree/traverser/counter/MNodeLevelCounter.java | 5 +-
.../traverser/counter/MeasurementCounter.java | 6 +-
.../counter/MeasurementGroupByLevelCounter.java | 6 +-
.../traverser/counter/StorageGroupCounter.java | 6 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 55 +
.../iotdb/db/metadata/path/MeasurementPath.java | 41 +
.../apache/iotdb/db/metadata/path/PartialPath.java | 30 +
.../db/metadata/path/PathDeserializeUtil.java | 59 +
.../iotdb/db/metadata/rescon/MemoryStatistics.java | 97 +
.../db/metadata/rescon/SchemaResourceManager.java | 67 +
.../db/metadata/rescon/TimeseriesStatistics.java | 38 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 193 +
.../db/metadata/schemaregion/SchemaEngine.java | 63 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 26 +
.../db/metadata/schemaregion/SchemaRegion.java | 698 ++--
.../metadata/schemaregion/SchemaRegionUtils.java | 101 +
.../schemaregion/rocksdb/CheckKeyResult.java | 50 +
.../schemaregion/rocksdb/RSchemaConstants.java | 76 +
.../schemaregion/rocksdb/RSchemaLogger.java | 61 +
.../rocksdb/RSchemaReadWriteHandler.java | 514 +++
.../schemaregion/rocksdb/RSchemaRegion.java | 1917 ++++++++++
.../schemaregion/rocksdb/RSchemaUtils.java | 592 +++
.../schemaregion/rocksdb/mnode/REntityMNode.java | 124 +
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 197 +
.../schemaregion/rocksdb/mnode/RMNode.java | 234 ++
.../schemaregion/rocksdb/mnode/RMNodeType.java | 49 +
.../rocksdb/mnode/RMNodeValueType.java | 47 +
.../rocksdb/mnode/RMeasurementMNode.java | 262 ++
.../rocksdb/mnode/RStorageGroupMNode.java | 102 +
.../storagegroup/IStorageGroupSchemaManager.java | 10 +-
.../storagegroup/StorageGroupSchemaManager.java | 30 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 10 +-
.../iotdb/db/metadata/template/Template.java | 51 +-
.../db/metadata/template/TemplateManager.java | 61 +-
.../db/metadata/upgrade/MetadataUpgrader.java | 5 +-
.../iotdb/db/mpp/buffer/DataBlockManager.java | 16 +-
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 5 +
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 5 +-
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 1 +
.../apache/iotdb/db/mpp/buffer/TsBlockSerde.java | 36 -
.../iotdb/db/mpp/buffer/TsBlockSerdeFactory.java | 2 +
.../org/apache/iotdb/db/mpp/common/DataRegion.java | 58 -
.../iotdb/db/mpp/common/FragmentInstanceId.java | 42 +-
.../iotdb/db/mpp/common/GroupByTimeParameter.java | 27 -
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 23 +
.../org/apache/iotdb/db/mpp/common/QueryId.java | 4 +
.../db/mpp/common/filter/BasicFunctionFilter.java | 20 +
.../mpp/common/filter/FilterDeserializeUtil.java | 63 +
.../iotdb/db/mpp/common/filter/FunctionFilter.java | 43 +
.../iotdb/db/mpp/common/filter/InFilter.java | 23 +
.../iotdb/db/mpp/common/filter/LikeFilter.java | 18 +
.../iotdb/db/mpp/common/filter/QueryFilter.java | 60 +
.../iotdb/db/mpp/common/filter/RegexpFilter.java | 16 +
.../iotdb/db/mpp/common/header/ColumnHeader.java | 125 +
.../iotdb/db/mpp/common/header/DatasetHeader.java | 86 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 90 +
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 47 +
.../db/mpp/common/schematree/PathPatternNode.java | 48 +-
.../db/mpp/common/schematree/PathPatternTree.java | 138 +-
.../db/mpp/common/schematree/SchemaEntityNode.java | 51 +
.../mpp/common/schematree/SchemaInternalNode.java | 47 +-
.../common/schematree/SchemaMeasurementNode.java | 49 +-
.../iotdb/db/mpp/common/schematree/SchemaNode.java | 17 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 182 +-
.../iotdb/db/mpp/execution/ConfigExecution.java | 110 -
.../apache/iotdb/db/mpp/execution/DataDriver.java | 10 +-
.../iotdb/db/mpp/execution/DataDriverContext.java | 8 +-
.../iotdb/db/mpp/execution/ExecutionResult.java | 2 +-
.../db/mpp/execution/FragmentInstanceInfo.java | 3 +-
.../db/mpp/execution/FragmentInstanceManager.java | 4 +-
.../apache/iotdb/db/mpp/execution/IConfigTask.java | 26 -
.../iotdb/db/mpp/execution/QueryExecution.java | 22 +-
.../iotdb/db/mpp/execution/SampleConfigTask.java | 47 -
.../iotdb/db/mpp/execution/SchemaDriver.java | 3 +-
.../db/mpp/execution/SchemaDriverContext.java | 8 +-
.../db/mpp/execution/config/ConfigExecution.java | 123 +
.../iotdb/db/mpp/execution/config/IConfigTask.java | 26 +
.../db/mpp/execution/config/SampleConfigTask.java | 47 +
.../mpp/execution/config/SetStorageGroupTask.java | 75 +
.../scheduler/AbstractFragInsStateTracker.java | 2 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 18 +-
.../db/mpp/operator/process/TransformOperator.java | 118 +
.../operator/schema/DevicesSchemaScanOperator.java | 97 +
.../mpp/operator/schema/SchemaFetchOperator.java | 129 +
.../mpp/operator/schema/SchemaMergeOperator.java | 79 +
.../db/mpp/operator/schema/SchemaScanOperator.java | 107 +
.../schema/TimeSeriesSchemaScanOperator.java | 142 +
.../db/mpp/operator/source/DataSourceOperator.java | 26 +
.../db/mpp/operator/source/ExchangeOperator.java | 93 +
.../source/SeriesAggregateScanOperator.java | 32 +-
.../db/mpp/operator/source/SeriesScanOperator.java | 9 +-
.../db/mpp/operator/source/SeriesScanUtil.java | 8 +-
.../db/mpp/operator/source/SourceOperator.java | 3 -
.../db/mpp/schedule/FragmentInstanceScheduler.java | 2 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 14 +
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 337 +-
.../mpp/sql/analyze/ClusterPartitionFetcher.java | 213 +-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 72 +-
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 37 +-
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 7 +-
.../db/mpp/sql/analyze/IPartitionFetcher.java | 16 +-
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 7 +-
.../sql/analyze/StandalonePartitionFetcher.java | 23 +-
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 7 +-
.../iotdb/db/mpp/sql/constant/StatementType.java | 5 +-
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 29 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 151 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 124 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 94 +-
.../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 48 +
.../db/mpp/sql/planner/plan/FragmentInstance.java | 109 +-
.../db/mpp/sql/planner/plan/IOutputPlanNode.java | 2 +-
.../db/mpp/sql/planner/plan/PlanFragment.java | 39 +-
.../plan/SimpleFragmentParallelPlanner.java | 32 +-
.../planner/plan/WriteFragmentParallelPlanner.java | 70 +
.../db/mpp/sql/planner/plan/node/ColumnHeader.java | 88 -
.../db/mpp/sql/planner/plan/node/PlanNode.java | 40 +-
.../db/mpp/sql/planner/plan/node/PlanNodeId.java | 30 +
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 41 +-
.../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 3 +
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 35 +
.../planner/plan/node/SimplePlanNodeRewriter.java | 4 +
.../mpp/sql/planner/plan/node/WritePlanNode.java | 36 +
.../node/metedata/read/DevicesSchemaScanNode.java | 108 +
.../plan/node/metedata/read/SchemaFetchNode.java | 90 +
.../plan/node/metedata/read/SchemaMergeNode.java | 76 +
.../plan/node/metedata/read/SchemaScanNode.java | 128 +
.../plan/node/metedata/read/ShowDevicesNode.java | 15 +-
.../planner/plan/node/metedata/read/ShowNode.java | 4 +-
.../metedata/read/TimeSeriesSchemaScanNode.java | 145 +
.../node/metedata/write/AlterTimeSeriesNode.java | 50 +-
.../plan/node/metedata/write/AuthorNode.java | 159 +-
.../write/CreateAlignedTimeSeriesNode.java | 27 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 145 +-
.../planner/plan/node/process/AggregateNode.java | 55 +-
.../planner/plan/node/process/DeviceMergeNode.java | 53 +-
.../planner/plan/node/process/ExchangeNode.java | 56 +-
.../sql/planner/plan/node/process/FillNode.java | 38 +-
.../sql/planner/plan/node/process/FilterNode.java | 36 +-
.../planner/plan/node/process/FilterNullNode.java | 34 +-
.../plan/node/process/GroupByLevelNode.java | 44 +-
.../sql/planner/plan/node/process/LimitNode.java | 17 +-
.../sql/planner/plan/node/process/OffsetNode.java | 21 +-
.../sql/planner/plan/node/process/SortNode.java | 49 +-
.../planner/plan/node/process/TimeJoinNode.java | 34 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 48 +-
.../plan/node/source/SeriesAggregateScanNode.java | 70 +-
.../planner/plan/node/source/SeriesScanNode.java | 79 +-
.../sql/planner/plan/node/source/SourceNode.java | 4 +-
.../plan/node/write/InsertMultiTabletsNode.java | 31 +-
.../sql/planner/plan/node/write/InsertNode.java | 67 +-
.../sql/planner/plan/node/write/InsertRowNode.java | 351 +-
.../planner/plan/node/write/InsertRowsNode.java | 26 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 26 +-
.../planner/plan/node/write/InsertTabletNode.java | 482 ++-
.../db/mpp/sql/rewriter/WildcardsRemover.java | 14 +-
.../db/mpp/sql/statement/StatementVisitor.java | 35 +-
.../db/mpp/sql/statement/component/FillPolicy.java | 2 +-
.../statement/component/FilterNullComponent.java | 44 +
.../statement/component/GroupByLevelComponent.java | 2 +-
.../component/GroupByLevelController.java | 2 +-
.../mpp/sql/statement/component/ResultColumn.java | 9 +
.../sql/statement/component/SelectComponent.java | 29 +-
.../statement/crud/AggregationQueryStatement.java | 13 +-
.../sql/statement/crud/GroupByQueryStatement.java | 11 +
.../crud/InsertMultiTabletsStatement.java | 8 +
.../mpp/sql/statement/crud/InsertRowStatement.java | 13 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 1 +
.../sql/statement/crud/InsertRowsStatement.java | 8 +
.../db/mpp/sql/statement/crud/InsertStatement.java | 1 +
.../sql/statement/crud/InsertTabletStatement.java | 11 +-
.../mpp/sql/statement/crud/LastQueryStatement.java | 11 +
.../db/mpp/sql/statement/crud/QueryStatement.java | 86 +-
.../metadata/AlterTimeSeriesStatement.java | 1 +
.../metadata/CreateAlignedTimeSeriesStatement.java | 1 +
.../metadata/CreateTimeSeriesStatement.java | 1 +
.../statement/metadata/SchemaFetchStatement.java | 56 +
.../metadata/SetStorageGroupStatement.java | 41 +
.../statement/metadata/ShowDevicesStatement.java | 6 +
.../mpp/sql/statement/metadata/ShowStatement.java | 10 +
.../metadata/ShowStorageGroupStatement.java | 42 +
.../metadata/ShowTimeSeriesStatement.java | 6 +
.../db/mpp/sql/statement/sys/AuthorStatement.java | 4 +-
.../db/protocol/influxdb/handler/QueryHandler.java | 14 +-
.../influxdb/meta/InfluxDBMetaManager.java | 13 +-
.../protocol/influxdb/util/QueryResultUtils.java | 3 +-
.../iotdb/db/protocol/mqtt/PublishHandler.java | 2 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 26 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 195 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 14 +-
.../db/qp/logical/sys/CreatePipeOperator.java | 69 +
.../db/qp/logical/sys/CreatePipeSinkOperator.java | 61 +
.../iotdb/db/qp/logical/sys/DropPipeOperator.java | 44 +
.../db/qp/logical/sys/DropPipeSinkOperator.java | 43 +
.../iotdb/db/qp/logical/sys/ShowPipeOperator.java | 45 +
.../db/qp/logical/sys/ShowPipeServerOperator.java | 38 +
.../db/qp/logical/sys/ShowPipeSinkOperator.java | 45 +
.../qp/logical/sys/ShowPipeSinkTypeOperator.java | 38 +
.../iotdb/db/qp/logical/sys/StartPipeOperator.java | 44 +
.../db/qp/logical/sys/StartPipeServerOperator.java | 38 +
.../iotdb/db/qp/logical/sys/StopPipeOperator.java | 44 +
.../db/qp/logical/sys/StopPipeServerOperator.java | 38 +
.../org/apache/iotdb/db/qp/physical/BatchPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 10 +
.../qp/physical/crud/InsertMultiTabletsPlan.java | 4 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 2 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 4 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 37 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 15 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/CreatePipePlan.java | 110 +
.../db/qp/physical/sys/CreatePipeSinkPlan.java | 98 +
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 10 +
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/DropPipeSinkPlan.java | 45 +
.../iotdb/db/qp/physical/sys/OperatePipePlan.java | 45 +
.../iotdb/db/qp/physical/sys/ShowPipePlan.java | 33 +
.../db/qp/physical/sys/ShowPipeServerPlan.java | 26 +
.../iotdb/db/qp/physical/sys/ShowPipeSinkPlan.java | 33 +
.../db/qp/physical/sys/ShowPipeSinkTypePlan.java | 26 +
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 6 +-
.../db/qp/physical/sys/StartPipeServerPlan.java | 56 +
.../db/qp/physical/sys/StopPipeServerPlan.java | 56 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 193 +-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 15 +
.../iotdb/db/qp/utils/GroupByLevelController.java | 90 +
.../db/query/aggregation/AggregateResult.java | 9 +
.../iotdb/db/query/control/SessionManager.java | 14 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 4 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 3 +-
.../iotdb/db/query/expression/Expression.java | 18 +-
.../iotdb/db/query/expression/ExpressionType.java | 115 +
.../iotdb/db/query/expression/ResultColumn.java | 17 +
.../expression/binary/AdditionExpression.java | 19 +
.../query/expression/binary/BinaryExpression.java | 22 +-
.../expression/binary/DivisionExpression.java | 19 +
.../query/expression/binary/EqualToExpression.java | 19 +
.../expression/binary/GreaterEqualExpression.java | 19 +
.../expression/binary/GreaterThanExpression.java | 19 +
.../expression/binary/LessEqualExpression.java | 19 +
.../expression/binary/LessThanExpression.java | 19 +
.../expression/binary/LogicAndExpression.java | 19 +
.../query/expression/binary/LogicOrExpression.java | 19 +
.../query/expression/binary/ModuloExpression.java | 19 +
.../binary/MultiplicationExpression.java | 19 +
.../expression/binary/NonEqualExpression.java | 19 +
.../expression/binary/SubtractionExpression.java | 19 +
.../db/query/expression/unary/ConstantOperand.java | 30 +-
.../query/expression/unary/FunctionExpression.java | 57 +-
.../query/expression/unary/LogicNotExpression.java | 43 +-
.../query/expression/unary/NegationExpression.java | 37 +-
.../query/expression/unary/TimeSeriesOperand.java | 29 +-
.../db/query/udf/core/executor/UDTFContext.java | 60 +
.../iotdb/db/query/udf/core/layer/DAGBuilder.java | 9 +-
.../query/udf/core/layer/EvaluationDAGBuilder.java | 100 +
.../query/udf/core/layer/RawQueryInputLayer.java | 4 +
.../query/udf/core/layer/TsBlockInputDataSet.java | 64 +
.../transformer/ArithmeticNegationTransformer.java | 6 +-
.../udf/core/transformer/LogicNotTransformer.java | 6 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 91 +-
.../iotdb/db/service/InternalServiceImpl.java | 51 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 11 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 2 +
.../db/service/basic/BasicOpenSessionResp.java | 2 +-
.../thrift/impl/DataNodeManagementServiceImpl.java | 111 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 44 +-
.../db/service/thrift/impl/TSServiceImpl.java | 4 +-
.../apache/iotdb/db/sync/conf/SyncConstant.java | 85 +-
.../apache/iotdb/db/sync/conf/SyncPathUtil.java | 100 +
.../iotdb/db/sync/conf/SyncSenderConfig.java | 127 -
.../iotdb/db/sync/conf/SyncSenderDescriptor.java | 124 -
.../org/apache/iotdb/db/sync/package-info.java | 38 -
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 85 +
.../apache/iotdb/db/sync/pipedata/PipeData.java | 96 +
.../iotdb/db/sync/pipedata/SchemaPipeData.java | 98 +
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 177 +
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 438 +++
.../db/sync/pipedata/queue/PipeDataQueue.java | 37 +
.../sync/pipedata/queue/PipeDataQueueFactory.java | 57 +
.../iotdb/db/sync/receiver/ReceiverService.java | 278 ++
.../iotdb/db/sync/receiver/SyncServerManager.java | 129 -
.../db/sync/receiver/SyncServerManagerMBean.java | 34 -
.../db/sync/receiver/SyncServerThriftHandler.java | 56 -
.../db/sync/receiver/collector/Collector.java | 170 +
.../db/sync/receiver/load/DeletionLoader.java | 48 +
.../iotdb/db/sync/receiver/load/FileLoader.java | 203 --
.../db/sync/receiver/load/FileLoaderManager.java | 213 --
.../iotdb/db/sync/receiver/load/IFileLoader.java | 50 -
.../iotdb/db/sync/receiver/load/ILoadLogger.java | 57 -
.../iotdb/db/sync/receiver/load/ILoader.java | 29 +
.../iotdb/db/sync/receiver/load/LoadLogger.java | 72 -
.../iotdb/db/sync/receiver/load/LoadType.java | 25 -
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 60 +
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 67 +
.../iotdb/db/sync/receiver/manager/PipeInfo.java | 85 +
.../db/sync/receiver/manager/PipeMessage.java | 76 +
.../db/sync/receiver/manager/ReceiverManager.java | 216 ++
.../receiver/recover/ISyncReceiverLogAnalyzer.java | 33 -
.../sync/receiver/recover/ISyncReceiverLogger.java | 50 -
.../receiver/recover/SyncReceiverLogAnalyzer.java | 154 -
.../sync/receiver/recover/SyncReceiverLogger.java | 72 -
.../db/sync/receiver/recovery/ReceiverLog.java | 127 +
.../receiver/recovery/ReceiverLogAnalyzer.java | 157 +
.../db/sync/receiver/transfer/SyncServiceImpl.java | 370 --
.../db/sync/sender/manage/ISyncFileManager.java | 72 -
.../db/sync/sender/manage/SyncFileManager.java | 291 --
.../db/sync/sender/manager/SchemaSyncManager.java | 163 +
.../db/sync/sender/manager/TsFileSyncManager.java | 118 +
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 97 +
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 106 +
.../apache/iotdb/db/sync/sender/pipe/PipeSink.java | 47 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 334 ++
.../sender/recover/ISyncSenderLogAnalyzer.java | 47 -
.../db/sync/sender/recover/ISyncSenderLogger.java | 67 -
.../sync/sender/recover/SyncSenderLogAnalyzer.java | 128 -
.../db/sync/sender/recover/SyncSenderLogger.java | 72 -
.../db/sync/sender/recovery/SenderLogAnalyzer.java | 172 +
.../db/sync/sender/recovery/SenderLogger.java | 141 +
.../db/sync/sender/recovery/TsFilePipeLogger.java | 150 +
.../db/sync/sender/service/SenderService.java | 417 +++
.../db/sync/sender/service/TransportHandler.java | 127 +
.../iotdb/db/sync/sender/transfer/ISyncClient.java | 95 -
.../iotdb/db/sync/sender/transfer/SyncClient.java | 810 -----
.../db/sync/transport/client/ITransportClient.java | 28 +
.../db/sync/transport/client/TransportClient.java | 527 +++
.../db/sync/transport/conf/TransportConfig.java | 45 +
.../db/sync/transport/conf/TransportConstant.java | 36 +
.../transport/server/TransportServerManager.java | 129 +
.../server/TransportServerManagerMBean.java | 34 +
.../server/TransportServerThriftHandler.java | 52 +
.../transport/server/TransportServiceImpl.java | 385 ++
.../org/apache/iotdb/db/utils/DataTypeUtils.java | 8 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 10 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 2 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +-
.../iotdb/db/utils/IExpressionDeserializeUtil.java | 51 +
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 181 +-
.../org/apache/iotdb/db/utils/StatusUtils.java | 46 -
.../java/org/apache/iotdb/db/utils/SyncUtils.java | 109 -
.../db/utils/writelog/SingleFileLogReader.java | 9 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 5 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 4 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 5 +-
.../compaction/CompactionTaskComparatorTest.java | 31 +-
.../compaction/CompactionTaskManagerTest.java | 101 +-
.../db/engine/compaction/CompactionUtilsTest.java | 3825 -------------------
.../ReadPointCompactionPerformerTest.java | 3826 ++++++++++++++++++++
.../db/engine/compaction/TsFileIdentifierUT.java | 3 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 23 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 52 +-
.../engine/compaction/cross/MergeUpgradeTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 87 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 25 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 46 +-
.../compaction/inner/InnerCompactionLogTest.java | 2 +-
.../inner/InnerCompactionSchedulerTest.java | 18 +-
.../compaction/inner/InnerSeqCompactionTest.java | 40 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 44 +-
.../InnerSpaceCompactionUtilsAlignedTest.java | 534 ---
.../InnerSpaceCompactionUtilsNoAlignedTest.java | 918 -----
.../inner/InnerSpaceCompactionUtilsOldTest.java | 128 -
.../compaction/inner/InnerUnseqCompactionTest.java | 14 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 534 +++
.../ReadChunkCompactionPerformerNoAlignedTest.java | 918 +++++
.../inner/ReadChunkCompactionPerformerOldTest.java | 133 +
.../SizeTieredCompactionRecoverTest.java | 77 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 2 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 20 +-
.../recover/SizeTieredCompactionRecoverTest.java | 49 +-
.../task/FakedCrossSpaceCompactionTask.java | 62 -
.../task/FakedCrossSpaceCompactionTaskFactory.java | 47 -
.../task/FakedInnerSpaceCompactionTask.java | 97 -
.../task/FakedInnerSpaceCompactionTaskFactory.java | 50 -
.../compaction/utils/CompactionClearUtils.java | 2 +-
.../compaction/utils/CompactionConfigRestorer.java | 13 +-
.../storagegroup/StorageGroupProcessorTest.java | 12 +-
.../engine/storagegroup/TsFileProcessorTest.java | 2 +-
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 79 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 2 +-
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 4 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 58 +-
.../mtree/disk/CachedMNodeContainerTest.java | 51 +
.../db/metadata/mtree/disk/MemManagerTest.java | 112 +
.../mtree/multimode/MTreeDiskModeTest.java | 42 +
.../mtree/multimode/MTreeFullMemoryTest.java | 28 +
.../mtree/multimode/MTreeMemoryModeTest.java | 35 +
.../mtree/multimode/MTreeNonMemoryTest.java | 28 +
.../mtree/multimode/MTreePartialMemoryTest.java | 28 +
.../metadata/mtree/schemafile/RecordUtilTests.java | 78 +
.../metadata/mtree/schemafile/SchemaFileTest.java | 787 ++++
.../metadata/mtree/schemafile/SchemaPageTest.java | 130 +
.../db/metadata/mtree/schemafile/SegmentTest.java | 148 +
.../db/metadata/multimode/SchemaDiskModeTest.java | 42 +
.../metadata/multimode/SchemaFullMemoryTest.java | 29 +
.../metadata/multimode/SchemaMemoryModeTest.java | 35 +
.../db/metadata/multimode/SchemaNonMemoryTest.java | 29 +
.../multimode/SchemaPartialMemoryTest.java | 28 +
.../schemaregion/rocksdb/MRocksDBBenchmark.java | 98 +
.../schemaregion/rocksdb/MRocksDBUnitTest.java | 238 ++
.../rocksdb/RSchemaReadWriteHandlerTest.java | 77 +
.../rocksdb/RSchemaRegionAdvancedTest.java | 167 +
.../rocksdb/RocksDBBenchmarkEngine.java | 153 +
.../schemaregion/rocksdb/RocksDBBenchmarkTask.java | 109 +
.../schemaregion/rocksdb/RocksDBTestUtils.java | 72 +
.../apache/iotdb/db/mpp/buffer/SinkHandleTest.java | 42 +-
.../iotdb/db/mpp/buffer/SourceHandleTest.java | 21 +-
.../java/org/apache/iotdb/db/mpp/buffer/Utils.java | 1 +
.../iotdb/db/mpp/common/PathPatternTreeTest.java | 131 -
.../apache/iotdb/db/mpp/common/SchemaTreeTest.java | 214 --
.../mpp/common/schematree/PathPatternTreeTest.java | 193 +
.../db/mpp/common/schematree/SchemaTreeTest.java | 350 ++
.../iotdb/db/mpp/execution/DataDriverTest.java | 8 +-
.../iotdb/db/mpp/operator/LimitOperatorTest.java | 8 +-
.../db/mpp/operator/SchemaScanOperatorTest.java | 242 ++
.../db/mpp/operator/SeriesScanOperatorTest.java | 4 +-
.../db/mpp/operator/TimeJoinOperatorTest.java | 8 +-
.../operator/schema/SchemaFetchOperatorTest.java | 149 +
.../db/mpp/sql/plan/DistributionPlannerTest.java | 188 +-
.../db/mpp/sql/plan/FragmentInstanceIdTest.java | 38 +
.../db/mpp/sql/plan/FragmentInstanceSerdeTest.java | 152 +
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 520 ++-
.../db/mpp/sql/plan/QueryLogicalPlanUtil.java | 2 +-
.../sql/plan/node/PlanNodeDeserializeHelper.java | 37 +
.../metadata/read/ShowDevicesNodeSerdeTest.java | 42 +
.../plan/node/process/AggregateNodeSerdeTest.java | 58 +
.../node/process/DeviceMergeNodeSerdeTest.java | 81 +
.../plan/node/process/ExchangeNodeSerdeTest.java | 101 +
.../sql/plan/node/process/FillNodeSerdeTest.java | 85 +
.../sql/plan/node/process/FilterNodeSerdeTest.java | 97 +
.../plan/node/process/FilterNullNodeSerdeTest.java | 102 +
.../node/process/GroupByLevelNodeSerdeTest.java | 117 +
.../sql/plan/node/process/LimitNodeSerdeTest.java | 119 +
.../sql/plan/node/process/OffsetNodeSerdeTest.java | 186 +
.../sql/plan/node/process/SortNodeSerdeTest.java | 130 +
.../plan/node/process/TimeJoinNodeSerdeTest.java | 135 +
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 53 +
.../source/SeriesAggregateScanNodeSerdeTest.java | 71 +
.../plan/node/source/SeriesScanNodeSerdeTest.java | 55 +
.../plan/node/write/InsertRowNodeSerdeTest.java | 126 +
.../plan/node/write/InsertTabletNodeSerdeTest.java | 94 +
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 28 +
.../iotdb/db/service/InternalServiceImplTest.java | 167 +
.../sync/pipedata/BufferedPipeDataQueueTest.java | 542 +++
.../iotdb/db/sync/pipedata/PipeDataTest.java | 86 +
.../db/sync/receiver/load/FileLoaderTest.java | 405 ---
.../sync/receiver/manager/ReceiverManagerTest.java | 98 +
.../recover/SyncReceiverLogAnalyzerTest.java | 229 --
.../receiver/recover/SyncReceiverLoggerTest.java | 115 -
.../receiver/recovery/ReceiverLogAnalyzerTest.java | 124 +
.../db/sync/sender/manage/SyncFileManagerTest.java | 350 --
.../sender/recover/SyncSenderLogAnalyzerTest.java | 201 -
.../sync/sender/recover/SyncSenderLoggerTest.java | 112 -
.../db/sync/sender/transfer/SyncClientTest.java | 161 -
.../db/sync/transport/TransportServiceTest.java | 205 ++
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 9 +-
server/src/test/resources/iotdb-engine.properties | 4 +
server/src/test/resources/logback-test.xml | 2 +-
.../apache/iotdb/rpc/BatchExecutionException.java | 2 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 2 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 2 +-
.../org/apache/iotdb/rpc/RedirectException.java | 2 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 19 +-
.../iotdb/rpc/StatementExecutionException.java | 6 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 18 +-
.../java/org/apache/iotdb/session/Session.java | 2 +-
.../apache/iotdb/session/SessionConnection.java | 4 +-
.../apache/iotdb/session/util/SessionUtils.java | 2 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 2 +-
thrift-cluster/pom.xml | 97 +-
thrift-cluster/src/main/thrift/cluster.thrift | 4 +-
.../src/main/thrift/confignode.thrift | 176 +-
thrift-datanode/pom.xml | 67 -
thrift-datanode/src/main/thrift/datanode.thrift | 92 -
thrift-influxdb/src/main/thrift/influxdb.thrift | 36 +-
thrift-sync/src/main/thrift/sync.thrift | 51 -
thrift-sync/src/main/thrift/transport.thrift | 90 +
thrift/src/main/thrift/common.thrift | 47 +
thrift/src/main/thrift/management.thrift | 77 +
thrift/src/main/thrift/mpp.thrift | 9 +-
thrift/src/main/thrift/rpc.thrift | 92 +-
tsfile/pom.xml | 22 +
.../org/apache/iotdb/tsfile/read/common/Path.java | 21 +
.../iotdb/tsfile/read/common/block/TsBlock.java | 96 +-
.../block/column/BinaryArrayColumnEncoder.java | 85 +
.../read/common/block/column/BinaryColumn.java | 21 +
.../common/block/column/BinaryColumnBuilder.java | 6 +
.../read/common/block/column/BooleanColumn.java | 21 +
.../common/block/column/BooleanColumnBuilder.java | 6 +
.../block/column/ByteArrayColumnEncoder.java | 68 +
.../tsfile/read/common/block/column/Column.java | 18 +
.../read/common/block/column/ColumnBuilder.java | 4 +
.../read/common/block/column/ColumnEncoder.java | 120 +
.../common/block/column/ColumnEncoderFactory.java | 42 +
.../read/common/block/column/ColumnEncoding.java | 64 +
.../read/common/block/column/DoubleColumn.java | 21 +
.../common/block/column/DoubleColumnBuilder.java | 6 +
.../read/common/block/column/FloatColumn.java | 21 +
.../common/block/column/FloatColumnBuilder.java | 6 +
.../block/column/Int32ArrayColumnEncoder.java | 87 +
.../block/column/Int64ArrayColumnEncoder.java | 87 +
.../tsfile/read/common/block/column/IntColumn.java | 21 +
.../read/common/block/column/IntColumnBuilder.java | 6 +
.../read/common/block/column/LongColumn.java | 21 +
.../common/block/column/LongColumnBuilder.java | 6 +
.../block/column/RunLengthEncodedColumn.java | 22 +
.../read/common/block/column/TimeColumn.java | 21 +
.../common/block/column/TimeColumnBuilder.java | 6 +
.../read/common/block/column/TsBlockSerde.java | 125 +
.../iotdb/tsfile/read/expression/IExpression.java | 3 +
.../read/expression/impl/BinaryExpression.java | 16 +
.../read/expression/impl/GlobalTimeExpression.java | 13 +
.../expression/impl/SingleSeriesExpression.java | 9 +
.../iotdb/tsfile/read/filter/basic/Filter.java | 8 +
.../org/apache/iotdb/tsfile/utils/BloomFilter.java | 7 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 39 +-
.../common/block/BinaryArrayColumnEncoderTest.java | 82 +
.../common/block/ByteArrayColumnEncoderTest.java | 78 +
.../tsfile/common/block/ColumnEncoderTest.java | 144 +
.../common/block/Int32ArrayColumnEncoderTest.java | 120 +
.../common/block/Int64ArrayColumnEncoderTest.java | 121 +
.../tsfile/common/block/TsBlockSerdeTest.java | 112 +
866 files changed, 56485 insertions(+), 21264 deletions(-)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/cli/TemporaryClient.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/DataNodeConfigurationDataSet.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/DataRegionInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/SchemaRegionInfo.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/CreateDataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/CreateRegionsPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/CreateSchemaPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/GetOrCreateDataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/crud/GetOrCreateSchemaPartitionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/DataPartitionPlan.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/SchemaPartitionPlan.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/cli/TemporaryClientDemo.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/physical/SerializeDeserializeUT.java
create mode 100644 docker/src/main/Dockerfile-single-influxdb
create mode 100644 example/rest-client-c-example/CMakeLists.txt
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSelectSchemaIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverCollectorIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncReceiverLoaderIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/IoTDBSyncSenderIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/SyncTestUtil.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/sync/TransportClientMock.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/cluster/DataNodeLocation.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/APHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/BKDRHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/DeviceGroupHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/JSHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/hash/SDBMHashExecutor.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DataNodeLocation.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/SeriesPartitionExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/APHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/BKDRHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/JSHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/executor/hash/SDBMHashExecutor.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/utils/StatusUtils.java
create mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/ConsensusGroupIdTest.java
delete mode 100644 server/src/assembly/resources/conf/iotdb-sync-client.properties
create mode 100644 server/src/assembly/resources/tools/rocksdb-transfer.bat
create mode 100644 server/src/assembly/resources/tools/rocksdb-transfer.sh
delete mode 100755 server/src/assembly/resources/tools/start-sync-client.bat
delete mode 100755 server/src/assembly/resources/tools/start-sync-client.sh
delete mode 100755 server/src/assembly/resources/tools/stop-sync-client.bat
delete mode 100755 server/src/assembly/resources/tools/stop-sync-client.sh
create mode 100644 server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionExceptionHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionRecoverManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionTaskComparator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/TsFileIdentifier.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/comparator/DefaultCompactionTaskComparatorImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/comparator/ICompactionTaskComparator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CrossCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/CrossCompactionSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerSeqCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerSequenceCompactionSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerUnseqCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/constant/InnerUnsequenceCompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/AbstractCrossSpaceCompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/AbstractCrossSpaceCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/CrossCompactionStrategy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/CrossSpaceCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/CrossSpaceCompactionTaskFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/ICrossSpaceSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionResource.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/manage/CrossSpaceCompactionResource.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/IMergePathSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/MergeFileStrategy.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/NaivePathSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/ReadPointPerformerSubTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/RewriteCrossSpaceCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/SubCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/AbstractInnerSpaceCompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/AbstractInnerSpaceCompactionTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/IInnerSeqSpaceSelector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/IInnerUnseqSpaceSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerCompactionStrategy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionTaskFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/sizetiered/SizeTieredCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/InnerSpaceCompactionUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/log/CompactionLogAnalyzer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/log/CompactionLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/log/TsFileIdentifier.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ICompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ICrossCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ISeqCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/IUnseqCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/ReadChunkCompactionPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/ReadPointCompactionPerformer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/AbstractCompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/CompactionExceptionHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/CompactionRecoverManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/ICompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/log/CompactionLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/utils/log/CompactionLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/SyncDeviceOwnerConflictException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/AcquireLockTimeoutException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/DifferentTemplateException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/DuplicatedTemplateException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/NoTemplateOnMNodeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/TemplateImcompatibeException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/TemplateIsInUseException.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/UndefinedTemplateException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/cache/MNodeNotCachedException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/cache/MNodeNotPinnedException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/RecordDuplicatedException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaFileNotExists.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SchemaPageOverflowException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SegmentNotFoundException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/schemafile/SegmentOverflowException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/DifferentTemplateException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/DuplicatedTemplateException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/NoTemplateOnMNodeException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/TemplateImcompatibeException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/TemplateIsInUseException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/metadata/template/UndefinedTemplateException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeDataLoadBearableException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeDataLoadException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeDataLoadUnbearableException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeServerException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/exception/sync/PipeSinkException.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/Executor/SchemaVisitor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/LocalConfigManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/LocalConfigNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/container/IMNodeContainer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/container/MNodeContainerMapImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/container/MNodeContainers.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/estimator/BasicMNodSizeEstimator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/estimator/IMNodeSizeEstimator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/iterator/IMNodeIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mnode/iterator/MNodeIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/CachedMTreeStore.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/IMTreeStore.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/MemMTreeStore.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/CachedMNodeContainer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/ICachedMNodeContainer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/MTreeFlushTaskManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/MTreeReleaseTaskManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/SegmentLock.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/CacheEntry.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/CacheManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/ICacheManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/LRUCacheManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/cache/PlainCacheManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/CachedMNodeSizeEstimator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/IMemManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/MemManagerHolder.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/MemManagerNodeEstimatedSizeBasedImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/MemManagerNodeNumBasedImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/ISchemaFile.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/ISchemaPage.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/ISegment.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/MockSchemaFile.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/RecordUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/SchemaFile.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/SchemaPage.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/schemafile/Segment.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/path/PathDeserializeUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/MemoryStatistics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaResourceManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/ISchemaRegion.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/CheckKeyResult.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaConstants.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaReadWriteHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaRegion.java
create 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/metadata/schemaregion/rocksdb/mnode/REntityMNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RInternalMNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNodeType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNodeValueType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMeasurementMNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RStorageGroupMNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/TsBlockSerde.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/DataRegion.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/GroupByTimeParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/filter/FilterDeserializeUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/header/ColumnHeader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/header/DatasetHeader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/header/HeaderConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/DeviceSchemaInfo.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/ConfigExecution.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/IConfigTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/SampleConfigTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/ConfigExecution.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/IConfigTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/SampleConfigTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/SetStorageGroupTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/process/TransformOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/DevicesSchemaScanOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaFetchOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaMergeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/SchemaScanOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/schema/TimeSeriesSchemaScanOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/source/DataSourceOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/source/ExchangeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/WriteFragmentParallelPlanner.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/ColumnHeader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/WritePlanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/DevicesSchemaScanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SchemaFetchNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SchemaMergeNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/SchemaScanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/TimeSeriesSchemaScanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/SchemaFetchStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/SetStorageGroupStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/ShowStorageGroupStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreatePipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/CreatePipeSinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropPipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropPipeSinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeServerOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeSinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeSinkTypeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StartPipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StartPipeServerOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StopPipeOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StopPipeServerOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreatePipePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreatePipeSinkPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropPipeSinkPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/OperatePipePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipeServerPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipeSinkPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ShowPipeSinkTypePlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/StartPipeServerPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/StopPipeServerPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/expression/ExpressionType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/executor/UDTFContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/EvaluationDAGBuilder.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/TsBlockInputDataSet.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/conf/SyncPathUtil.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/conf/SyncSenderConfig.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/conf/SyncSenderDescriptor.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/package-info.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/DeletionPipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/PipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/SchemaPipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/TsFilePipeData.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/BufferedPipeDataQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/PipeDataQueue.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/pipedata/queue/PipeDataQueueFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/ReceiverService.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerManagerMBean.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerThriftHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/collector/Collector.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/DeletionLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/FileLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/IFileLoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/ILoadLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/ILoader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/LoadLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/LoadType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/SchemaLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/TsFileLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/manager/PipeInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/manager/PipeMessage.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/manager/ReceiverManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/ISyncReceiverLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/ISyncReceiverLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recovery/ReceiverLog.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/recovery/ReceiverLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/transfer/SyncServiceImpl.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manage/ISyncFileManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manager/SchemaSyncManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/manager/TsFileSyncManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/IoTDBPipeSink.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/Pipe.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/PipeSink.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/TsFilePipe.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/ISyncSenderLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/ISyncSenderLogger.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLogAnalyzer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/SenderLogAnalyzer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/SenderLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/recovery/TsFilePipeLogger.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/service/SenderService.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/service/TransportHandler.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/ISyncClient.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/sender/transfer/SyncClient.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/client/ITransportClient.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/client/TransportClient.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/conf/TransportConfig.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/conf/TransportConstant.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServerManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServerManagerMBean.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServerThriftHandler.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServiceImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/IExpressionDeserializeUtil.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/StatusUtils.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/SyncUtils.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/CompactionUtilsTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/ReadPointCompactionPerformerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionUtilsAlignedTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionUtilsNoAlignedTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionUtilsOldTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/ReadChunkCompactionPerformerAlignedTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/ReadChunkCompactionPerformerNoAlignedTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/ReadChunkCompactionPerformerOldTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedCrossSpaceCompactionTask.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedCrossSpaceCompactionTaskFactory.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedInnerSpaceCompactionTask.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedInnerSpaceCompactionTaskFactory.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/disk/CachedMNodeContainerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/disk/MemManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeDiskModeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeFullMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeMemoryModeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeNonMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreePartialMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/RecordUtilTests.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/SchemaFileTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/SchemaPageTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/SegmentTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaDiskModeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaFullMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaMemoryModeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaNonMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/multimode/SchemaPartialMemoryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/MRocksDBBenchmark.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/MRocksDBUnitTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaReadWriteHandlerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RSchemaRegionAdvancedTest.java
create 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/metadata/schemaregion/rocksdb/RocksDBBenchmarkTask.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/RocksDBTestUtils.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/PathPatternTreeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/SchemaTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/PathPatternTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/SchemaTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/SchemaScanOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/schema/SchemaFetchOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceIdTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/FragmentInstanceSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/PlanNodeDeserializeHelper.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/metadata/read/ShowDevicesNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/AggregateNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/DeviceMergeNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/ExchangeNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FillNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/FilterNullNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/GroupByLevelNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/LimitNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/OffsetNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/SortNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/TimeJoinNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/sink/FragmentSinkNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesAggregateScanNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/SeriesScanNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertRowNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/write/InsertTabletNodeSerdeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/service/InternalServiceImplTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/pipedata/BufferedPipeDataQueueTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/pipedata/PipeDataTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/load/FileLoaderTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/manager/ReceiverManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLogAnalyzerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recover/SyncReceiverLoggerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/receiver/recovery/ReceiverLogAnalyzerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/manage/SyncFileManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLogAnalyzerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/recover/SyncSenderLoggerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/sync/sender/transfer/SyncClientTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/sync/transport/TransportServiceTest.java
delete mode 100644 thrift-datanode/pom.xml
delete mode 100644 thrift-datanode/src/main/thrift/datanode.thrift
delete mode 100755 thrift-sync/src/main/thrift/sync.thrift
create mode 100644 thrift-sync/src/main/thrift/transport.thrift
create mode 100644 thrift/src/main/thrift/common.thrift
create mode 100644 thrift/src/main/thrift/management.thrift
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryArrayColumnEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ByteArrayColumnEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnEncoderFactory.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnEncoding.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/Int32ArrayColumnEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/Int64ArrayColumnEncoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/TsBlockSerde.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/BinaryArrayColumnEncoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/ByteArrayColumnEncoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/ColumnEncoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/Int32ArrayColumnEncoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/Int64ArrayColumnEncoderTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/TsBlockSerdeTest.java