This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch 2G_metadata_read
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ddee7685ce7 Fix review
add 2da2255c75e Fix UT testLargeFileInLowerLevel of
CompactionSchedulerTestWithFastCompactionPerformer (#11735)
add 2c29fbc9f50 Pipe: validate the value of extractor.pattern (#11720)
add f98b3d218e0 Fix LIMIT/OFFSET push down in GROUP BY MONTH
add 14048939836 Fix some problems of FastCompactionPerformer (#11743)
add 82139d433eb Pipe: fix losing points when enable batch mode introduced
by progress commit framework refactor (#11722)
add 28833cbb360 Refactor query optimization rule: ColumnInjectionPushDown
(#11738)
add 7dea735db98 [IOTDB-6266] Add the ability to flush syncIndex and update
reader periodically for IoTConsensus (#11737)
add 81af7f4c7e7 Add more query metrics in the fragment instance level
(#11719)
add 64599d9db38 Pipe IT: Avoid infinite self-loop request forwarding in
IoTDBPipeLifeCycleIT.testDoubleLiving (#11746)
add fc5d228abb3 fix(session): remove ignored logs (#11749)
add 6351e765b40 PBTree Mode supports node-level read/write locking with
concurrent flush and querying (#11736)
add 50d01a78f56 Fix ColumnInjectionPushDown bug & add UTs
add a287355c46e [IOTDB-5706] Data inconsistency between IoT protocol
replications (#11748)
add a0ac60e0bf2 [IOTDB-6262] Pipe: fix NPE while deserializing WAL (caused
by non-atomic WAL rename operation during pipe read) (#11753)
add 349397f4553 Pipe Schema: execution framework for config regions and
schema regions (#11639)
add 13ea7e6bb61 Load: Fix InstanceAlreadyExistsException caused by
concurrent registration on JMXService (#11755)
add 06810e69568 [IOTDB-6272] Fix wrong RealNumber check for PartialPath
add 1b4665b7d68 Merge branch 'master' of github.com:apache/iotdb into
2G_metadata_read
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 57 ++
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 44 +-
.../IoTDBGroupByNaturalMonthNsPrecisionIT.java | 12 +-
.../IoTDBGroupByNaturalMonthUsPrecisionIT.java | 12 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 4 +-
.../apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java | 4 +
.../java/org/apache/iotdb/session/Session.java | 15 -
.../heartbeat/DataNodeHeartbeatHandler.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../apache/iotdb/confignode/manager/IManager.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../manager/pipe/agent/PipeConfigNodeAgent.java | 54 ++
.../PipeConfigRegionConnectorConstructor.java | 68 ++
.../PipeConfigRegionExtractorConstructor.java | 49 ++
.../PipeConfigRegionProcessorConstructor.java} | 34 +-
.../agent/plugin/PipePluginConfigNodeAgent.java} | 30 +-
.../pipe/agent/task/PipeTaskConfigNodeAgent.java | 84 ++
.../connector/IoTDBConfigRegionConnector.java} | 13 +-
.../pipe/{ => coordinator}/PipeManager.java | 8 +-
.../plugin/PipePluginCoordinator.java | 2 +-
.../runtime/PipeHeartbeatParser.java | 2 +-
.../runtime/PipeHeartbeatScheduler.java | 2 +-
.../runtime/PipeLeaderChangeHandler.java | 2 +-
.../{ => coordinator}/runtime/PipeMetaSyncer.java | 2 +-
.../runtime/PipeRuntimeCoordinator.java | 2 +-
.../task/PipeTaskCoordinator.java | 2 +-
.../task/PipeTaskCoordinatorLock.java | 2 +-
.../pipe/execution/PipeConfigNodeSubtask.java | 314 ++++++++
.../execution/PipeConfigNodeSubtaskExecutor.java | 50 ++
.../extractor/IoTDBConfigRegionExtractor.java} | 12 +-
.../manager/pipe/metric/PipeConfigNodeMetrics.java | 2 +-
.../manager/pipe/metric/PipeTaskInfoMetrics.java | 4 +-
.../manager/pipe/task/PipeConfigNodeTask.java} | 39 +-
.../pipe/task/PipeConfigNodeTaskBuilder.java} | 44 +-
.../manager/pipe/task/PipeConfigNodeTaskStage.java | 75 ++
.../persistence/pipe/PipePluginInfo.java | 10 +-
.../persistence/schema/ConfigMTreeStore.java | 7 +
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 3 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 1 -
.../response/pipe/PipePluginTableRespTest.java | 4 +-
.../connector/IoTDBConfigRegionConnectorTest.java} | 27 +-
.../PipeConfigNodeSubtaskExecutorTest.java} | 50 +-
.../extractor/IoTDBConfigRegionExtractorTest.java} | 13 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 15 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 15 +-
.../dataregion/DataRegionStateMachine.java | 39 +-
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 20 +-
...uginAgent.java => PipePluginDataNodeAgent.java} | 125 +--
.../PipeDataRegionConnectorConstructor.java} | 68 +-
.../PipeDataRegionExtractorConstructor.java} | 36 +-
.../dataregion/PipeDataRegionPluginAgent.java | 48 ++
.../PipeDataRegionProcessorConstructor.java} | 30 +-
.../PipeSchemaRegionConnectorConstructor.java | 68 ++
.../PipeSchemaRegionExtractorConstructor.java | 49 ++
.../schemaregion/PipeSchemaRegionPluginAgent.java} | 30 +-
.../PipeSchemaRegionProcessorConstructor.java} | 34 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 1 +
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 285 +++++++
.../builder/PipeTransferBatchReqBuilder.java | 17 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 14 +-
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 34 +-
.../connector/protocol/opcua/OpcUaConnector.java | 30 +-
.../protocol/opcua/OpcUaServerBuilder.java | 2 +-
.../thrift/async/IoTDBThriftAsyncConnector.java | 8 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 13 +-
.../protocol/websocket/WebSocketConnector.java | 2 +-
.../apache/iotdb/db/pipe/event/EnrichedEvent.java | 4 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 4 +-
.../executor/PipeAssignerSubtaskExecutor.java | 10 +-
.../executor/PipeConnectorSubtaskExecutor.java | 10 +-
.../executor/PipeProcessorSubtaskExecutor.java | 10 +-
.../executor/PipeSubtaskExecutorManager.java | 47 +-
.../PipeDataRegionAssignerSubtaskExecutor.java} | 9 +-
.../PipeDataRegionConnectorSubtaskExecutor.java} | 9 +-
.../PipeDataRegionProcessorSubtaskExecutor.java} | 9 +-
.../PipeSchemaRegionAssignerSubtaskExecutor.java} | 13 +-
.../PipeSchemaRegionConnectorSubtaskExecutor.java} | 13 +-
.../PipeSchemaRegionProcessorSubtaskExecutor.java} | 13 +-
.../pipe/extractor/IoTDBDataRegionExtractor.java | 77 +-
.../extractor/IoTDBSchemaRegionExtractor.java} | 12 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 26 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 13 +-
.../realtime/assigner/DisruptorQueue.java | 5 +-
...ounter.java => PipeDataRegionEventCounter.java} | 9 +-
.../db/pipe/metric/PipeEventCommitMetrics.java | 2 +-
.../downsampling/DownSamplingProcessor.java | 14 +-
.../SimpleConsensusProgressIndexAssigner.java | 2 +-
.../committer}/PipeEventCommitManager.java | 2 +-
.../committer}/PipeEventCommitter.java | 2 +-
.../task/{PipeTask.java => PipeDataNodeTask.java} | 23 +-
.../PipeDataNodeBuilder.java} | 45 +-
.../PipeDataNodeTaskBuilder.java} | 40 +-
.../PipeDataNodeTaskDataRegionBuilder.java} | 25 +-
.../PipeDataNodeTaskSchemaRegionBuilder.java} | 25 +-
.../db/pipe/task/connection/EnrichedDeque.java | 4 +-
.../pipe/task/connection/PipeEventCollector.java | 3 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 12 +-
.../db/pipe/task/stage/PipeTaskExtractorStage.java | 9 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 20 +-
.../{PipeSubtask.java => PipeDataNodeSubtask.java} | 134 +---
.../subtask/connector/PipeConnectorSubtask.java | 10 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 2 +-
.../connector/PipeConnectorSubtaskManager.java | 16 +-
.../subtask/processor/PipeProcessorSubtask.java | 8 +-
.../processor/PipeProcessorSubtaskWorker.java | 2 +-
.../iotdb/db/protocol/session/SessionManager.java | 2 +-
.../timerangeiterator/AggrWindowIterator.java | 39 +-
.../fragment/FragmentInstanceContext.java | 57 ++
.../fragment/FragmentInstanceManager.java | 15 +-
.../execution/fragment/QueryContext.java | 14 +-
.../execution/fragment/QueryStatistics.java | 69 ++
.../operator/source/AlignedSeriesScanUtil.java | 4 +-
.../execution/operator/source/FileLoaderUtils.java | 63 +-
.../execution/operator/source/SeriesScanUtil.java | 50 +-
.../metric/QueryExecutionMetricSet.java | 24 +-
.../queryengine/metric/QueryPlanCostMetricSet.java | 10 +-
.../metric/QueryRelatedResourceMetricSet.java | 144 +++-
.../metric/SeriesScanCostMetricSet.java | 825 +++++++++++++------
.../queryengine/plan/execution/QueryExecution.java | 1 +
.../config/executor/ClusterConfigTaskExecutor.java | 7 +-
.../plan/optimization/ColumnInjectionPushDown.java | 119 +++
.../plan/optimization/LimitOffsetPushDown.java | 61 +-
.../plan/optimization/PlanNodePushDown.java | 76 --
.../plan/planner/LogicalPlanBuilder.java | 11 +-
.../plan/planner/LogicalPlanVisitor.java | 3 +-
.../planner/distribution/DistributionPlanner.java | 12 +-
.../plan/planner/plan/node/PlanVisitor.java | 14 +-
.../planner/plan/node/process/AggregationNode.java | 4 +-
.../plan/node/process/ColumnInjectNode.java | 22 +
.../node/process/SlidingWindowAggregationNode.java | 5 +-
.../node/source/SeriesAggregationSourceNode.java | 11 +-
.../metric/SchemaEngineCachedMetric.java | 65 +-
.../schemaengine/metric/SchemaMetricManager.java | 4 +-
.../rescon/CachedSchemaRegionStatistics.java | 12 +-
.../schemaengine/rescon/SchemaResourceManager.java | 6 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 10 +-
.../schemaregion/mtree/IMTreeStore.java | 3 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 20 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 9 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 335 ++++----
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 72 +-
.../mtree/impl/pbtree/PBTreeFactory.java | 104 +++
.../pbtree/ReentrantReadOnlyCachedMTreeStore.java | 10 +-
.../mtree/impl/pbtree/cache/CacheManager.java | 741 -----------------
.../impl/pbtree/cache/CacheMemoryManager.java | 363 ---------
.../impl/pbtree/flush/PBTreeFlushExecutor.java | 122 ++-
.../mtree/impl/pbtree/flush/Scheduler.java | 232 ++++++
.../{cache/CacheEntry.java => lock/LockEntry.java} | 29 +-
.../mtree/impl/pbtree/lock/LockManager.java | 147 ++++
.../{ => lock}/StampedWriterPreferredLock.java | 28 +-
.../pbtree/memcontrol/IReleaseFlushStrategy.java | 3 -
.../{MemManager.java => MemoryStatistics.java} | 4 +-
.../ReleaseFlushStrategyNumBasedImpl.java | 5 -
.../ReleaseFlushStrategySizeBasedImpl.java | 11 +-
.../IMemoryManager.java} | 35 +-
.../mtree/impl/pbtree/memory/MemoryManager.java | 596 ++++++++++++++
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 376 +++++++++
.../buffer/INodeBuffer.java} | 48 +-
.../impl/pbtree/memory/buffer/NodeBuffer.java | 188 +++++
.../impl/pbtree/{ => memory}/cache/CacheEntry.java | 24 +-
.../cache/INodeCache.java} | 36 +-
.../cache/LRUNodeCache.java} | 58 +-
.../cache/PlainNodeCache.java} | 36 +-
.../mtree/impl/pbtree/mnode/ICachedMNode.java | 7 +-
.../impl/pbtree/mnode/basic/CachedBasicMNode.java | 13 +-
.../mnode/container/CachedMNodeContainer.java | 8 +-
.../mnode/impl/CachedAboveDatabaseMNode.java | 13 +-
.../pbtree/mnode/impl/CachedDatabaseMNode.java | 13 +-
.../pbtree/mnode/impl/CachedMeasurementMNode.java | 13 +-
.../impl/pbtree/mnode/info/CacheMNodeInfo.java | 15 +-
.../mtree/impl/pbtree/schemafile/ISchemaPage.java | 35 +-
.../impl/pbtree/schemafile/ISegmentedPage.java | 2 +-
.../mtree/impl/pbtree/schemafile/InternalPage.java | 9 +
.../impl/pbtree/schemafile/MockSchemaFile.java | 20 +-
.../mtree/impl/pbtree/schemafile/SchemaFile.java | 9 +-
.../mtree/impl/pbtree/schemafile/SchemaPage.java | 47 +-
.../impl/pbtree/schemafile/SegmentedPage.java | 16 +-
.../schemafile/pagemgr/BTreePageManager.java | 379 +++++----
.../pbtree/schemafile/pagemgr/IPageManager.java | 9 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 834 +++++++++++++-------
.../schemaregion/mtree/traverser/Traverser.java | 9 +-
.../schemaregion/utils/ResourceByPathUtils.java | 21 +-
.../db/service/metrics/CompactionMetrics.java | 2 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 2 +-
.../writer/AbstractInnerCompactionWriter.java | 6 +-
.../utils/writer/FastInnerCompactionWriter.java | 8 -
.../dataregion/memtable/AbstractMemTable.java | 8 +-
.../memtable/AlignedReadOnlyMemChunk.java | 11 +-
.../dataregion/memtable/IMemTable.java | 6 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 11 +-
.../dataregion/memtable/TsFileProcessor.java | 4 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 13 +-
.../read/reader/chunk/DiskChunkLoader.java | 21 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 11 +-
.../read/reader/chunk/MemChunkLoader.java | 11 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 2 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 2 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 2 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 2 +-
.../dataregion/wal/buffer/AbstractWALBuffer.java | 14 +-
.../storageengine/dataregion/wal/node/WALNode.java | 2 +-
.../dataregion/wal/utils/WALEntryHandler.java | 14 +-
.../dataregion/wal/utils/WALFileUtils.java | 8 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 12 +-
.../mtree/lock/StampedWriterPreferredLockTest.java | 16 +-
.../db/metadata/mtree/schemafile/MonitorTest.java | 85 ++
.../mtree/schemafile/SchemaFileLogTest.java | 4 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 1 -
.../schemaRegion/SchemaStatisticsTest.java | 16 +-
...tTest.java => PipePluginDataNodeAgentTest.java} | 13 +-
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 2 +-
.../PipeConnectorSubtaskExecutorTest.java | 6 +-
.../PipeProcessorSubtaskExecutorTest.java | 6 +-
.../db/pipe/execution/PipeSubtaskExecutorTest.java | 4 +-
.../extractor/CachedSchemaPatternMatcherTest.java | 6 +-
.../extractor/IoTDBDataRegionExtractorTest.java | 50 +-
.../db/pipe/extractor/PipeRealtimeExtractTest.java | 6 +-
.../aggregation/TimeRangeIteratorTest.java | 66 +-
.../optimization/ColumnInjectionPushDownTest.java | 657 ++++++++++++++++
.../plan/optimization/LimitOffsetPushDownTest.java | 35 +-
.../plan/optimization/OptimizationTestUtil.java | 75 ++
.../plan/optimization/TestPlanBuilder.java | 149 +++-
.../storageengine/dataregion/DataRegionTest.java | 5 +-
.../compaction/CompactionSchedulerTest.java | 3 +-
.../CompactionSchedulerWithFastPerformerTest.java | 24 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 17 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 4 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 13 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 25 +-
.../datanode/src/test/resources/logback-test.xml | 1 +
.../commons/concurrent/IoTDBThreadPoolFactory.java | 22 +
.../iotdb/commons/concurrent/ThreadName.java | 36 +-
.../threadpool/WrappedThreadPoolExecutor.java | 18 +
.../iotdb/commons/conf/CommonDescriptor.java | 13 +
.../agent/plugin/PipeConnectorConstructor.java | 53 ++
.../agent/plugin/PipeExtractorConstructor.java | 21 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 113 +++
.../pipe/agent/plugin/PipePluginConstructor.java | 36 +-
.../agent/plugin/PipeProcessorConstructor.java | 23 +-
.../commons}/pipe/agent/task/PipeTaskAgent.java | 875 +++++++++------------
.../config/constant/PipeConnectorConstant.java | 8 +-
.../config/constant/PipeExtractorConstant.java | 13 +-
.../config/constant/PipeProcessorConstant.java | 2 +-
.../configuraion/PipeTaskRuntimeConfiguration.java | 2 +-
.../env/PipeTaskConnectorRuntimeEnvironment.java | 2 +-
.../env/PipeTaskExtractorRuntimeEnvironment.java | 2 +-
.../env/PipeTaskProcessorRuntimeEnvironment.java | 2 +-
.../plugin/env/PipeTaskRuntimeEnvironment.java | 4 +-
.../env/PipeTaskTemporaryRuntimeEnvironment.java | 8 +-
.../client}/IoTDBThriftSyncConnectorClient.java | 2 +-
.../execution/executor/PipeSubtaskExecutor.java | 6 +-
.../execution/scheduler/PipeSubtaskScheduler.java | 4 +-
.../commons/pipe/metric/PipeEventCounter.java} | 24 +-
.../commons/pipe/metric/PipeFakeEventCounter.java} | 16 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 32 +-
.../{ => donothing}/DoNothingConnector.java | 2 +-
.../builtin/connector/iotdb}/IoTDBConnector.java | 26 +-
.../{ => iotdb/airgap}/IoTDBAirGapConnector.java | 4 +-
.../thrift}/IoTDBLegacyPipeConnector.java | 4 +-
.../connector/iotdb/thrift/IoTDBMetaConnector.java | 257 ++++++
.../iotdb/thrift/IoTDBSchemaRegionConnector.java} | 6 +-
.../thrift}/IoTDBThriftAsyncConnector.java | 2 +-
.../{ => iotdb/thrift}/IoTDBThriftConnector.java | 4 +-
.../thrift}/IoTDBThriftSslConnector.java | 4 +-
.../thrift}/IoTDBThriftSyncConnector.java | 2 +-
.../connector/{ => opcua}/OpcUaConnector.java | 4 +-
.../{ => websocket}/WebSocketConnector.java | 4 +-
.../{ => writeback}/WriteBackConnector.java | 4 +-
.../donothing/DoNothingExtractor.java} | 33 +-
.../extractor/{ => iotdb}/IoTDBExtractor.java | 3 +-
.../extractor/iotdb/IoTDBMetaExtractor.java | 150 ++++
.../{ => donothing}/DoNothingProcessor.java | 2 +-
.../{ => downsampling}/DownSamplingProcessor.java | 4 +-
.../meta/ConfigNodePipePluginMetaKeeper.java | 2 +-
.../plugin/meta/DataNodePipePluginMetaKeeper.java | 45 +-
.../pipe/plugin/meta/PipePluginMetaKeeper.java | 28 +
.../iotdb/commons/pipe/task}/DecoratingLock.java | 2 +-
.../iotdb/commons/pipe/task}/EventSupplier.java | 2 +-
.../apache/iotdb/commons/pipe/task/PipeTask.java} | 15 +-
.../iotdb/commons}/pipe/task/PipeTaskManager.java | 33 +-
.../pipe/task/connection/BlockingPendingQueue.java | 9 +-
.../connection/BoundedBlockingPendingQueue.java | 7 +-
.../connection/UnboundedBlockingPendingQueue.java | 7 +-
.../commons}/pipe/task/stage/PipeTaskStage.java | 2 +-
.../commons}/pipe/task/subtask/PipeSubtask.java | 108 +--
.../apache/iotdb/commons/service/JMXService.java | 8 +-
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 7 +-
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 10 +-
.../tsfile/read/common/parser/PathVisitor.java | 10 +-
.../read/filter/operator/GroupByMonthFilter.java | 11 +-
.../apache/iotdb/tsfile/utils/TimeDuration.java | 93 +--
.../apache/iotdb/tsfile/read/common/PathTest.java | 32 +
.../iotdb/tsfile/utils/TimeDurationTest.java | 40 +-
296 files changed, 9040 insertions(+), 4459 deletions(-)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/PipeConfigNodeAgent.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/PipeConfigRegionConnectorConstructor.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/PipeConfigRegionExtractorConstructor.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskRuntimeEnvironment.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/PipeConfigRegionProcessorConstructor.java}
(50%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskRuntimeEnvironment.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/PipePluginConfigNodeAgent.java}
(56%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/task/PipeTaskConfigNodeAgent.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/BoundedBlockingPendingQueue.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/IoTDBConfigRegionConnector.java}
(68%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> coordinator}/PipeManager.java (84%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> coordinator}/plugin/PipePluginCoordinator.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> coordinator}/runtime/PipeHeartbeatParser.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> coordinator}/runtime/PipeHeartbeatScheduler.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> coordinator}/runtime/PipeLeaderChangeHandler.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> coordinator}/runtime/PipeMetaSyncer.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> coordinator}/runtime/PipeRuntimeCoordinator.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> coordinator}/task/PipeTaskCoordinator.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> coordinator}/task/PipeTaskCoordinatorLock.java (98%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/execution/PipeConfigNodeSubtask.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/execution/PipeConfigNodeSubtaskExecutor.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/base/ColumnInjectionPushDown.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/IoTDBConfigRegionExtractor.java}
(68%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/DecoratingLock.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeConfigNodeTask.java}
(60%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/task/PipeBuilder.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeConfigNodeTaskBuilder.java}
(58%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/task/PipeConfigNodeTaskStage.java
copy
iotdb-core/{datanode/src/test/java/org/apache/iotdb/db/pipe/extractor/IoTDBDataRegionExtractorTest.java
=>
confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/connector/IoTDBConfigRegionConnectorTest.java}
(62%)
copy
iotdb-core/{datanode/src/test/java/org/apache/iotdb/db/pipe/execution/PipeSubtaskExecutorTest.java
=>
confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/execution/PipeConfigNodeSubtaskExecutorTest.java}
(77%)
copy
iotdb-core/{datanode/src/test/java/org/apache/iotdb/db/pipe/extractor/IoTDBDataRegionExtractorTest.java
=>
confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/extractor/IoTDBConfigRegionExtractorTest.java}
(79%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/{PipePluginAgent.java
=> PipePluginDataNodeAgent.java} (64%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/{PipeConnectorConstructor.java
=> dataregion/PipeDataRegionConnectorConstructor.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/{PipeExtractorConstructor.java
=> dataregion/PipeDataRegionExtractorConstructor.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/dataregion/PipeDataRegionPluginAgent.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/{PipeProcessorConstructor.java
=> dataregion/PipeDataRegionProcessorConstructor.java} (56%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/PipeSchemaRegionConnectorConstructor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/PipeSchemaRegionExtractorConstructor.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{config/plugin/env/PipeTaskRuntimeEnvironment.java
=> agent/plugin/schemaregion/PipeSchemaRegionPluginAgent.java} (56%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{config/plugin/env/PipeTaskRuntimeEnvironment.java
=> agent/plugin/schemaregion/PipeSchemaRegionProcessorConstructor.java} (50%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskDataNodeAgent.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeAssignerSubtaskExecutor.java
=> dataregion/PipeDataRegionAssignerSubtaskExecutor.java} (75%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeAssignerSubtaskExecutor.java
=> dataregion/PipeDataRegionConnectorSubtaskExecutor.java} (74%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeAssignerSubtaskExecutor.java
=> dataregion/PipeDataRegionProcessorSubtaskExecutor.java} (74%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeProcessorSubtaskExecutor.java
=> schemaregion/PipeSchemaRegionAssignerSubtaskExecutor.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeProcessorSubtaskExecutor.java
=> schemaregion/PipeSchemaRegionConnectorSubtaskExecutor.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeProcessorSubtaskExecutor.java
=> schemaregion/PipeSchemaRegionProcessorSubtaskExecutor.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/optimization/base/ColumnInjectionPushDown.java
=> pipe/extractor/IoTDBSchemaRegionExtractor.java} (69%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/{PipeEventCounter.java
=> PipeDataRegionEventCounter.java} (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{agent/runtime =>
progress/assigner}/SimpleConsensusProgressIndexAssigner.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{commit =>
progress/committer}/PipeEventCommitManager.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{commit =>
progress/committer}/PipeEventCommitter.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/{PipeTask.java
=> PipeDataNodeTask.java} (80%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/{PipeBuilder.java
=> builder/PipeDataNodeBuilder.java} (61%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/{PipeTaskBuilder.java
=> builder/PipeDataNodeTaskBuilder.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{config/plugin/env/PipeTaskExtractorRuntimeEnvironment.java
=> task/builder/PipeDataNodeTaskDataRegionBuilder.java} (55%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{config/plugin/env/PipeTaskExtractorRuntimeEnvironment.java
=> task/builder/PipeDataNodeTaskSchemaRegionBuilder.java} (55%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/{PipeSubtask.java
=> PipeDataNodeSubtask.java} (53%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryStatistics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/ColumnInjectionPushDown.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/PlanNodePushDown.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/PBTreeFactory.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/cache/CacheManager.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/cache/CacheMemoryManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/flush/Scheduler.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/{cache/CacheEntry.java
=> lock/LockEntry.java} (71%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/lock/LockManager.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/{
=> lock}/StampedWriterPreferredLock.java (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memcontrol/{MemManager.java
=> MemoryStatistics.java} (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/{cache/ICacheManager.java
=> memory/IMemoryManager.java} (62%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/MemoryManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/ReleaseFlushMonitor.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/{mnode/impl/CachedAboveDatabaseMNode.java
=> memory/buffer/INodeBuffer.java} (54%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/memory/buffer/NodeBuffer.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/{
=> memory}/cache/CacheEntry.java (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/{mnode/info/CacheMNodeInfo.java
=> memory/cache/INodeCache.java} (61%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/{cache/LRUCacheManager.java
=> memory/cache/LRUNodeCache.java} (79%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/{cache/PlainCacheManager.java
=> memory/cache/PlainNodeCache.java} (65%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/mtree/schemafile/MonitorTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/agent/plugin/{PipePluginAgentTest.java
=> PipePluginDataNodeAgentTest.java} (90%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/optimization/ColumnInjectionPushDownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/optimization/OptimizationTestUtil.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipeConnectorConstructor.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/agent/plugin/PipeExtractorConstructor.java
(67%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/PipePluginAgent.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/agent/plugin/PipePluginConstructor.java
(66%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/agent/plugin/PipeProcessorConstructor.java
(62%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/agent/task/PipeTaskAgent.java
(50%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/config/constant/PipeConnectorConstant.java
(95%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/config/constant/PipeExtractorConstant.java
(80%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/config/constant/PipeProcessorConstant.java
(96%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/config/plugin/configuraion/PipeTaskRuntimeConfiguration.java
(96%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/config/plugin/env/PipeTaskConnectorRuntimeEnvironment.java
(94%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/config/plugin/env/PipeTaskExtractorRuntimeEnvironment.java
(95%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/config/plugin/env/PipeTaskProcessorRuntimeEnvironment.java
(94%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/config/plugin/env/PipeTaskRuntimeEnvironment.java
(90%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/config/plugin/env/PipeTaskTemporaryRuntimeEnvironment.java
(75%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/sync
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/client}/IoTDBThriftSyncConnectorClient.java
(97%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/execution/executor/PipeSubtaskExecutor.java
(96%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/execution/scheduler/PipeSubtaskScheduler.java
(95%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection/BoundedBlockingPendingQueue.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/metric/PipeEventCounter.java}
(62%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/base/ColumnInjectionPushDown.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/metric/PipeFakeEventCounter.java}
(72%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> donothing}/DoNothingConnector.java (96%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb}/IoTDBConnector.java
(78%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> iotdb/airgap}/IoTDBAirGapConnector.java (88%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> iotdb/thrift}/IoTDBLegacyPipeConnector.java (88%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBMetaConnector.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/base/ColumnInjectionPushDown.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/thrift/IoTDBSchemaRegionConnector.java}
(83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> iotdb/thrift}/IoTDBThriftAsyncConnector.java (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> iotdb/thrift}/IoTDBThriftConnector.java (88%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> iotdb/thrift}/IoTDBThriftSslConnector.java (88%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> iotdb/thrift}/IoTDBThriftSyncConnector.java (94%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> opcua}/OpcUaConnector.java (88%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> websocket}/WebSocketConnector.java (88%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{
=> writeback}/WriteBackConnector.java (88%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/{connector/DoNothingConnector.java
=> extractor/donothing/DoNothingExtractor.java} (60%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/extractor/{
=> iotdb}/IoTDBExtractor.java (97%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/extractor/iotdb/IoTDBMetaExtractor.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/{
=> donothing}/DoNothingProcessor.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/{
=> downsampling}/DownSamplingProcessor.java (88%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask =>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/task}/DecoratingLock.java
(96%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/task/connection =>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/task}/EventSupplier.java
(96%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/base/ColumnInjectionPushDown.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/PipeTask.java}
(78%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/task/PipeTaskManager.java
(77%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/task/connection/BlockingPendingQueue.java
(92%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/task/connection/BoundedBlockingPendingQueue.java
(78%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/task/connection/UnboundedBlockingPendingQueue.java
(83%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/task/stage/PipeTaskStage.java
(98%)
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db =>
node-commons/src/main/java/org/apache/iotdb/commons}/pipe/task/subtask/PipeSubtask.java
(53%)
