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/14 07:00:21 UTC
[iotdb] branch xingtanzjr/graph_visitor updated (f006e50abb -> 7b2650ccd3)
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch xingtanzjr/graph_visitor
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f006e50abb remove useless code
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 0e1825925d Merge branch 'master' into xingtanzjr/graph_visitor
add 7b2650ccd3 spotless
No new revisions were added by this update.
Summary of changes:
.github/workflows/influxdb-protocol.yml | 2 +-
.github/workflows/main-unix.yml | 3 +-
.github/workflows/main-win.yml | 3 +-
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 67 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 1 -
.../apache/iotdb/cluster/query/ClusterPlanner.java | 1 +
.../apache/iotdb/cluster/utils/StatusUtils.java | 6 +-
confignode/pom.xml | 5 -
.../resources/conf/iotdb-confignode.properties | 13 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 14 +
.../confignode/conf/ConfigNodeDescriptor.java | 4 +
.../consensus/response/DataPartitionDataSet.java | 22 +-
.../consensus/response/SchemaPartitionDataSet.java | 77 +-
.../response/StorageGroupSchemaDataSet.java | 12 +-
.../iotdb/confignode/manager/ConfigManager.java | 114 ++-
.../iotdb/confignode/manager/ConsensusManager.java | 36 +-
.../apache/iotdb/confignode/manager/Manager.java | 24 +-
.../iotdb/confignode/manager/PartitionManager.java | 130 ++--
.../iotdb/confignode/manager/RegionManager.java | 6 +-
.../confignode/partition/StorageGroupSchema.java | 9 +
.../persistence/PartitionInfoPersistence.java | 60 +-
.../persistence/RegionInfoPersistence.java | 29 +-
.../iotdb/confignode/physical/PhysicalPlan.java | 2 +-
.../physical/crud/CreateDataPartitionPlan.java | 5 +-
.../physical/crud/CreateRegionsPlan.java | 5 +-
.../physical/crud/CreateSchemaPartitionPlan.java | 70 +-
.../crud/GetOrCreateDataPartitionPlan.java | 6 +-
.../crud/GetOrCreateSchemaPartitionPlan.java | 86 ++-
.../confignode/service/executor/PlanExecutor.java | 4 +-
.../server/ConfigNodeRPCServerProcessor.java | 64 +-
.../confignode/consensus/RatisConsensusDemo.java | 10 +-
.../hash/DeviceGroupHashExecutorManualTest.java | 5 +-
.../physical/SerializeDeserializeUT.java | 45 +-
.../server/ConfigNodeRPCServerProcessorTest.java | 284 +++++---
.../iotdb/consensus/ratis/RequestMessage.java | 1 +
distribution/pom.xml | 6 +
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 396 +++++++---
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 493 ++++++++++---
example/rest-client-c-example/main.c | 14 +-
influxdb-protocol/pom.xml | 38 +-
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 6 +-
.../protocol/impl/IoTDBInfluxDBService.java | 12 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 42 +-
.../db/integration/IoTDBDeleteStorageGroupIT.java | 23 +
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 38 +
.../db/integration/IoTDBRecoverUnclosedIT.java | 17 +-
.../iotdb/db/integration/IoTDBSelectSchemaIT.java | 111 +++
.../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 ++
.../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 +-
.../iotdb/commons/cluster/DataNodeLocation.java | 6 +-
.../org/apache/iotdb/commons/cluster/Endpoint.java | 6 +-
.../iotdb/commons/concurrent/ThreadName.java | 6 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 15 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 5 +-
.../iotdb/commons/partition/DataPartition.java | 24 +-
.../iotdb/commons/partition/RegionReplicaSet.java | 41 +-
.../iotdb/commons/partition/SchemaPartition.java | 120 ++-
.../apache/iotdb/commons/service/ServiceType.java | 2 +
.../apache/iotdb/commons/utils/CommonUtils.java | 4 +-
.../apache/iotdb/commons}/utils/StatusUtils.java | 49 +-
pom.xml | 1 +
server/pom.xml | 5 +
.../resources/conf/iotdb-engine.properties | 47 +-
.../resources/conf/iotdb-sync-client.properties | 35 -
.../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 | 309 ++++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 163 +++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 83 ++-
.../consensus/statemachine/BaseStateMachine.java | 2 +
.../statemachine/DataRegionStateMachine.java | 37 +-
.../statemachine/SchemaRegionStateMachine.java | 17 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 16 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 62 +-
.../{task => }/CompactionExceptionHandler.java | 3 +-
.../compaction/CompactionMetricsManager.java | 12 +-
.../{task => }/CompactionRecoverManager.java | 9 +-
.../db/engine/compaction/CompactionScheduler.java | 165 +++--
.../engine/compaction/CompactionTaskManager.java | 5 +-
.../db/engine/compaction/CompactionUtils.java | 371 +++-------
.../DefaultCompactionTaskComparatorImpl.java} | 34 +-
.../comparator/ICompactionTaskComparator.java} | 23 +-
.../constant/CrossCompactionPerformer.java} | 27 +-
.../CrossCompactionSelector.java} | 45 +-
.../constant/InnerSeqCompactionPerformer.java} | 27 +-
.../constant/InnerSequenceCompactionSelector.java} | 41 +-
.../constant/InnerUnseqCompactionPerformer.java} | 27 +-
.../InnerUnsequenceCompactionSelector.java} | 43 +-
.../AbstractCrossSpaceCompactionSelector.java | 56 --
.../cross/AbstractCrossSpaceCompactionTask.java | 113 ---
.../compaction/cross/CrossCompactionStrategy.java | 79 --
.../compaction/cross/CrossSpaceCompactionTask.java | 290 ++++++++
.../ICrossSpaceSelector.java} | 19 +-
...va => RewriteCrossSpaceCompactionResource.java} | 8 +-
.../RewriteCrossSpaceCompactionSelector.java | 60 +-
.../selector/ICrossSpaceMergeFileSelector.java | 2 -
.../cross/rewrite/selector/NaivePathSelector.java | 55 --
.../selector/RewriteCompactionFileSelector.java | 12 +-
...ionTask.java => ReadPointPerformerSubTask.java} | 10 +-
.../task/RewriteCrossSpaceCompactionTask.java | 254 -------
.../AbstractInnerSpaceCompactionSelector.java | 59 --
.../inner/AbstractInnerSpaceCompactionTask.java | 160 ----
.../compaction/inner/IInnerSeqSpaceSelector.java} | 15 +-
.../IInnerUnseqSpaceSelector.java} | 15 +-
.../compaction/inner/InnerCompactionStrategy.java | 80 --
...tionTask.java => InnerSpaceCompactionTask.java} | 238 ++++--
.../sizetiered/SizeTieredCompactionSelector.java | 70 +-
.../inner/utils/InnerSpaceCompactionUtils.java | 302 --------
.../{utils => }/log/CompactionLogAnalyzer.java | 21 +-
.../{utils => }/log/CompactionLogger.java | 3 +-
.../compaction/{ => log}/TsFileIdentifier.java | 7 +-
.../compaction/performer/ICompactionPerformer.java | 49 ++
.../performer/ICrossCompactionPerformer.java} | 9 +-
.../performer/ISeqCompactionPerformer.java} | 9 +-
.../performer/IUnseqCompactionPerformer.java} | 9 +-
.../impl/ReadChunkCompactionPerformer.java | 166 +++++
.../impl/ReadPointCompactionPerformer.java} | 272 +++----
.../compaction/task/AbstractCompactionTask.java | 7 +-
.../compaction/task/CompactionRecoverTask.java | 6 +-
.../compaction/task/ICompactionSelector.java | 54 ++
.../iotdb/db/engine/modification/Deletion.java | 23 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 193 +++--
.../db/engine/storagegroup/TsFileManager.java | 38 +
.../db/engine/storagegroup/TsFileProcessor.java | 23 +
.../dataregion/StorageGroupManager.java | 10 +
.../metadata/DataTypeMismatchException.java | 6 +-
.../sync/PipeDataLoadBearableException.java} | 11 +-
.../sync/PipeDataLoadException.java} | 11 +-
.../sync/PipeDataLoadUnbearableException.java} | 11 +-
.../sync/PipeException.java} | 20 +-
.../sync/PipeServerException.java} | 21 +-
.../PipeSinkException.java} | 24 +-
.../iotdb/db/metadata/Executor/SchemaVisitor.java | 96 +++
...ocalConfigManager.java => LocalConfigNode.java} | 170 ++---
.../db/metadata/LocalSchemaPartitionTable.java | 4 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 28 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 50 +-
.../db/metadata/lastCache/LastCacheManager.java | 8 +-
.../iotdb/db/metadata/mtree/MTreeBelowSG.java | 1 +
.../traverser/collector/MeasurementCollector.java | 4 +
.../db/metadata/schemaregion/SchemaEngine.java | 27 +-
.../db/metadata/schemaregion/SchemaRegion.java | 70 +-
.../metadata/schemaregion/SchemaRegionUtils.java | 42 ++
.../schemaregion/rocksdb/RSchemaRegion.java | 49 +-
.../storagegroup/IStorageGroupSchemaManager.java | 8 +
.../storagegroup/StorageGroupSchemaManager.java | 28 +
.../iotdb/db/mpp/buffer/DataBlockManager.java | 7 +-
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 5 +
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 14 +-
.../org/apache/iotdb/db/mpp/common/QueryId.java | 8 +-
.../plan/node => common/header}/ColumnHeader.java | 23 +-
.../iotdb/db/mpp/common/header/DatasetHeader.java | 86 +++
.../apache/iotdb/db/mpp/execution/DataDriver.java | 3 +-
.../db/mpp/execution/FragmentInstanceManager.java | 4 +-
.../iotdb/db/mpp/execution/QueryExecution.java | 22 +-
.../db/mpp/execution/SchemaDriverContext.java | 8 +-
.../execution/{ => config}/ConfigExecution.java | 17 +-
.../db/mpp/execution/{ => config}/IConfigTask.java | 2 +-
.../execution/{ => config}/SampleConfigTask.java | 2 +-
.../mpp/execution/config/SetStorageGroupTask.java | 75 ++
.../scheduler/SimpleFragInstanceDispatcher.java | 4 +-
.../db/mpp/operator/process/TransformOperator.java | 118 +++
.../operator/schema/DevicesSchemaScanOperator.java | 97 +++
.../mpp/operator/schema/SchemaMergeOperator.java | 79 ++
.../db/mpp/operator/schema/SchemaScanOperator.java | 107 +++
.../schema/TimeSeriesSchemaScanOperator.java | 142 ++++
.../db/mpp/operator/source/SeriesScanOperator.java | 2 +-
.../db/mpp/operator/source/SeriesScanUtil.java | 16 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 14 +
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 43 +-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 7 +-
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 7 +-
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 7 +-
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 7 +-
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 14 +
.../db/mpp/sql/planner/DistributionPlanner.java | 144 +++-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 65 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 57 +-
.../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 42 ++
.../db/mpp/sql/planner/plan/FragmentInstance.java | 66 +-
.../db/mpp/sql/planner/plan/IOutputPlanNode.java | 2 +-
.../db/mpp/sql/planner/plan/PlanFragment.java | 10 +-
.../plan/SimpleFragmentParallelPlanner.java | 13 +-
.../planner/plan/WriteFragmentParallelPlanner.java | 70 ++
.../db/mpp/sql/planner/plan/node/PlanNode.java | 5 +-
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 15 +-
.../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 3 +
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 30 +
.../planner/plan/node/SimplePlanNodeRewriter.java | 4 +
.../WritePlanNode.java} | 16 +-
.../node/metedata/read/DevicesSchemaScanNode.java | 108 +++
.../read/SchemaMergeNode.java} | 43 +-
.../plan/node/metedata/read/SchemaScanNode.java | 119 +++
.../metedata/read/TimeSeriesSchemaScanNode.java | 145 ++++
.../node/metedata/write/AlterTimeSeriesNode.java | 37 +
.../write/CreateAlignedTimeSeriesNode.java | 13 +
.../node/metedata/write/CreateTimeSeriesNode.java | 127 +++-
.../planner/plan/node/process/AggregateNode.java | 8 +-
.../planner/plan/node/process/DeviceMergeNode.java | 2 +-
.../planner/plan/node/process/ExchangeNode.java | 1 +
.../sql/planner/plan/node/process/FillNode.java | 2 +-
.../sql/planner/plan/node/process/FilterNode.java | 2 +-
.../planner/plan/node/process/FilterNullNode.java | 2 +-
.../plan/node/process/GroupByLevelNode.java | 2 +-
.../sql/planner/plan/node/process/LimitNode.java | 2 +-
.../sql/planner/plan/node/process/OffsetNode.java | 2 +-
.../sql/planner/plan/node/process/SortNode.java | 2 +-
.../planner/plan/node/process/TimeJoinNode.java | 3 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 1 +
.../plan/node/source/SeriesAggregateScanNode.java | 19 +-
.../planner/plan/node/source/SeriesScanNode.java | 18 +-
.../sql/planner/plan/node/source/SourceNode.java | 4 +-
.../plan/node/write/InsertMultiTabletsNode.java | 14 +-
.../sql/planner/plan/node/write/InsertNode.java | 12 +-
.../sql/planner/plan/node/write/InsertRowNode.java | 3 +-
.../planner/plan/node/write/InsertRowsNode.java | 8 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 8 +-
.../planner/plan/node/write/InsertTabletNode.java | 5 +-
.../db/mpp/sql/rewriter/WildcardsRemover.java | 14 +-
.../db/mpp/sql/statement/StatementVisitor.java | 25 +-
.../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 | 5 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 1 +
.../sql/statement/crud/InsertRowsStatement.java | 8 +
.../db/mpp/sql/statement/crud/InsertStatement.java | 1 +
.../sql/statement/crud/InsertTabletStatement.java | 5 +-
.../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 +
...tatement.java => SetStorageGroupStatement.java} | 27 +-
.../statement/metadata/ShowDevicesStatement.java | 6 +
.../mpp/sql/statement/metadata/ShowStatement.java | 10 +
.../metadata/ShowTimeSeriesStatement.java | 6 +
.../db/protocol/influxdb/handler/QueryHandler.java | 6 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 26 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 193 ++++-
.../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 | 24 +-
.../db/qp/logical/sys/DropPipeSinkOperator.java | 23 +-
.../iotdb/db/qp/logical/sys/ShowPipeOperator.java | 27 +-
.../db/qp/logical/sys/ShowPipeServerOperator.java | 20 +-
.../db/qp/logical/sys/ShowPipeSinkOperator.java | 27 +-
.../qp/logical/sys/ShowPipeSinkTypeOperator.java | 20 +-
.../iotdb/db/qp/logical/sys/StartPipeOperator.java | 24 +-
.../db/qp/logical/sys/StartPipeServerOperator.java | 18 +-
.../iotdb/db/qp/logical/sys/StopPipeOperator.java | 24 +-
.../db/qp/logical/sys/StopPipeServerOperator.java | 18 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 10 +
.../qp/physical/crud/InsertMultiTabletsPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 37 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 15 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 2 +-
.../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 | 2 +-
.../iotdb/db/qp/physical/sys/DropPipeSinkPlan.java | 29 +-
.../iotdb/db/qp/physical/sys/OperatePipePlan.java | 29 +-
.../physical/sys/ShowPipePlan.java} | 15 +-
.../physical/sys/ShowPipeServerPlan.java} | 11 +-
.../physical/sys/ShowPipeSinkPlan.java} | 23 +-
.../physical/sys/ShowPipeSinkTypePlan.java} | 11 +-
.../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 | 190 ++++-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 15 +
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 3 +-
.../iotdb/db/query/expression/Expression.java | 12 +-
.../query/expression/binary/BinaryExpression.java | 14 +-
.../db/query/expression/unary/ConstantOperand.java | 8 +-
.../query/expression/unary/FunctionExpression.java | 26 +-
.../query/expression/unary/LogicNotExpression.java | 25 +-
.../query/expression/unary/NegationExpression.java | 19 +-
.../query/expression/unary/TimeSeriesOperand.java | 10 +-
.../db/query/udf/core/executor/UDTFContext.java | 60 ++
.../iotdb/db/query/udf/core/layer/DAGBuilder.java | 9 +-
.../{DAGBuilder.java => EvaluationDAGBuilder.java} | 66 +-
.../query/udf/core/layer/RawQueryInputLayer.java | 4 +
.../query/udf/core/layer/TsBlockInputDataSet.java | 64 ++
.../java/org/apache/iotdb/db/service/DataNode.java | 67 +-
.../iotdb/db/service/InternalServiceImpl.java | 32 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 11 +-
.../thrift/impl/DataNodeManagementServiceImpl.java | 108 ++-
.../service/thrift/impl/InfluxDBServiceImpl.java | 42 +-
.../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 +++++++++++
.../pipedata/queue/PipeDataQueue.java} | 24 +-
.../sync/pipedata/queue/PipeDataQueueFactory.java | 57 ++
.../iotdb/db/sync/receiver/ReceiverService.java | 278 +++++++
.../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 --
.../receiver/load/{LoadType.java => ILoader.java} | 12 +-
.../iotdb/db/sync/receiver/load/LoadLogger.java | 72 --
.../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 ++++++
.../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 +++
.../sender/pipe/PipeSink.java} | 41 +-
.../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 ---------------------
.../transport/client/ITransportClient.java} | 13 +-
.../db/sync/transport/client/TransportClient.java | 527 ++++++++++++++
.../conf/TransportConfig.java} | 26 +-
.../conf/TransportConstant.java} | 22 +-
.../server/TransportServerManager.java} | 80 +-
.../server/TransportServerManagerMBean.java} | 6 +-
.../server/TransportServerThriftHandler.java} | 30 +-
.../transport/server/TransportServiceImpl.java | 385 ++++++++++
.../org/apache/iotdb/db/utils/DataTypeUtils.java | 8 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 10 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 181 ++++-
.../org/apache/iotdb/db/utils/StatusUtils.java | 46 --
.../java/org/apache/iotdb/db/utils/SyncUtils.java | 109 ---
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 4 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 5 +-
.../compaction/CompactionTaskComparatorTest.java | 31 +-
.../compaction/CompactionTaskManagerTest.java | 101 ++-
....java => ReadPointCompactionPerformerTest.java} | 57 +-
.../db/engine/compaction/TsFileIdentifierUT.java | 3 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 23 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 52 +-
.../engine/compaction/cross/MergeUpgradeTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 58 +-
.../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 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 14 +-
...> ReadChunkCompactionPerformerAlignedTest.java} | 18 +-
...ReadChunkCompactionPerformerNoAlignedTest.java} | 22 +-
...va => ReadChunkCompactionPerformerOldTest.java} | 17 +-
.../SizeTieredCompactionRecoverTest.java | 77 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 2 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 20 +-
.../recover/SizeTieredCompactionRecoverTest.java | 49 +-
.../task/FakedCrossSpaceCompactionTask.java | 62 --
.../task/FakedInnerSpaceCompactionTask.java | 97 ---
.../task/FakedInnerSpaceCompactionTaskFactory.java | 50 --
.../compaction/utils/CompactionClearUtils.java | 2 +-
.../compaction/utils/CompactionConfigRestorer.java | 13 +-
.../storagegroup/StorageGroupProcessorTest.java | 12 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 2 +-
.../db/mpp/operator/SchemaScanOperatorTest.java | 242 ++++++
.../db/mpp/sql/plan/DistributionPlannerTest.java | 168 ++++-
.../db/mpp/sql/plan/FragmentInstanceSerdeTest.java | 32 +-
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 85 +++
.../db/mpp/sql/plan/QueryLogicalPlanUtil.java | 2 +-
.../sql/plan/node/PlanNodeDeserializeHelper.java | 3 +-
.../metadata/read/ShowDevicesNodeSerdeTest.java | 3 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 2 +-
.../sql/plan/node/process/LimitNodeSerdeTest.java | 2 +-
.../sql/plan/node/process/OffsetNodeSerdeTest.java | 8 +-
.../sql/plan/node/process/SortNodeSerdeTest.java | 2 +-
.../plan/node/process/TimeJoinNodeSerdeTest.java | 2 +-
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 3 +-
.../source/SeriesAggregateScanNodeSerdeTest.java | 2 +-
.../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 ++++++
server/src/test/resources/iotdb-engine.properties | 4 +-
server/src/test/resources/logback-test.xml | 2 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 15 +-
.../iotdb/rpc/StatementExecutionException.java | 4 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +-
.../src/main/thrift/confignode.thrift | 67 +-
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 | 43 +-
thrift/src/main/thrift/management.thrift | 14 -
.../iotdb/tsfile/read/common/block/TsBlock.java | 80 +-
.../read/common/block/column/BinaryColumn.java | 5 +
.../read/common/block/column/BooleanColumn.java | 5 +
.../tsfile/read/common/block/column/Column.java | 5 +
.../read/common/block/column/DoubleColumn.java | 5 +
.../read/common/block/column/FloatColumn.java | 5 +
.../tsfile/read/common/block/column/IntColumn.java | 5 +
.../read/common/block/column/LongColumn.java | 5 +
.../block/column/RunLengthEncodedColumn.java | 6 +
.../read/common/block/column/TimeColumn.java | 4 +
454 files changed, 17825 insertions(+), 9913 deletions(-)
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
copy {cluster/src/main/java/org/apache/iotdb/cluster => node-commons/src/main/java/org/apache/iotdb/commons}/utils/StatusUtils.java (90%)
delete mode 100644 server/src/assembly/resources/conf/iotdb-sync-client.properties
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
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{task => }/CompactionExceptionHandler.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{task => }/CompactionRecoverManager.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{CompactionTaskComparator.java => comparator/DefaultCompactionTaskComparatorImpl.java} (75%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/SchemaDriverContext.java => engine/compaction/comparator/ICompactionTaskComparator.java} (53%)
copy server/src/{test/java/org/apache/iotdb/db/mpp/sql/plan/node/PlanNodeDeserializeHelper.java => main/java/org/apache/iotdb/db/engine/compaction/constant/CrossCompactionPerformer.java} (53%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner/InnerSpaceCompactionTaskFactory.java => constant/CrossCompactionSelector.java} (50%)
copy server/src/{test/java/org/apache/iotdb/db/mpp/sql/plan/node/PlanNodeDeserializeHelper.java => main/java/org/apache/iotdb/db/engine/compaction/constant/InnerSeqCompactionPerformer.java} (53%)
rename server/src/{test/java/org/apache/iotdb/db/engine/compaction/task/FakedCrossSpaceCompactionTaskFactory.java => main/java/org/apache/iotdb/db/engine/compaction/constant/InnerSequenceCompactionSelector.java} (52%)
copy server/src/{test/java/org/apache/iotdb/db/mpp/sql/plan/node/PlanNodeDeserializeHelper.java => main/java/org/apache/iotdb/db/engine/compaction/constant/InnerUnseqCompactionPerformer.java} (52%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/CrossSpaceCompactionTaskFactory.java => constant/InnerUnsequenceCompactionSelector.java} (51%)
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
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{task/AbstractCompactionSelector.java => cross/ICrossSpaceSelector.java} (63%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/{manage/CrossSpaceCompactionResource.java => RewriteCrossSpaceCompactionResource.java} (97%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/NaivePathSelector.java
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/{SubCompactionTask.java => ReadPointPerformerSubTask.java} (91%)
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/inner/AbstractInnerSpaceCompactionSelector.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/AbstractInnerSpaceCompactionTask.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/common/GroupByTimeParameter.java => engine/compaction/inner/IInnerSeqSpaceSelector.java} (68%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/rewrite/selector/IMergePathSelector.java => inner/IInnerUnseqSpaceSelector.java} (70%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerCompactionStrategy.java
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/{sizetiered/SizeTieredCompactionTask.java => InnerSpaceCompactionTask.java} (59%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/InnerSpaceCompactionUtils.java
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{utils => }/log/CompactionLogAnalyzer.java (84%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{utils => }/log/CompactionLogger.java (96%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ => log}/TsFileIdentifier.java (98%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/ICompactionPerformer.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/IConfigTask.java => engine/compaction/performer/ICrossCompactionPerformer.java} (72%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/IConfigTask.java => engine/compaction/performer/ISeqCompactionPerformer.java} (75%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/IConfigTask.java => engine/compaction/performer/IUnseqCompactionPerformer.java} (74%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/performer/impl/ReadChunkCompactionPerformer.java
copy server/src/main/java/org/apache/iotdb/db/engine/compaction/{CompactionUtils.java => performer/impl/ReadPointCompactionPerformer.java} (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/task/ICompactionSelector.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/IConfigTask.java => exception/sync/PipeDataLoadBearableException.java} (80%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/IConfigTask.java => exception/sync/PipeDataLoadException.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/IConfigTask.java => exception/sync/PipeDataLoadUnbearableException.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/execution/SchemaDriverContext.java => exception/sync/PipeException.java} (64%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/recover/ISyncReceiverLogAnalyzer.java => exception/sync/PipeServerException.java} (66%)
rename server/src/main/java/org/apache/iotdb/db/exception/{SyncDeviceOwnerConflictException.java => sync/PipeSinkException.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/Executor/SchemaVisitor.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{LocalConfigManager.java => LocalConfigNode.java} (86%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql/planner/plan/node => common/header}/ColumnHeader.java (87%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/header/DatasetHeader.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ => config}/ConfigExecution.java (84%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/{ => config}/IConfigTask.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ => config}/SampleConfigTask.java (96%)
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/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/sql/planner/plan/WriteFragmentParallelPlanner.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/{IOutputPlanNode.java => node/WritePlanNode.java} (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/DevicesSchemaScanNode.java
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/{write/InsertMultiTabletNode.java => metedata/read/SchemaMergeNode.java} (54%)
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
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/{ShowStatement.java => SetStorageGroupStatement.java} (70%)
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
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropPipeOperator.java (63%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/DropPipeSinkOperator.java (62%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeOperator.java (61%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeServerOperator.java (69%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeSinkOperator.java (59%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/ShowPipeSinkTypeOperator.java (65%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StartPipeOperator.java (62%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StartPipeServerOperator.java (68%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StopPipeOperator.java (63%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/logical/sys/StopPipeServerOperator.java (68%)
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
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropPipeSinkPlan.java (62%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanner.java => server/src/main/java/org/apache/iotdb/db/qp/physical/sys/OperatePipePlan.java (64%)
rename server/src/main/java/org/apache/iotdb/db/{mpp/execution/IConfigTask.java => qp/physical/sys/ShowPipePlan.java} (74%)
copy server/src/main/java/org/apache/iotdb/db/{engine/compaction/cross/rewrite/selector/MergeFileStrategy.java => qp/physical/sys/ShowPipeServerPlan.java} (82%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/SyncServerManagerMBean.java => qp/physical/sys/ShowPipeSinkPlan.java} (71%)
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/load/LoadType.java => qp/physical/sys/ShowPipeSinkTypePlan.java} (81%)
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/udf/core/executor/UDTFContext.java
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/{DAGBuilder.java => EvaluationDAGBuilder.java} (59%)
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
rename server/src/main/java/org/apache/iotdb/db/{mpp/common/GroupByTimeParameter.java => sync/pipedata/queue/PipeDataQueue.java} (70%)
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
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
rename server/src/main/java/org/apache/iotdb/db/sync/receiver/load/{LoadType.java => ILoader.java} (77%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/sync/receiver/load/LoadLogger.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/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
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/metadata/ShowStatement.java => sync/sender/pipe/PipeSink.java} (55%)
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
rename server/src/main/java/org/apache/iotdb/db/{engine/compaction/cross/rewrite/selector/MergeFileStrategy.java => sync/transport/client/ITransportClient.java} (68%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/client/TransportClient.java
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver/recover/ISyncReceiverLogAnalyzer.java => transport/conf/TransportConfig.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/sync/{receiver/SyncServerManagerMBean.java => transport/conf/TransportConstant.java} (62%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver/SyncServerManager.java => transport/server/TransportServerManager.java} (58%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver/SyncServerManagerMBean.java => transport/server/TransportServerManagerMBean.java} (91%)
rename server/src/main/java/org/apache/iotdb/db/sync/{receiver/SyncServerThriftHandler.java => transport/server/TransportServerThriftHandler.java} (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/sync/transport/server/TransportServiceImpl.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
rename server/src/test/java/org/apache/iotdb/db/engine/compaction/{CompactionUtilsTest.java => ReadPointCompactionPerformerTest.java} (98%)
rename server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerSpaceCompactionUtilsAlignedTest.java => ReadChunkCompactionPerformerAlignedTest.java} (97%)
rename server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerSpaceCompactionUtilsNoAlignedTest.java => ReadChunkCompactionPerformerNoAlignedTest.java} (98%)
rename server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerSpaceCompactionUtilsOldTest.java => ReadChunkCompactionPerformerOldTest.java} (86%)
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/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/mpp/operator/SchemaScanOperatorTest.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 100755 thrift-sync/src/main/thrift/sync.thrift
create mode 100644 thrift-sync/src/main/thrift/transport.thrift