This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/RefactorAnalyzer
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 81156b1aae fix IT fails
add 7da6d051e0 [IOTDB-4519] Fix existing measurement check during auto
creating schema (#7428)
add 38831292ed [IOTDB-4503] fix load error when autoregister is
false(#7426)
add 60a2621460 [IOTDB-4487] Remove enable_timed_close_tsfile in the time
partition doc (#7431)
add 2bc3954df3 fix some log and potential memory leak. (#7414)
add c66e890dca Make some comments and logs tidy in remove-nodes (#7435)
add 8ff428b0ae Add Error log for ConfigExecution (#7436)
add a29d38dacd change port to InternalPort for show cluster (#7440)
add b01996544a [IOTDB-4456][IOTDB-4459] Sync cluster framework in
ConfigNode and PipeSink operation (#7386)
add 31996b05ec Move all path related class to node-commons module (#7437)
add 85329a92a8 [IOTDB-4491] Achieve idempotence of Create Trigger On
DataNode (#7409)
add 9c9e2c9dc8 [IOTDB-4495] Fix NPE when enable_auto_create_schema is
false (#7429)
add 9030734573 [IOTDB-4511] Fix NPE while deleting timeseries with
template (#7445)
add 6430503900 [IOTDB-4338] Implementation of Drop Trigger on Data Node
(#7444)
add 09f3510ce8 [ISSUE-7430] Fix npe when dispatchRemote (#7439)
add 27cb018fb7 Merge remote-tracking branch 'origin/master' into
lmh/RefactorAnalyzer
No new revisions were added by this update.
Summary of changes:
.../consensus/request/ConfigPhysicalPlan.java | 12 +
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
.../request/read/GetNodePathsPartitionPlan.java | 2 +-
.../sync/CreatePipeSinkPlan.java} | 30 +--
.../DropPipeSinkPlan.java} | 29 ++-
.../GetPipeSinkPlan.java} | 30 ++-
.../{TemplateInfoResp.java => PipeSinkResp.java} | 15 +-
.../iotdb/confignode/manager/ConfigManager.java | 49 +++-
.../apache/iotdb/confignode/manager/IManager.java | 28 +++
.../iotdb/confignode/manager/SyncManager.java | 101 ++++++++
.../persistence/executor/ConfigPlanExecutor.java | 16 +-
.../persistence/sync/ClusterSyncInfo.java | 118 +++++++++
.../thrift/ConfigNodeRPCServiceProcessor.java | 21 ++
.../request/ConfigPhysicalPlanSerDeTest.java | 47 ++++
.../multileader/MultiLeaderServerImpl.java | 26 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 48 ++--
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 48 ++--
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 6 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 27 ---
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 3 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 56 +++++
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 18 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 2 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 2 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 2 +-
.../db/integration/sync/IoTDBSyncSenderIT.java | 2 +-
.../exception/sync/PipeDataLoadException.java | 2 +-
.../commons}/exception/sync/PipeException.java | 2 +-
.../exception/sync/PipeServerException.java | 2 +-
.../commons}/exception/sync/PipeSinkException.java | 2 +-
.../commons/executable/ExecutableManager.java | 142 ++++++++---
.../iotdb/commons/partition/DataPartition.java | 21 +-
.../apache/iotdb/commons}/path/AlignedPath.java | 4 +-
.../iotdb/commons}/path/MeasurementPath.java | 29 ++-
.../iotdb/commons}/path/PathDeserializeUtil.java | 3 +-
.../iotdb/commons}/path/PatternTreeMapFactory.java | 3 +-
.../apache/iotdb/commons/service/ServiceType.java | 3 -
.../iotdb/commons/sync/metadata/SyncMetadata.java | 212 +++++++++++++++++
.../apache/iotdb/commons/sync}/pipe/PipeInfo.java | 4 +-
.../iotdb/commons/sync}/pipe/PipeMessage.java | 2 +-
.../apache/iotdb/commons/sync/pipe/PipeStatus.java | 10 +-
.../pipe/SyncOperation.java} | 10 +-
.../iotdb/commons/sync}/pipe/TsFilePipeInfo.java | 4 +-
.../commons/sync/pipesink}/IoTDBPipeSink.java | 29 ++-
.../iotdb/commons/sync/pipesink}/PipeSink.java | 25 +-
.../commons/sync/{ => utils}/SyncConstant.java | 2 +-
.../commons/sync/{ => utils}/SyncPathUtil.java | 2 +-
.../iotdb/commons/trigger/TriggerInformation.java | 17 +-
.../apache/iotdb/commons/trigger/TriggerTable.java | 29 +--
.../trigger/service/TriggerExecutableManager.java | 34 +--
.../commons/udf/service/UDFExecutableManager.java | 6 +
.../udf/service/UDFRegistrationService.java | 6 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 19 ++
.../schemaregion/rocksdb/RSchemaRegion.java | 2 +-
.../rocksdb/mnode/RMeasurementMNode.java | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 52 ++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../impl/ReadPointCompactionPerformer.java | 4 +-
.../compaction/reader/SeriesDataBlockReader.java | 4 +-
.../memtable/AlignedWritableMemChunkGroup.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 6 +-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../engine/trigger/executor/TriggerExecutor.java | 2 +-
.../trigger/service/TriggerClassLoaderManager.java | 2 +-
.../service/TriggerRegistrationService.java | 2 +-
.../metadata/MeasurementAlreadyExistException.java | 2 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 18 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 2 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 2 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 4 +-
.../idtable/entry/InsertMeasurementMNode.java | 2 +-
.../db/metadata/lastCache/LastCacheManager.java | 2 +-
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 2 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 2 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 2 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 2 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 18 +-
.../db/metadata/mtree/traverser/Traverser.java | 4 +
.../traverser/collector/MeasurementCollector.java | 2 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 2 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 12 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 2 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 4 +-
.../db/metadata/utils/ResourceByPathUtils.java | 6 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 19 +-
.../iotdb/db/mpp/common/filter/FunctionFilter.java | 2 +-
.../iotdb/db/mpp/common/filter/QueryFilter.java | 2 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 2 +-
.../common/schematree/DeviceGroupSchemaTree.java | 2 +-
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 2 +-
.../db/mpp/common/schematree/ISchemaTree.java | 2 +-
.../visitor/SchemaTreeMeasurementVisitor.java | 2 +-
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../AlignedSeriesAggregationScanOperator.java | 2 +-
.../operator/source/AlignedSeriesScanOperator.java | 2 +-
.../operator/source/AlignedSeriesScanUtil.java | 2 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 4 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 8 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 2 +-
.../mpp/plan/analyze/GroupByLevelController.java | 2 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 18 +-
.../mpp/plan/execution/config/ConfigExecution.java | 9 +-
.../config/executor/ClusterConfigTaskExecutor.java | 176 +++++++++++---
.../executor/StandaloneConfigTaskExecutor.java | 16 +-
.../config/sys/sync/ShowPipeSinkTask.java | 27 ++-
.../memory/StatementMemorySourceVisitor.java | 2 +-
.../plan/expression/leaf/TimeSeriesOperand.java | 2 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 15 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 4 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 4 +-
.../db/mpp/plan/planner/SubPlanTypeExtractor.java | 2 +-
.../metedata/read/NodePathsSchemaScanNode.java | 2 +-
.../node/metedata/read/SchemaFetchScanNode.java | 2 +-
.../node/metedata/write/ActivateTemplateNode.java | 2 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 2 +-
.../write/InternalCreateTimeSeriesNode.java | 2 +-
.../metedata/write/InvalidateSchemaCacheNode.java | 2 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 4 +-
.../source/AlignedSeriesAggregationScanNode.java | 4 +-
.../plan/node/source/AlignedSeriesScanNode.java | 4 +-
.../plan/node/source/LastQueryScanNode.java | 4 +-
.../node/source/SeriesAggregationScanNode.java | 4 +-
.../planner/plan/node/source/SeriesScanNode.java | 4 +-
.../planner/plan/node/write/DeleteDataNode.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 3 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/statement/crud/LoadTsFileStatement.java | 7 +-
.../sys/sync/CreatePipeSinkStatement.java | 2 +-
.../statement/sys/sync/CreatePipeStatement.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 8 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 2 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 2 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/CreatePipePlan.java | 2 +-
.../db/qp/physical/sys/CreatePipeSinkPlan.java | 2 +-
.../qp/physical/sys/PreDeleteTimeSeriesPlan.java | 2 +-
.../sys/RollbackPreDeleteTimeSeriesPlan.java | 2 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 2 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 2 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 2 +-
.../iotdb/db/query/context/QueryContext.java | 2 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 2 +-
.../groupby/GroupByWithValueFilterDataSet.java | 4 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 4 +-
.../db/query/executor/AggregationExecutor.java | 4 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 2 +-
.../db/query/executor/RawDataQueryExecutor.java | 4 +-
.../iotdb/db/query/executor/UDFQueryExecutor.java | 2 +-
.../executor/fill/AlignedLastPointReader.java | 2 +-
.../groupby/impl/LocalAlignedGroupByExecutor.java | 2 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 2 +-
.../series/AlignedSeriesAggregateReader.java | 2 +-
.../query/reader/series/AlignedSeriesReader.java | 2 +-
.../query/timegenerator/ServerTimeGenerator.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 17 +-
.../db/service/DataNodeServerCommandLine.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 31 ++-
.../service/thrift/impl/DataNodeRegionManager.java | 2 +
.../db/service/thrift/impl/TSServiceImpl.java | 2 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 35 +--
.../iotdb/db/sync/common/ISyncInfoFetcher.java | 6 +-
.../apache/iotdb/db/sync/common/LocalSyncInfo.java | 164 +++++++++++++
.../iotdb/db/sync/common/LocalSyncInfoFetcher.java | 92 +++----
.../org/apache/iotdb/db/sync/common/SyncInfo.java | 264 ---------------------
.../db/sync/common/persistence/SyncLogReader.java | 8 +-
.../db/sync/common/persistence/SyncLogWriter.java | 11 +-
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 2 +-
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 2 +-
.../externalpipe/operation/InsertOperation.java | 2 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 2 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 4 +-
.../db/sync/receiver/load/DeletionLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/ILoader.java | 2 +-
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 2 +-
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 2 +-
.../db/sync/sender/pipe/ExternalPipeSink.java | 10 +-
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 14 +-
.../{PipeMessage.java => PipeSinkFactory.java} | 45 ++--
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 11 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 4 +-
.../db/sync/transport/client/IoTDBSyncClient.java | 4 +-
.../db/sync/transport/client/SenderManager.java | 8 +-
.../sync/transport/client/SyncClientFactory.java | 6 +-
.../db/sync/transport/server/ReceiverManager.java | 6 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 8 +
.../db}/trigger/service/TriggerClassLoader.java | 2 +-
.../trigger/service/TriggerClassLoaderManager.java | 55 ++---
.../trigger/service/TriggerManagementService.java | 195 ++++++++-------
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +-
.../iotdb/db/utils/IExpressionDeserializeUtil.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../apache/iotdb/db/utils/sync/SyncPipeUtil.java | 32 ++-
.../ReadPointCompactionPerformerTest.java | 4 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 2 +-
.../inner/InnerCompactionMoreDataTest.java | 2 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 2 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 2 +-
.../SizeTieredCompactionRecoverTest.java | 2 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 4 +-
.../db/engine/storagegroup/DataRegionTest.java | 2 +-
.../storagegroup/StorageGroupProcessorTest.java | 2 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 2 +-
.../engine/storagegroup/TsFileProcessorTest.java | 2 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 2 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 4 +-
.../iotdb/db/metadata/SchemaAdvancedTest.java | 2 +-
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 2 +-
.../org/apache/iotdb/db/metadata/TemplateTest.java | 2 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 2 +-
.../db/metadata/path/MeasurementPathTest.java | 46 ++++
.../iotdb/db/metadata/path/PatternTreeMapTest.java | 1 +
.../common/schematree/ClusterSchemaTreeTest.java | 2 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 2 +-
.../operator/AggregationOperatorTest.java | 2 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 2 +-
.../operator/AlignedSeriesScanOperatorTest.java | 4 +-
.../operator/DeviceMergeOperatorTest.java | 2 +-
.../execution/operator/DeviceViewOperatorTest.java | 2 +-
.../execution/operator/LastQueryOperatorTest.java | 2 +-
.../operator/LastQuerySortOperatorTest.java | 2 +-
.../mpp/execution/operator/LimitOperatorTest.java | 2 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 2 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 4 +-
.../operator/RawDataAggregationOperatorTest.java | 2 +-
.../SeriesAggregationScanOperatorTest.java | 2 +-
.../execution/operator/SeriesScanOperatorTest.java | 2 +-
.../SlidingWindowAggregationOperatorTest.java | 2 +-
.../execution/operator/TimeJoinOperatorTest.java | 2 +-
.../operator/UpdateLastCacheOperatorTest.java | 2 +-
.../schema/SchemaFetchScanOperatorTest.java | 2 +-
.../plan/analyze/AggregationDescriptorTest.java | 2 +-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 2 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 4 +-
.../distribution/AggregationDistributionTest.java | 4 +-
.../distribution/DistributionPlannerBasicTest.java | 4 +-
.../mpp/plan/plan/distribution/LastQueryTest.java | 4 +-
.../distribution/NoDataRegionPlanningTest.java | 2 +-
.../node/process/AggregationNodeSerdeTest.java | 2 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 2 +-
.../plan/plan/node/process/LimitNodeSerdeTest.java | 2 +-
.../plan/node/process/OffsetNodeSerdeTest.java | 2 +-
.../plan/plan/node/process/SortNodeSerdeTest.java | 2 +-
.../plan/node/process/TimeJoinNodeSerdeTest.java | 2 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 2 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 2 +-
.../reader/series/SeriesAggregateReaderTest.java | 2 +-
.../org/apache/iotdb/db/sync/SyncTestUtils.java | 8 +-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 4 +-
.../{SyncInfoTest.java => LocalSyncInfoTest.java} | 46 ++--
.../db/sync/receiver/recovery/SyncLogTest.java | 16 +-
.../iotdb/db/sync/transport/SyncTransportTest.java | 6 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 2 +-
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 4 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +
.../src/main/thrift/confignode.thrift | 38 ++-
thrift/src/main/thrift/datanode.thrift | 8 +-
.../iotdb/trigger/api/enums/FailureStrategy.java | 37 ++-
259 files changed, 2208 insertions(+), 1188 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/template/GetPathsSetTemplatePlan.java
=> write/sync/CreatePipeSinkPlan.java} (61%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DropFunctionPlan.java
=> sync/DropPipeSinkPlan.java} (66%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DropFunctionPlan.java
=> sync/GetPipeSinkPlan.java} (66%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{TemplateInfoResp.java
=> PipeSinkResp.java} (79%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/SyncManager.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/sync/ClusterSyncInfo.java
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeDataLoadException.java
(95%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeException.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeServerException.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/exception/sync/PipeSinkException.java
(96%)
rename {server/src/main/java/org/apache/iotdb/db/metadata =>
node-commons/src/main/java/org/apache/iotdb/commons}/path/AlignedPath.java (98%)
rename {server/src/main/java/org/apache/iotdb/db/metadata =>
node-commons/src/main/java/org/apache/iotdb/commons}/path/MeasurementPath.java
(88%)
rename {server/src/main/java/org/apache/iotdb/db/metadata =>
node-commons/src/main/java/org/apache/iotdb/commons}/path/PathDeserializeUtil.java
(93%)
rename {server/src/main/java/org/apache/iotdb/db/metadata =>
node-commons/src/main/java/org/apache/iotdb/commons}/path/PatternTreeMapFactory.java
(92%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/sync/metadata/SyncMetadata.java
rename {server/src/main/java/org/apache/iotdb/db/sync/sender =>
node-commons/src/main/java/org/apache/iotdb/commons/sync}/pipe/PipeInfo.java
(95%)
copy {server/src/main/java/org/apache/iotdb/db/sync/sender =>
node-commons/src/main/java/org/apache/iotdb/commons/sync}/pipe/PipeMessage.java
(97%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/RegionMaintainType.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipe/PipeStatus.java
(85%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/{schema/tree/ITreeNode.java
=> sync/pipe/SyncOperation.java} (87%)
rename {server/src/main/java/org/apache/iotdb/db/sync/sender =>
node-commons/src/main/java/org/apache/iotdb/commons/sync}/pipe/TsFilePipeInfo.java
(97%)
rename {server/src/main/java/org/apache/iotdb/db/sync/sender/pipe =>
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipesink}/IoTDBPipeSink.java
(78%)
rename {server/src/main/java/org/apache/iotdb/db/sync/sender/pipe =>
node-commons/src/main/java/org/apache/iotdb/commons/sync/pipesink}/PipeSink.java
(65%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{ =>
utils}/SyncConstant.java (98%)
rename node-commons/src/main/java/org/apache/iotdb/commons/sync/{ =>
utils}/SyncPathUtil.java (99%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/LocalSyncInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/sync/common/SyncInfo.java
rename
server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/{PipeMessage.java =>
PipeSinkFactory.java} (55%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
server/src/main/java/org/apache/iotdb/db}/trigger/service/TriggerClassLoader.java
(97%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
server/src/main/java/org/apache/iotdb/db}/trigger/service/TriggerClassLoaderManager.java
(63%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/path/MeasurementPathTest.java
rename
server/src/test/java/org/apache/iotdb/db/sync/receiver/manager/{SyncInfoTest.java
=> LocalSyncInfoTest.java} (62%)
