This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch optimize_records
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from cc0973d5efe fix bug
add a93cf09d1bd Enhance the exapmle of parameter dn_seed_config_node
(#11686)
add c450e768980 Enhance parameter dn_seed_config_node commets order
(#11687)
add 4922dad4d17 Add last time check for inner space compaction task
(#11553)
add 9af1e765c5d Cache the internal compaction estimation result if
compaction task is failed to run (#11586)
add acde4457a3d [IOTDB-6264] Load: Optimized Validation Messages with
'write_data' Permissions When Loading TsFiles Without schema Creation (#11684)
add 09b7e86fd63 add config for inner compaction selector (#11693)
add b1d3dc63c9e [IOTDB-6265] Construct SessionPool using empty nodeUrls
should throw exception
add 5caeeb3e3b7 Pipe: automatically start pipe upon creation & allow to
start RUNNING pipe & allow to stop STOPPED pipe (#11690)
add a061c0d4514 Pipe: Make error message reported by pipe parameter check
clearer (#11695)
add b57f320153b Make slimit and soffset available in align by device with
template
add 1dfdae910bf [IOTDB-6266] Add the ability to flush syncIndex and update
reader periodically for IoTConsensus (#11691)
add e75bc1c4675 Enable Jenkins Log when CI failed (#11700)
add f5a05fba466 Enable jenkins log when ci failed (#11701)
add bcc3b3dd4a1 Pipe schema: RPC request & response datastructures (#11680)
add 63475a16592 Pipe: Add pipeSinkHandshakeTimeout parameter to
distinguish it from pipeSinkTransferTimeout & Call handshake() method of
temporary connector's to validate createPipeStatement (#11655)
add baae7ce0332 Fix snapshot UT (#11697)
add 4e72d07de9b Featrue add insertRecords and insertTablets to the rest v2
service for data type verification (#11708)
add fb23bd43639 fix(cli): add jna for windows (#11707)
add f61f310c277 fix Precondition failure (#11710)
add f12b5eb5f51 add IT testing to rest service (#11437)
add 795d420db86 Pipe: rename iotdb-thrift-ssl-sink & allow not specifying
connector in kv attrs & support kv attrs that don't have sink. / processor. /
sink. prefixes (#11715)
add 3e4c6a4df91 Pipe Schema: Receiver Agent: Added pipe enriched planNode
to enable pipe request detection to configure "forwarding-pipe-request" (#11672)
add ac326a59e40 Improved stability of Ratis addMemberToGroup and
testThresholdSnapshot UT (#11717)
add 88549541f6b Add a param to switch whether to enable data separation or
not (#11692)
add 8c8c8d58523 [IOTDB-5706] Data inconsistency between IoT protocol
replications (#11727)
add 13c047fe7bc IT: enable REST service when needed to fix IT (#11726)
add 54a3733263f Take snapshot for mods using copy instead of hard link
(#11728)
add 1c886d255b6 change default config value of
inner_compaction_task_selection_mods_file_threshold (#11703)
add fd9cb6ed8b7 Implement Cluster ID (#11702)
add 301033fe015 Show devices with template (#11681)
add 40c32518da0 Pipe Schema: Receiver Agent: config plan node to statement
transformation logic (#11689)
add ef6dc0a8e14 Pipe: enhance the idempotence of start / stop pipe
(#11713)
add 720d4729bd1 SeriesScanUtil support predicate pushdown
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 440935489cc Pipe: Changed the property files' "extractor" and
"connector" related parameters to their "source" and "sink" counterparts
(#11751)
add cc4d0835e0f flink-sql-iotdb-connector: add property cdc.mode in cdc
connector (#11758)
add 1e7395ac524 Pipe: set pipe_sink_selector_number to
pipe_sink_core_client_number to improves the performance of concurrent file
transfers (#11760)
add acde4127cd3 merge master
No new revisions were added by this update.
Summary of changes:
Jenkinsfile | 4 +
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 6 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 26 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 11 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 5 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../it/cluster/IoTDBClusterRestartIT.java | 17 +-
.../confignode/it/cluster/IoTDBClusterStartIT.java | 93 +
.../apache/iotdb/db/it/GrafanaApiServiceIT.java | 451 +++++
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 2119 ++++++++++++++++++++
.../IoTDBAlignByDeviceWithTemplateIT.java | 82 +
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 5 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 4 +-
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 75 +-
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 57 +
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 44 +-
.../IoTDBGroupByNaturalMonthNsPrecisionIT.java | 12 +-
.../IoTDBGroupByNaturalMonthUsPrecisionIT.java | 12 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 7 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 4 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 85 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 108 +-
.../apache/iotdb/pipe/it/IoTDBPipeExtractorIT.java | 22 +-
.../apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java | 101 +
.../iotdb/pipe/it/IoTDBPipeSwitchStatusIT.java | 22 +-
.../apache/iotdb/pipe/it/IoTDBPipeSyntaxIT.java | 2 +-
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 10 +-
.../parameter/PipeParameterValidator.java | 6 +-
.../api/customizer/parameter/PipeParameters.java | 104 +-
iotdb-client/cli/pom.xml | 17 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 23 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 8 +-
.../java/org/apache/iotdb/session/SessionTest.java | 12 +
.../session/pool/SessionPoolExceptionTest.java | 12 +
.../org/apache/iotdb/flink/sql/common/Options.java | 7 +
.../sql/factory/IoTDBDynamicTableFactory.java | 1 +
.../flink/sql/function/IoTDBCDCSourceFunction.java | 47 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 13 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../heartbeat/DataNodeHeartbeatHandler.java | 2 +-
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
.../write/confignode/UpdateClusterIdPlan.java | 76 +
.../request/write/pipe/PipeEnrichedPlan.java | 79 +
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../iotdb/confignode/manager/ClusterManager.java | 67 +
.../iotdb/confignode/manager/ConfigManager.java | 23 +-
.../apache/iotdb/confignode/manager/IManager.java | 12 +-
.../iotdb/confignode/manager/ProcedureManager.java | 17 +-
.../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} | 17 +-
.../payload/request/PipeTransferConfigPlanReq.java | 78 +
.../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 | 12 +-
.../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 | 33 +-
.../pipe/task/PipeConfigNodeTaskBuilder.java} | 44 +-
.../manager/pipe/task/PipeConfigNodeTaskStage.java | 75 +
.../iotdb/confignode/persistence/ClusterInfo.java | 109 +
.../persistence/executor/ConfigPlanExecutor.java | 13 +
.../persistence/pipe/PipePluginInfo.java | 23 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 32 +-
.../persistence/schema/ConfigMTreeStore.java | 7 +
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 18 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 3 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 3 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 3 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 9 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 4 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 5 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 6 +-
.../confignode/service/ConfigNodeShutdownHook.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 45 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 12 +
.../response/pipe/PipePluginTableRespTest.java | 4 +-
.../connector/IoTDBConfigRegionConnectorTest.java} | 27 +-
.../PipeConfigNodeSubtaskExecutorTest.java} | 50 +-
.../extractor/IoTDBConfigRegionExtractorTest.java} | 13 +-
.../confignode/persistence/ClusterInfoTest.java | 67 +
.../apache/iotdb/consensus/iot/IoTConsensus.java | 31 +-
.../consensus/iot/IoTConsensusServerImpl.java | 14 +-
.../consensus/iot/client/DispatchLogHandler.java | 5 +-
.../iot/logdispatcher/IndexController.java | 3 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 14 +
.../consensus/iot/logdispatcher/SyncStatus.java | 4 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +
.../iot/logdispatcher/IndexControllerTest.java | 14 +-
.../iotdb/consensus/ratis/DiskGuardianTest.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 25 +-
.../iotdb/consensus/ratis/RecoverReadTest.java | 4 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 25 +-
.../resources/conf/iotdb-datanode.properties | 2 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 56 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 44 +-
.../dataregion/DataExecutionVisitor.java | 29 +-
.../dataregion/DataRegionStateMachine.java | 39 +-
.../schemaregion/SchemaExecutionVisitor.java | 14 +
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 20 +-
...uginAgent.java => PipePluginDataNodeAgent.java} | 118 +-
.../PipeDataRegionConnectorConstructor.java} | 77 +-
.../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 +
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 921 ---------
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 285 +++
.../builder/PipeTransferBatchReqBuilder.java | 17 +-
.../request/PipeTransferFilePieceReq.java | 4 +-
.../evolvable/request/PipeTransferFileSealReq.java | 4 +-
.../request/PipeTransferHandshakeReq.java | 4 +-
.../request/PipeTransferSchemaPlanReq.java | 105 +
.../request/PipeTransferTabletBatchReq.java | 4 +-
.../request/PipeTransferTabletBinaryReq.java | 4 +-
.../request/PipeTransferTabletInsertNodeReq.java | 4 +-
.../request/PipeTransferTabletRawReq.java | 4 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 16 +-
.../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 | 57 +-
.../protocol/websocket/WebSocketConnector.java | 2 +-
.../protocol/writeback/WriteBackConnector.java | 4 +-
.../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 +-
.../pipe/receiver/PipePlanToStatementVisitor.java | 186 ++
.../pipe/receiver/airgap/IoTDBAirGapReceiver.java | 2 +-
.../pipe/receiver/thrift/IoTDBThriftReceiver.java | 2 +-
.../receiver/thrift/IoTDBThriftReceiverAgent.java | 2 +-
.../receiver/thrift/IoTDBThriftReceiverV1.java | 46 +-
.../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/client/ConfigNodeClient.java | 37 +-
.../rest/v2/handler/RequestValidationHandler.java | 43 +
.../iotdb/db/protocol/session/SessionManager.java | 2 +-
.../common/header/ColumnHeaderConstant.java | 16 +-
.../common/header/DatasetHeaderFactory.java | 4 +
.../timerangeiterator/AggrWindowIterator.java | 39 +-
.../execution/executor/RegionWriteExecutor.java | 276 ++-
.../fragment/FragmentInstanceContext.java | 57 +
.../fragment/FragmentInstanceManager.java | 15 +-
.../execution/fragment/QueryContext.java | 14 +-
.../execution/fragment/QueryStatistics.java | 69 +
.../execution/load/LoadTsFileManager.java | 4 +-
.../queryengine/execution/load/TsFileSplitter.java | 2 +-
.../operator/schema/source/DeviceSchemaSource.java | 15 +
.../AbstractSeriesAggregationScanOperator.java | 33 +-
.../operator/source/AlignedSeriesScanUtil.java | 148 +-
.../operator/source}/FileLoaderUtils.java | 170 +-
.../execution/operator/source/SeriesScanUtil.java | 593 +++---
.../metric/QueryExecutionMetricSet.java | 24 +-
.../queryengine/metric/QueryPlanCostMetricSet.java | 10 +-
.../metric/QueryRelatedResourceMetricSet.java | 144 +-
.../metric/SeriesScanCostMetricSet.java | 825 +++++---
.../queryengine/plan/analyze/AnalyzeVisitor.java | 44 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 43 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 42 +-
.../queryengine/plan/execution/QueryExecution.java | 11 +-
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 109 +-
.../config/executor/IConfigTaskExecutor.java | 10 +
.../config/metadata/ShowClusterIdTask.java | 65 +
.../plan/optimization/ColumnInjectionPushDown.java | 119 ++
.../plan/optimization/LimitOffsetPushDown.java | 61 +-
.../plan/optimization/PlanNodePushDown.java | 76 -
.../db/queryengine/plan/parser/ASTVisitor.java | 20 +-
.../plan/planner/LogicalPlanBuilder.java | 11 +-
.../plan/planner/LogicalPlanVisitor.java | 63 +-
.../plan/planner/OperatorTreeGenerator.java | 1 -
.../planner/distribution/DistributionPlanner.java | 12 +-
.../plan/planner/plan/node/PlanNode.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 18 +-
.../plan/planner/plan/node/PlanVisitor.java | 37 +-
.../planner/plan/node/load/LoadTsFileNode.java | 7 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 2 +-
.../metedata/write/view/AlterLogicalViewNode.java | 43 +-
.../node/pipe/PipeEnrichedConfigSchemaNode.java | 161 ++
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 169 ++
.../{write => pipe}/PipeEnrichedInsertNode.java | 19 +-
.../node/pipe/PipeEnrichedWriteSchemaNode.java | 192 ++
.../planner/plan/node/process/AggregationNode.java | 4 +-
.../plan/node/process/ColumnInjectNode.java | 22 +
.../node/process/SlidingWindowAggregationNode.java | 5 +-
.../node/source/SeriesAggregationSourceNode.java | 11 +-
.../plan/planner/plan/node/write/InsertNode.java | 10 -
.../planner/plan/parameter/SeriesScanOptions.java | 3 -
.../queryengine/plan/statement/StatementType.java | 3 +-
.../plan/statement/StatementVisitor.java | 18 +-
.../crud/PipeEnrichedInsertBaseStatement.java | 220 --
.../crud/PipeEnrichedLoadTsFileStatement.java | 137 --
.../statement/metadata/ShowClusterIdStatement.java | 18 +-
.../metadata/view/CreateLogicalViewStatement.java | 10 +-
.../plan/statement/pipe/PipeEnrichedStatement.java | 72 +
.../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 | 23 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 9 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 335 ++--
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 75 +-
.../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 +-
.../read/resp/info/IDeviceSchemaInfo.java | 2 +
.../read/resp/info/impl/ShowDevicesResult.java | 11 +
.../schemaregion/utils/ResourceByPathUtils.java | 21 +-
.../utils/filter/DeviceFilterVisitor.java | 26 +
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 3 +-
.../db/service/metrics/CompactionMetrics.java | 2 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 215 +-
.../dataregion/HashLastFlushTimeMap.java | 115 +-
.../dataregion/IDataRegionForQuery.java | 5 +-
.../dataregion/ILastFlushTimeMap.java | 31 +-
.../dataregion/VirtualDataRegion.java | 5 +-
.../CompactionLastTimeCheckFailedException.java} | 18 +-
.../execute/task/AbstractCompactionTask.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 8 +-
.../fast/AlignedSeriesCompactionExecutor.java | 19 +-
.../fast/NonAlignedSeriesCompactionExecutor.java | 15 +-
.../executor/fast/SeriesCompactionExecutor.java | 46 +-
.../executor/fast/element/AlignedPageElement.java | 94 +
.../fast/element/NonAlignedPageElement.java | 74 +
.../utils/executor/fast/element/PageElement.java | 96 +-
.../utils/executor/fast/element/PointElement.java | 11 +-
.../fast/reader/CompactionAlignedChunkReader.java | 122 ++
.../fast/reader/CompactionChunkReader.java | 94 +
.../readchunk/AlignedSeriesCompactionExecutor.java | 12 +
.../readchunk/SingleSeriesCompactionExecutor.java | 15 +-
.../execute/utils/reader/PointPriorityReader.java | 2 +-
.../utils/writer/AbstractCompactionWriter.java | 11 +
.../writer/AbstractCrossCompactionWriter.java | 11 +-
.../writer/AbstractInnerCompactionWriter.java | 8 +-
.../utils/writer/FastInnerCompactionWriter.java | 12 +-
.../compaction/schedule/CompactionWorker.java | 9 +-
.../estimator/AbstractCompactionEstimator.java | 27 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +-
.../impl/SizeTieredCompactionSelector.java | 8 +-
.../dataregion/memtable/AbstractMemTable.java | 8 +-
.../memtable/AlignedReadOnlyMemChunk.java | 21 +-
.../dataregion/memtable/IMemTable.java | 6 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 11 +-
.../dataregion/memtable/TsFileProcessor.java | 4 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 24 +-
.../read/reader/chunk/DiskChunkLoader.java | 25 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 22 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 6 +-
.../read/reader/chunk/MemAlignedPageReader.java | 105 +-
.../read/reader/chunk/MemChunkLoader.java | 15 +-
.../read/reader/chunk/MemChunkReader.java | 13 +-
.../read/reader/chunk/MemPageReader.java | 267 +--
.../metadata/DiskAlignedChunkMetadataLoader.java | 57 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 50 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 40 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 33 +-
.../dataregion/snapshot/SnapshotTaker.java | 14 +-
.../dataregion/tsfile/TsFileResource.java | 8 +-
.../dataregion/utils/TsFileResourceUtils.java | 52 +-
.../dataregion/wal/buffer/AbstractWALBuffer.java | 14 +-
.../storageengine/dataregion/wal/node/WALNode.java | 2 +-
.../file/AbstractTsFileRecoverPerformer.java | 4 +-
.../dataregion/wal/utils/WALEntryHandler.java | 14 +-
.../dataregion/wal/utils/WALFileUtils.java | 8 +-
.../quotas/DataNodeThrottleQuotaManager.java | 2 +-
.../rescon/quotas/DefaultOperationQuota.java | 16 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 2 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 2 +-
.../db/tools/validate/TsFileValidationTool.java | 2 +-
.../db/trigger/executor/TriggerFireVisitor.java | 17 +-
.../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/SchemaRegionBasicTest.java | 42 +-
.../schemaRegion/SchemaStatisticsTest.java | 16 +-
...tTest.java => PipePluginDataNodeAgentTest.java} | 13 +-
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 2 +-
...est.java => PipeDataNodeThriftRequestTest.java} | 80 +-
.../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 +-
.../db/protocol/rest/IoTDBRestServiceTest.java | 15 +
.../aggregation/TimeRangeIteratorTest.java | 66 +-
.../schema/SchemaQueryScanOperatorTest.java | 6 +-
.../optimization/ColumnInjectionPushDownTest.java | 657 ++++++
.../plan/optimization/LimitOffsetPushDownTest.java | 35 +-
.../plan/optimization/OptimizationTestUtil.java | 75 +
.../plan/optimization/TestPlanBuilder.java | 149 +-
.../storageengine/dataregion/DataRegionTest.java | 53 +-
.../compaction/CompactionOverlapCheckTest.java | 269 +++
.../compaction/CompactionSchedulerTest.java | 3 +-
.../CompactionSchedulerWithFastPerformerTest.java | 24 +-
...InconsistentCompressionTypeAndEncodingTest.java | 4 +-
.../compaction/utils/CompactionCheckerUtils.java | 7 +-
.../utils/CompactionUpdateFileCountTest.java | 2 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 17 +-
.../reader/chunk/AlignedMemPageReaderTest.java | 250 +++
.../reader/chunk/MemAlignedChunkLoaderTest.java | 6 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 25 +-
.../read/reader/chunk/MemPageReaderTest.java | 134 ++
...est.java => AbstractAlignedSeriesScanTest.java} | 307 +--
.../read/reader/series/AbstractSeriesScanTest.java | 236 +++
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 404 +---
.../AlignedSeriesScanPredicatePushDownTest.java | 225 +++
...gleColumnSeriesScanLimitOffsetPushDownTest.java | 201 ++
.../series/SeriesScanLimitOffsetPushDownTest.java | 210 +-
.../series/SeriesScanPredicatePushDownTest.java | 318 +++
.../dataregion/snapshot/IoTDBSnapshotTest.java | 4 +
.../wal/recover/file/TsFilePlanRedoerTest.java | 25 +-
.../datanode/src/test/resources/logback-test.xml | 2 +
.../resources/conf/iotdb-common.properties | 29 +-
.../iotdb/commons/client/ClientPoolFactory.java | 2 +-
.../commons/concurrent/IoTDBThreadPoolFactory.java | 22 +
.../iotdb/commons/concurrent/ThreadName.java | 40 +-
.../threadpool/WrappedThreadPoolExecutor.java | 18 +
.../apache/iotdb/commons/conf/CommonConfig.java | 21 +-
.../iotdb/commons/conf/CommonDescriptor.java | 120 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../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 | 798 ++++++++
.../iotdb/commons/pipe/config/PipeConfig.java | 11 +-
.../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} | 9 +-
.../client}/IoTDBThriftSyncConnectorClient.java | 14 +-
.../request}/IoTDBConnectorRequestVersion.java | 2 +-
.../payload/request}/PipeRequestType.java | 8 +-
.../request/PipeTransferSnapshotPieceReq.java} | 78 +-
.../request/PipeTransferSnapshotSealReq.java} | 74 +-
.../payload/request/TransferConfigPlanReq.java} | 7 +-
.../response/PipeTransferSnapshotPieceResp.java | 81 +
.../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 | 38 +-
.../{ => 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} | 10 +-
.../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} | 12 +-
.../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 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 3 +
.../commons/schema/filter/SchemaFilterFactory.java | 5 +
.../commons/schema/filter/SchemaFilterType.java | 3 +
.../commons/schema/filter/SchemaFilterVisitor.java | 5 +
.../commons/schema/filter/impl/TemplateFilter.java | 73 +
.../apache/iotdb/commons/service/JMXService.java | 8 +-
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 7 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 3 +
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 10 +-
.../tsfile/file/metadata/AlignedChunkMetadata.java | 2 +
.../file/metadata/AlignedTimeSeriesMetadata.java | 2 +
.../iotdb/tsfile/file/metadata/IMetadata.java | 8 +
.../apache/iotdb/tsfile/read/TimeValuePair.java | 20 +
.../read/TsFileAlignedSeriesReaderIterator.java | 3 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 5 +-
.../tsfile/read/common/parser/PathVisitor.java | 10 +-
.../read/controller/CachedChunkLoaderImpl.java | 4 +-
.../iotdb/tsfile/read/controller/IChunkLoader.java | 3 +-
.../iotdb/tsfile/read/filter/basic/Filter.java | 9 +
.../iotdb/tsfile/read/filter/basic/TimeFilter.java | 10 +
.../tsfile/read/filter/basic/ValueFilter.java | 17 +
.../tsfile/read/filter/factory/FilterFactory.java | 21 +-
.../iotdb/tsfile/read/filter/operator/And.java | 11 +
.../read/filter/operator/GroupByMonthFilter.java | 11 +-
.../iotdb/tsfile/read/filter/operator/Not.java | 10 +
.../iotdb/tsfile/read/filter/operator/Or.java | 11 +
.../iotdb/tsfile/read/reader/IPageReader.java | 2 +-
.../read/reader/chunk/AbstractChunkReader.java | 83 +
.../read/reader/chunk/AlignedChunkReader.java | 470 ++---
.../tsfile/read/reader/chunk/ChunkReader.java | 235 +--
.../tsfile/read/reader/page/AlignedPageReader.java | 476 ++---
.../iotdb/tsfile/read/reader/page/PageReader.java | 390 ++--
.../read/reader/series/FileSeriesReader.java | 2 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 4 +-
.../read/reader/series/PaginationController.java | 1 -
.../apache/iotdb/tsfile/utils/TimeDuration.java | 93 +-
.../apache/iotdb/tsfile/read/common/PathTest.java | 32 +
.../read/reader/AlignedPageReaderPushDownTest.java | 322 +++
.../iotdb/tsfile/read/reader/ChunkReaderTest.java | 4 +-
.../tsfile/read/reader/PageReaderPushDownTest.java | 145 ++
.../iotdb/tsfile/read/reader/PageReaderTest.java | 6 +-
.../iotdb/tsfile/utils/TimeDurationTest.java | 40 +-
.../tsfile/write/TsFileIntegrityCheckingTool.java | 7 +-
.../src/main/thrift/confignode.thrift | 44 +-
pom.xml | 6 +
529 files changed, 20208 insertions(+), 9293 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterStartIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/GrafanaApiServiceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRestServiceIT.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/confignode/UpdateClusterIdPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/PipeEnrichedPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterManager.java
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/connector/protocol/IoTDBConnectorRequestVersion.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/IoTDBConfigRegionConnector.java}
(68%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/connector/payload/request/PipeTransferConfigPlanReq.java
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 (92%)
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
integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteDataNodeConfig.java
=>
iotdb-core/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
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/ClusterInfo.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%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterInfoTest.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/{PipePluginAgent.java
=> PipePluginDataNodeAgent.java} (66%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/{PipeConnectorConstructor.java
=> dataregion/PipeDataRegionConnectorConstructor.java} (62%)
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%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskDataNodeAgent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferSchemaPlanReq.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeProcessorSubtaskExecutor.java
=> dataregion/PipeDataRegionAssignerSubtaskExecutor.java} (75%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeProcessorSubtaskExecutor.java
=> dataregion/PipeDataRegionConnectorSubtaskExecutor.java} (74%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeProcessorSubtaskExecutor.java
=> dataregion/PipeDataRegionProcessorSubtaskExecutor.java} (74%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeAssignerSubtaskExecutor.java
=> schemaregion/PipeSchemaRegionAssignerSubtaskExecutor.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeAssignerSubtaskExecutor.java
=> schemaregion/PipeSchemaRegionConnectorSubtaskExecutor.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/execution/executor/{PipeAssignerSubtaskExecutor.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%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipePlanToStatementVisitor.java
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
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{utils =>
queryengine/execution/operator/source}/FileLoaderUtils.java (69%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterIdTask.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/queryengine/plan/planner/plan/node/pipe/PipeEnrichedConfigSchemaNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedDeleteDataNode.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/{write
=> pipe}/PipeEnrichedInsertNode.java (89%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedWriteSchemaNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedInsertBaseStatement.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedLoadTsFileStatement.java
copy
integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteDataNodeConfig.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/ShowClusterIdStatement.java
(59%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/pipe/PipeEnrichedStatement.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%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/execution/executor/PipeAssignerSubtaskExecutor.java
=>
storageengine/dataregion/compaction/execute/exception/CompactionLastTimeCheckFailedException.java}
(63%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/element/AlignedPageElement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/element/NonAlignedPageElement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/reader/CompactionAlignedChunkReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/reader/CompactionChunkReader.java
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%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/connector/{PipeThriftRequestTest.java
=> PipeDataNodeThriftRequestTest.java} (67%)
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/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionOverlapCheckTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/AlignedMemPageReaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/MemPageReaderTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/{AlignedSeriesScanLimitOffsetPushDownTest.java
=> AbstractAlignedSeriesScanTest.java} (60%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AbstractSeriesScanTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AlignedSeriesScanPredicatePushDownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AlignedSingleColumnSeriesScanLimitOffsetPushDownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/SeriesScanPredicatePushDownTest.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%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTaskAgent.java
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%)
copy 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/pipe/config/plugin/env/PipeTaskProcessorRuntimeEnvironment.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskTemporaryRuntimeEnvironment.java}
(73%)
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
(86%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request}/IoTDBConnectorRequestVersion.java
(94%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request}/PipeRequestType.java
(89%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferFilePieceReq.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request/PipeTransferSnapshotPieceReq.java}
(53%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/PipeTransferFileSealReq.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request/PipeTransferSnapshotSealReq.java}
(52%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/read/resp/info/IDeviceSchemaInfo.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/request/TransferConfigPlanReq.java}
(80%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/response/PipeTransferSnapshotPieceResp.java
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
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/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%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/{OpcUaConnector.java
=> iotdb/thrift/IoTDBThriftSslConnector.java} (78%)
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%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/read/resp/info/IDeviceSchemaInfo.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/PipeTask.java}
(84%)
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%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/TemplateFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/AbstractChunkReader.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/AlignedPageReaderPushDownTest.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/PageReaderPushDownTest.java
