This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch deletion_expr
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 29df1c43c07 spotless
add fdd7e8b08bf Fix print a log every time startup and error exception
handling (#13545) (#13546)
add 3a5304a78da Load: New SQL grammer -> LOAD <filePath> with ('k'='v',
...) (#13553)
add d4dcbc958ab [To rc/1.3.3] Modify regionMigrateService's ThreadPool to
IoTThreadPoolFactory.cachedThreadPool (#13551)
add a77a625a12f Fix AINode status error after ConfigNode Leader restarts
#13547 (#13556)
add df68b2a3710 [to rc/1.3.3] Fix fill aligned chunk metadata by schema
list (#13558)
add b1baff6ad99 Pipe: eliminate progress index for raw tablet event to
avoid endless rebind (#13567)
add 39dffe26b34 Pipe: Fixed the bug that the relative path in
OPCUAConnector security dir is not formulated (#13555) (#13564)
add 1c94d98c196 Pipe: optimize the 'Create Pipe' SQL statement to allow
omitting 'With Sink' when no Source or Processor attributes are defined.
(#13534) (#13563)
add cb795f4e928 Pipe / Subscription : Fixed the bug that
TsFileInsertionScanDataContainer may use wrong isMultiPage flag for aligned
chunk when value chunk is not continuous (#13554) (#13566)
add f09c99d101e [To rc/1.3.3] Don't print warn log for sort tmp file delete
add 0561c0d3fb3 [IOTDB-6351] Don't retry if operation has already succeed
even if the DN is not running status
add 7f11cb4b338 Pipe: make progress index immutable (#13571)
add 11c3d34d1f5 Subscription IT: explicitly declare `setUp` method for
test class to avoid `UNKNOWN-IT` test class name (#13576)
add 58d6645865a Pipe: Refactor pipe related packages (#13578) (#13584)
add f86bdcd07f7 [To rc/1.3.3] Refactor: Removed the useless Ser/de logic
in configNode read plans (#13586)
add a2d389e62af fix bug (#13589)
add 3537a30590f Make log dispatcher stop in parallel #13588 (#13595)
add 8ca5cf6a2e8 [to rc/1.3.3] Skip the file timestamp check of tsfiles
generated by repair task (#13582)
add 92426ad16e9 Update tsfile verison to 1.1.0-240924-SNAPSHOT (#13598)
add 0a37cd2cb40 [to rc/1.3.3] Fix flush chunk check in read chunk
compaction (#13539)
add 53e1a95fe5e Pipe: Added count-point-processor to black list (#13606)
add 253c41c5a0a Pipe: Fix relative path in SSLConnector trustStorePath is
not formulated & Fix inclusion option 'delete' fails to parse (#13580) (#13616)
add bdad615356f [To rc/1.3.3] Fix the issue that some ut can not stop
(#13615)
add 8e77c20a655 Subscription: register metrics to count the number of pipe
events in sink queue and prefetching queue in subscription task (#13618)
add b9f17a251b4 Load: Fix the source parameter of the load tsfile script
cannot specify a file (#13619)
add b45cc70fb02 [region migration] Catch Ratis Read InterruptedException
#13612 (#13625)
add 18d5c11c42e [To rc/1.3.3] Cherry pick 9903702
add 3c02466ff39 Pipe: Fixed the bug that alter source will not alter the
reference count of ConfigRegionListeningQueue (#13626)(#13632)
add cf1e89000fb Pipe: Fixed the bug that different types in schema
snapshot transfer may cause transfer failure (#13627) (#13631)
add 33bf372bf05 [To rc/1.3.3] [RatisConsensus] Bump ratis version to 3.1.1
#13630
add 4cc794cd2af [To rc/1.3.3] Tolerate ser/de call for
configPhysicalReadPlan #13628
add 5b273642620 [To rc/1.3.3]Change the error infomation when insert a
timestamp over Long.MaxValue && Fix potential NPE when write FileTimeIndexCache
(#13633)
add a8e29ad62c1 AINode: Correcting the Omissions and Redundancies (#13636)
add 7b36d8f6322 Use CountDownLatch to replace Semaphore in IoTConsensus
log dispatcher closing #13517 (#13638)
add f27a2495872 Fix NodeInfo processLoadSnapshot method (avoid
compatibility issues caused by ainode serialization) (#13622) (#13637)
add 866eab02b8e PipePlugin: Add pipe consensus related plugins to
blackList (#13642) (#13644)
add 7c59ea1e837 Pipe: Fix the problem of missing precision when converting
String type to Int32 and int64 types (#13643) (#13645)
add 547f3eba6bc [To rc/1.3.3] Make each execution acquire a schema read
lock only once
add a3c462846c7 [to rc/1.3.3] Enhance repair compaction & exception handle
with full disks (#13613)
add 675e93ee6e5 Adjust procedure's default clean interval #13648 (#13655)
add 12fb3c5d8ef [to rc/1.3.3] Invalidate schema cache when data region
leader change (#13585) (#13659)
add 90fa3e95e91 Fix print error log when dir is not exist (#13591) (#13658)
add c3167435d52 [Config-properties] Change
iot_consensus_throttle_threshold_in_byte = wal_throttle_threshold_in_byte for
compatibility (#13652) (#13657)
add 8b85bc7411b Merge branch 'rc/1.3.3' into deletion_expr
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/it/IoTDBDatetimeFormatIT.java | 9 +
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 8 +-
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 20 +-
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 2 +-
.../pipe/it/autocreate/IoTDBPipeSyntaxIT.java | 11 +
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 7 +
.../it/dual/IoTDBSubscriptionTopicIT.java | 7 +
.../it/local/IoTDBSubscriptionBasicIT.java | 7 +
.../it/local/IoTDBSubscriptionDataTypeIT.java | 7 +
.../it/local/IoTDBSubscriptionIdempotentIT.java | 7 +
.../it/local/IoTDBSubscriptionTopicIT.java | 17 +-
.../param/IoTDBTestParamSubscriptionSessionIT.java | 7 +
.../iotdb/tool/tsfile/ImportTsFileScanTool.java | 4 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 22 +-
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 14 +-
.../consensus/request/ConfigPhysicalPlan.java | 198 +++------
.../request/ConfigPhysicalPlanVisitor.java | 2 +-
...nTablePlan.java => ConfigPhysicalReadPlan.java} | 18 +-
.../read/ainode/GetAINodeConfigurationPlan.java | 12 +-
.../request/read/auth/AuthorReadPlan.java | 143 ++++++
.../consensus/request/read/cq/ShowCQPlan.java} | 13 +-
.../request/read/database/CountDatabasePlan.java | 51 +--
.../request/read/database/GetDatabasePlan.java | 6 +-
.../datanode/GetDataNodeConfigurationPlan.java | 30 +-
.../read/function/GetFunctionTablePlan.java | 18 +-
.../request/read/function/GetUDFJarPlan.java | 42 +-
.../request/read/model/GetModelInfoPlan.java | 10 +-
.../request/read/model/ShowModelPlan.java | 10 +-
.../read/partition/CountTimeSlotListPlan.java | 49 +--
.../read/partition/GetDataPartitionPlan.java | 66 +--
.../read/partition/GetNodePathsPartitionPlan.java | 33 +-
.../partition/GetOrCreateDataPartitionPlan.java | 10 +-
.../partition/GetOrCreateSchemaPartitionPlan.java | 3 +-
.../read/partition/GetSchemaPartitionPlan.java | 58 +--
.../read/partition/GetSeriesSlotListPlan.java | 36 +-
.../read/partition/GetTimeSlotListPlan.java | 49 +--
.../read/pipe/plugin/GetPipePluginJarPlan.java | 35 +-
.../read/pipe/plugin/GetPipePluginTablePlan.java | 18 +-
.../request/read/pipe/task/ShowPipePlanV2.java | 18 +-
.../request/read/region/GetRegionIdPlan.java | 49 +--
.../request/read/region/GetRegionInfoListPlan.java | 47 +-
.../read/subscription/ShowSubscriptionPlan.java | 18 +-
.../request/read/subscription/ShowTopicPlan.java | 18 +-
.../read/template/CheckTemplateSettablePlan.java | 33 +-
.../read/template/GetAllSchemaTemplatePlan.java | 16 +-
.../read/template/GetAllTemplateSetInfoPlan.java | 16 +-
.../read/template/GetPathsSetTemplatePlan.java | 33 +-
.../read/template/GetSchemaTemplatePlan.java | 32 +-
.../read/template/GetTemplateSetInfoPlan.java | 37 +-
.../read/trigger/GetTransferringTriggersPlan.java | 18 +-
.../request/read/trigger/GetTriggerJarPlan.java | 42 +-
.../read/trigger/GetTriggerLocationPlan.java | 38 +-
.../request/read/trigger/GetTriggerTablePlan.java | 38 +-
.../consensus/request/read/ttl/ShowTTLPlan.java | 19 +-
.../request/{ => write}/auth/AuthorPlan.java | 99 +----
.../consensus/request/write/cq/ShowCQPlan.java | 45 --
.../write/partition/RemoveRegionLocationPlan.java | 5 -
.../write/pipe/plugin/CreatePipePluginPlan.java | 2 +-
.../pipe/runtime/PipeHandleMetaChangePlan.java | 2 +-
.../request/write/pipe/task/AlterPipePlanV2.java | 4 +-
.../request/write/pipe/task/CreatePipePlanV2.java | 4 +-
.../write/pipe/task/SetPipeStatusPlanV2.java | 2 +-
.../request/write/sync/ShowPipePlanV1.java | 59 ---
.../response/pipe/plugin/PipePluginTableResp.java | 2 +-
.../response/pipe/task/PipeTableResp.java | 10 +-
.../statemachine/ConfigRegionStateMachine.java | 22 +-
.../iotdb/confignode/manager/ConfigManager.java | 13 +-
.../apache/iotdb/confignode/manager/IManager.java | 7 +-
.../iotdb/confignode/manager/ModelManager.java | 10 +-
.../confignode/manager/PermissionManager.java | 9 +-
.../iotdb/confignode/manager/ProcedureManager.java | 4 +-
.../manager/consensus/ConsensusManager.java | 3 +-
.../iotdb/confignode/manager/cq/CQManager.java | 2 +-
.../manager/load/balancer/RouteBalancer.java | 35 ++
.../confignode/manager/load/cache/LoadCache.java | 14 +-
.../manager/partition/PartitionManager.java | 16 +-
.../agent/plugin/PipeConfigNodePluginAgent.java | 8 +-
.../PipeConfigRegionConnectorConstructor.java | 6 +-
.../PipeConfigRegionExtractorConstructor.java | 6 +-
.../PipeConfigRegionProcessorConstructor.java | 6 +-
.../agent/runtime/PipeConfigNodeRuntimeAgent.java | 15 +-
.../agent/runtime/PipeConfigRegionListener.java | 7 +-
.../task}/PipeConfigNodeSubtask.java | 10 +-
.../task}/PipeConfigNodeSubtaskExecutor.java | 4 +-
.../pipe/{ => agent}/task/PipeConfigNodeTask.java | 4 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 11 +-
.../task/PipeConfigNodeTaskBuilder.java | 12 +-
.../{ => agent}/task/PipeConfigNodeTaskStage.java | 8 +-
.../protocol/IoTDBConfigRegionConnector.java | 3 +-
.../coordinator/plugin/PipePluginCoordinator.java | 2 +-
.../runtime/heartbeat/PipeHeartbeat.java | 4 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 12 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 4 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 4 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 2 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 4 +-
.../metric/PipeConfigNodeRemainingTimeMetrics.java | 2 +-
.../PipeConfigNodeRemainingTimeOperator.java | 2 +-
.../metric/PipeConfigRegionConnectorMetrics.java | 2 +-
.../pipe/metric/PipeTemporaryMetaMetrics.java | 4 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 6 +-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 2 +-
.../PipeConfigNodeCopiedFileDirStartupCleaner.java | 2 +-
.../resource/PipeConfigNodeResourceManager.java | 3 +-
.../PipeConfigNodeSnapshotResourceManager.java | 4 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 53 +--
.../persistence/executor/ConfigPlanExecutor.java | 14 +-
.../confignode/persistence/node/NodeInfo.java | 33 +-
.../confignode/persistence/pipe/PipeInfo.java | 37 +-
.../persistence/pipe/PipePluginInfo.java | 12 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 20 +-
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../procedure/CompletedProcedureRecycler.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 2 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 2 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 2 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 2 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 10 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 10 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 2 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 2 +-
...bstractOperateSubscriptionAndPipeProcedure.java | 2 +-
.../subscription/CreateSubscriptionProcedure.java | 2 +-
.../subscription/DropSubscriptionProcedure.java | 2 +-
.../impl/sync/AuthOperationProcedure.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 7 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 489 +--------------------
.../response/pipe/PipePluginTableRespTest.java | 6 +-
.../consensus/response/pipe/PipeTableRespTest.java | 8 +-
.../PipeConfigNodeSubtaskExecutorTest.java | 12 +-
.../connector/IoTDBConfigRegionConnectorTest.java | 2 +-
...eConfigPhysicalPlanPatternParseVisitorTest.java | 4 +-
.../confignode/persistence/AuthorInfoTest.java | 82 ++--
.../persistence/CNPhysicalPlanGeneratorTest.java | 2 +-
.../ConfigRegionListeningQueueTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 10 +-
.../pipe/plugin/CreatePipePluginProcedureTest.java | 2 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 2 +-
.../impl/sync/AuthOperationProcedureTest.java | 29 +-
.../consensus/config/PipeConsensusConfig.java | 2 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 4 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 19 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 2 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeName.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeSelector.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 6 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 25 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 50 ++-
.../db/consensus/DataRegionConsensusImpl.java | 2 +-
.../schemaregion/SchemaExecutionVisitor.java | 12 +
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 10 +-
.../PipeDataRegionConnectorConstructor.java | 8 +-
.../PipeDataRegionExtractorConstructor.java | 8 +-
.../dataregion/PipeDataRegionPluginAgent.java | 10 +-
.../PipeDataRegionProcessorConstructor.java | 10 +-
.../PipeSchemaRegionConnectorConstructor.java | 6 +-
.../PipeSchemaRegionExtractorConstructor.java | 6 +-
.../schemaregion/PipeSchemaRegionPluginAgent.java | 8 +-
.../PipeSchemaRegionProcessorConstructor.java | 6 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 8 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 3 +-
.../runtime/PipeSchemaRegionListenerManager.java | 2 +-
.../runtime}/SimpleProgressIndexAssigner.java | 2 +-
.../db/pipe/{ => agent}/task/PipeDataNodeTask.java | 6 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 17 +-
.../task/builder/PipeDataNodeBuilder.java | 12 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 22 +-
.../{ => agent}/task/connection/EnrichedDeque.java | 2 +-
.../task/connection/PipeEventCollector.java | 8 +-
.../execution/PipeConnectorSubtaskExecutor.java | 4 +-
.../execution/PipeProcessorSubtaskExecutor.java | 4 +-
.../execution/PipeSubtaskExecutorManager.java | 4 +-
.../task/stage/PipeTaskConnectorStage.java | 10 +-
.../task/stage/PipeTaskExtractorStage.java | 8 +-
.../task/stage/PipeTaskProcessorStage.java | 18 +-
.../subtask/connector/PipeConnectorSubtask.java | 6 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 6 +-
.../connector/PipeConnectorSubtaskManager.java | 10 +-
.../PipeRealtimePriorityBlockingQueue.java | 8 +-
.../subtask/processor/PipeProcessorSubtask.java | 12 +-
.../processor/PipeProcessorSubtaskWorker.java | 2 +-
.../PipeProcessorSubtaskWorkerManager.java | 2 +-
.../client/IoTDBDataNodeSyncClientManager.java | 26 +-
.../connector/protocol/opcua/OpcUaConnector.java | 16 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 2 +-
.../async/IoTDBDataRegionAsyncConnector.java | 2 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 3 +-
.../consensus/PipeConsensusSubtaskExecutor.java | 2 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 4 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 6 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 2 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 4 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 4 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 4 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 10 +-
.../tablet/TabletInsertionDataContainer.java | 4 +-
.../event/common/terminate/PipeTerminateEvent.java | 6 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 10 +-
.../common/tsfile/TsFileInsertionPointCounter.java | 2 +-
.../container/TsFileInsertionDataContainer.java | 4 +-
.../TsFileInsertionDataContainerProvider.java | 6 +-
.../query/TsFileInsertionQueryDataContainer.java | 4 +-
.../scan/TsFileInsertionScanDataContainer.java | 23 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 4 +-
.../dataregion/DataRegionListeningFilter.java | 2 +-
.../dataregion/IoTDBDataRegionExtractor.java | 4 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 6 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 6 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 17 +-
.../PipeTimePartitionProgressIndexKeeper.java | 8 +-
.../matcher}/CachedSchemaPatternMatcher.java | 4 +-
.../realtime/matcher}/PipeDataRegionMatcher.java | 2 +-
.../schemaregion/PipePlanPatternParseVisitor.java | 2 +-
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 6 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 4 +-
.../metric/PipeDataRegionConnectorMetrics.java | 2 +-
.../iotdb/db/pipe/metric/PipeProcessorMetrics.java | 2 +-
.../metric/PipeSchemaRegionConnectorMetrics.java | 2 +-
.../processor/aggregate/AggregateProcessor.java | 16 +-
.../twostage/plugin/TwoStageCountProcessor.java | 14 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 +-
.../transform/converter/ValueConverter.java | 12 +-
...peStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../visitor/PipeStatementPatternParseVisitor.java | 2 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 2 +-
.../pipe/resource/PipeDataNodeResourceManager.java | 2 +-
.../PipeDataNodeSnapshotResourceManager.java | 2 +-
.../handler/AINodeRPCServiceThriftHandler.java | 60 ---
.../protocol/thrift/impl/AINodeRPCServiceImpl.java | 187 --------
.../impl/DataNodeInternalRPCServiceImpl.java | 5 +-
.../db/queryengine/common/MPPQueryContext.java | 18 +-
.../execution/executor/RegionReadExecutor.java | 3 +-
.../process/AggregationMergeSortOperator.java | 3 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 11 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 105 ++---
.../analyze/lock/DataNodeSchemaLockManager.java | 22 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 64 +--
.../config/executor/ClusterConfigTaskExecutor.java | 6 +-
.../config/metadata/ShowPipePluginsTask.java | 4 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 39 +-
.../plan/planner/OperatorTreeGenerator.java | 2 +-
.../plan/node/write/InsertMultiTabletsNode.java | 2 +-
.../plan/planner/plan/node/write/InsertNode.java | 2 +-
.../planner/plan/node/write/InsertRowsNode.java | 4 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 2 +-
.../plan/statement/crud/LoadTsFileStatement.java | 18 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 10 +-
.../apache/iotdb/db/service/AINodeRPCService.java | 94 ----
.../iotdb/db/service/AINodeRPCServiceMBean.java | 22 -
.../java/org/apache/iotdb/db/service/DataNode.java | 13 +-
.../iotdb/db/service/RegionMigrateService.java | 36 +-
.../db/service/ResourcesInformationHolder.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 1 +
.../db/storageengine/dataregion/DataRegion.java | 16 +-
.../RepairUnsortedFileCompactionPerformer.java | 9 +-
.../execute/task/AbstractCompactionTask.java | 4 +-
.../execute/task/CrossSpaceCompactionTask.java | 3 +
.../task/InsertionCrossSpaceCompactionTask.java | 2 +
.../task/RepairUnsortedFileCompactionTask.java | 96 ++--
.../execute/task/SettleCompactionTask.java | 30 +-
.../utils/AlignedSeriesBatchCompactionUtils.java | 10 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 6 +-
.../compaction/repair/RepairDataFileScanUtil.java | 22 +-
.../repair/RepairTimePartitionScanTask.java | 5 +-
.../repair/UnsortedFileRepairTaskScheduler.java | 2 +-
.../compaction/schedule/CompactionScheduler.java | 3 +-
.../selector/constant/CrossCompactionSelector.java | 6 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 19 +-
.../impl/SizeTieredCompactionSelector.java | 12 +-
.../selector/utils/TsFileResourceCandidate.java | 1 +
.../dataregion/tsfile/TsFileRepairStatus.java | 16 +-
.../dataregion/tsfile/TsFileResource.java | 6 +-
.../FileTimeIndexCacheWriter.java | 8 +-
.../storageengine/dataregion/wal/WALManager.java | 2 +-
.../load/config/LoadTsFileConfigurator.java | 100 +++++
.../agent/SubscriptionBrokerAgent.java | 10 +
.../broker/SubscriptionBlockingPendingQueue.java | 2 +-
.../db/subscription/broker/SubscriptionBroker.java | 22 +-
.../broker/SubscriptionPrefetchingQueue.java | 14 +-
.../TsFileDeduplicationBlockingPendingQueue.java | 2 +-
.../db/subscription/event/SubscriptionEvent.java | 6 +
.../batch/SubscriptionPipeTabletEventBatch.java | 10 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 12 +-
.../event/pipe/SubscriptionPipeEmptyEvent.java | 9 +
.../event/pipe/SubscriptionPipeEvents.java | 4 +
.../pipe/SubscriptionPipeTabletBatchEvents.java | 9 +
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 13 +
.../pipe/SubscriptionPipeTsFilePlainEvent.java | 9 +
.../SubscriptionPrefetchingQueueMetrics.java | 2 +-
.../execution}/SubscriptionSubtaskExecutor.java | 4 +-
.../task/stage/SubscriptionTaskConnectorStage.java | 6 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 18 +-
.../SubscriptionConnectorSubtaskLifeCycle.java | 8 +-
.../SubscriptionConnectorSubtaskManager.java | 19 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 8 +-
.../task}/PipeConnectorSubtaskExecutorTest.java | 7 +-
.../task}/PipeProcessorSubtaskExecutorTest.java | 9 +-
.../task}/PipeSubtaskExecutorTest.java | 6 +-
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 2 +-
.../PipeStatementPatternParseVisitorTest.java | 2 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 2 +-
.../event/TsFileInsertionDataContainerTest.java | 6 +-
.../extractor/PipePlanPatternParseVisitorTest.java | 2 +-
.../pattern/CachedSchemaPatternMatcherTest.java | 5 +-
.../db/pipe/pattern/IoTDBPipePatternTest.java | 2 +-
.../db/pipe/pattern/PrefixPipePatternTest.java | 2 +-
.../operator/AggregationMergeSortOperatorTest.java | 178 ++++++++
.../TsFileResourceProgressIndexTest.java | 64 +--
.../CrossSpaceCompactionWithUnusualCasesTest.java | 37 +-
.../cross/CrossSpaceCompactionSelectorTest.java | 63 ++-
.../CrossSpaceCompactionWithFastPerformerTest.java | 10 +-
...eCompactionWithFastPerformerValidationTest.java | 112 ++---
...sSpaceCompactionWithReadPointPerformerTest.java | 10 +-
...actionWithReadPointPerformerValidationTest.java | 106 +++--
.../InsertionCrossSpaceCompactionRecoverTest.java | 13 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 105 +++--
.../cross/InsertionCrossSpaceCompactionTest.java | 15 +-
.../compaction/cross/MergeUpgradeTest.java | 4 +-
.../cross/RewriteCompactionFileSelectorTest.java | 42 +-
.../repair/RepairUnsortedFileCompactionTest.java | 100 ++++-
.../repair/RepairUnsortedFileSchedulerTest.java | 2 +-
.../compaction/utils/BatchCompactionUtilsTest.java | 124 ++++++
.../compaction/utils/CompactionTaskQueueTest.java | 8 +-
.../conf/iotdb-system.properties.template | 12 +-
.../client/request/AsyncRequestManager.java | 2 +-
.../commons/consensus/index/ProgressIndex.java | 43 +-
.../consensus/index/impl/HybridProgressIndex.java | 41 +-
.../consensus/index/impl/IoTProgressIndex.java | 17 +-
.../consensus/index/impl/MetaProgressIndex.java | 25 +-
.../consensus/index/impl/MinimumProgressIndex.java | 7 +-
.../consensus/index/impl/RecoverProgressIndex.java | 27 +-
.../consensus/index/impl/SimpleProgressIndex.java | 9 +-
.../consensus/index/impl/StateProgressIndex.java | 29 +-
.../index/impl/TimeWindowStateProgressIndex.java | 47 +-
.../PipeRuntimeConnectorCriticalException.java | 2 +-
.../pipe/PipeRuntimeCriticalException.java | 2 +-
.../exception/pipe/PipeRuntimeExceptionType.java | 2 +-
.../pipe/PipeRuntimeNonCriticalException.java | 2 +-
.../PipeRuntimeOutOfMemoryCriticalException.java | 2 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 5 +-
.../plugin/builtin/BuiltinPipePlugin.java | 56 +--
.../builtin/connector/PlaceholderConnector.java | 2 +-
.../connector/donothing/DoNothingConnector.java | 2 +-
.../iotdb/airgap/IoTDBAirGapConnector.java | 4 +-
.../consensus/PipeConsensusAsyncConnector.java | 4 +-
.../iotdb/thrift/IoTDBLegacyPipeConnector.java | 4 +-
.../iotdb/thrift/IoTDBThriftAsyncConnector.java | 2 +-
.../iotdb/thrift/IoTDBThriftConnector.java | 4 +-
.../iotdb/thrift/IoTDBThriftSslConnector.java | 4 +-
.../iotdb/thrift/IoTDBThriftSyncConnector.java | 2 +-
.../builtin/connector/opcua/OpcUaConnector.java | 4 +-
.../connector/websocket/WebSocketConnector.java | 4 +-
.../connector/writeback/WriteBackConnector.java | 4 +-
.../extractor/donothing/DoNothingExtractor.java | 2 +-
.../builtin/extractor/iotdb/IoTDBExtractor.java | 2 +-
.../builtin/processor/PlaceHolderProcessor.java | 2 +-
.../processor/aggregate/AggregateProcessor.java | 4 +-
.../aggregate/StandardStatisticsProcessor.java | 4 +-
.../aggregate/TumblingWindowingProcessor.java | 4 +-
.../processor/donothing/DoNothingProcessor.java | 2 +-
.../ChangingValueSamplingProcessor.java | 4 +-
.../SwingingDoorTrendingSamplingProcessor.java | 4 +-
.../TumblingTimeSamplingProcessor.java | 4 +-
.../pipeconsensus/PipeConsensusProcessor.java | 4 +-
.../throwing/ThrowingExceptionProcessor.java | 2 +-
.../processor/twostage/TwoStageCountProcessor.java | 4 +-
.../PipeConnectorConstructor.java | 6 +-
.../PipeExtractorConstructor.java | 6 +-
.../{ => constructor}/PipePluginConstructor.java | 8 +-
.../PipeProcessorConstructor.java | 6 +-
.../meta/ConfigNodePipePluginMetaKeeper.java | 2 +-
.../plugin/meta/DataNodePipePluginMetaKeeper.java | 2 +-
.../{ => agent}/plugin/meta/PipePluginMeta.java | 2 +-
.../plugin/meta/PipePluginMetaKeeper.java | 4 +-
.../plugin/service/PipePluginClassLoader.java | 2 +-
.../service/PipePluginClassLoaderManager.java | 2 +-
.../service/PipePluginExecutableManager.java | 4 +-
.../commons/pipe/{ => agent}/task/PipeTask.java | 2 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 14 +-
.../pipe/{ => agent}/task/PipeTaskManager.java | 4 +-
.../task/connection/BlockingPendingQueue.java | 2 +-
.../connection/BoundedBlockingPendingQueue.java | 2 +-
.../task/connection}/EventSupplier.java | 2 +-
.../connection/UnboundedBlockingPendingQueue.java | 2 +-
.../task/execution}/PipeSubtaskExecutor.java | 5 +-
.../task/execution}/PipeSubtaskScheduler.java | 3 +-
.../pipe/{ => agent}/task/meta/PipeMeta.java | 2 +-
.../pipe/{ => agent}/task/meta/PipeMetaKeeper.java | 2 +-
.../{ => agent}/task/meta/PipeRuntimeMeta.java | 2 +-
.../task/meta/PipeRuntimeMetaVersion.java | 2 +-
.../pipe/{ => agent}/task/meta/PipeStaticMeta.java | 2 +-
.../pipe/{ => agent}/task/meta/PipeStatus.java | 2 +-
.../pipe/{ => agent}/task/meta/PipeTaskMeta.java | 2 +-
.../{ => agent}/task/meta/PipeTemporaryMeta.java | 2 +-
.../pipe/{ => agent}/task/meta/PipeType.java | 2 +-
.../{ => agent/task}/progress/CommitterKey.java | 2 +-
.../task}/progress/PipeEventCommitManager.java | 2 +-
.../task}/progress/PipeEventCommitter.java | 2 +-
.../pipe/{ => agent}/task/stage/PipeTaskStage.java | 4 +-
.../task/subtask/PipeAbstractConnectorSubtask.java | 4 +-
.../task/subtask/PipeReportableSubtask.java | 2 +-
.../pipe/{ => agent}/task/subtask/PipeSubtask.java | 4 +-
.../env/PipeTaskExtractorRuntimeEnvironment.java | 2 +-
.../env/PipeTaskProcessorRuntimeEnvironment.java | 2 +-
.../pipe/connector/protocol/IoTDBConnector.java | 2 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 35 +-
.../options/PipeInclusionOptions.java | 2 +-
.../pattern/IoTDBPipePattern.java | 2 +-
.../{ => datastructure}/pattern/PipePattern.java | 2 +-
.../pattern/PrefixPipePattern.java | 2 +-
.../listening/AbstractPipeListeningQueue.java | 2 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 8 +-
.../commons/pipe/event/PipeSnapshotEvent.java | 6 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 4 +-
.../commons/pipe/event/ProgressReportEvent.java | 4 +-
.../commons/pipe/extractor/IoTDBExtractor.java | 2 +-
.../extractor/IoTDBNonDataRegionExtractor.java | 4 +-
.../pipe/metric/PipeEventCommitMetrics.java | 2 +-
.../PipeReceiverStatusHandler.java | 4 +-
.../PipeSnapshotResourceManager.java | 2 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 11 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 9 +-
.../exception/pipe/PipeRuntimeExceptionTest.java | 2 +-
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 10 +-
.../pipe/plugin/meta/PipePluginMetaTest.java | 4 +-
.../pipe/task/{meta => }/PipeMetaDeSerTest.java | 20 +-
.../src/main/thrift/datanode.thrift | 15 +-
pom.xml | 4 +-
433 files changed, 3009 insertions(+), 3608 deletions(-)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{function/GetFunctionTablePlan.java
=> ConfigPhysicalReadPlan.java} (65%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/auth/AuthorReadPlan.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/IAINodeRPCServiceWithHandler.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java}
(70%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{
=> write}/auth/AuthorPlan.java (67%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/ShowCQPlan.java
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/sync/ShowPipePlanV1.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{execution
=> agent/task}/PipeConfigNodeSubtask.java (96%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{execution
=> agent/task}/PipeConfigNodeSubtaskExecutor.java (92%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> agent}/task/PipeConfigNodeTask.java (91%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> agent}/task/PipeConfigNodeTaskBuilder.java (87%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> agent}/task/PipeConfigNodeTaskStage.java (86%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/resource/{snapshot
=> }/PipeConfigNodeSnapshotResourceManager.java (89%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/{execution
=> agent}/PipeConfigNodeSubtaskExecutorTest.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{progress =>
agent/runtime}/SimpleProgressIndexAssigner.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/PipeDataNodeTask.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/builder/PipeDataNodeBuilder.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/builder/PipeDataNodeTaskBuilder.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/connection/EnrichedDeque.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/connection/PipeEventCollector.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent/task}/execution/PipeConnectorSubtaskExecutor.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent/task}/execution/PipeProcessorSubtaskExecutor.java (89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent/task}/execution/PipeSubtaskExecutorManager.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/stage/PipeTaskConnectorStage.java (88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/stage/PipeTaskExtractorStage.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/stage/PipeTaskProcessorStage.java (89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/connector/PipeConnectorSubtask.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/connector/PipeConnectorSubtaskLifeCycle.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/connector/PipeConnectorSubtaskManager.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/connector/PipeRealtimePriorityBlockingQueue.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/processor/PipeProcessorSubtask.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/processor/PipeProcessorSubtaskWorker.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/processor/PipeProcessorSubtaskWorkerManager.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{pattern =>
extractor/dataregion/realtime/matcher}/CachedSchemaPatternMatcher.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{pattern =>
extractor/dataregion/realtime/matcher}/PipeDataRegionMatcher.java (96%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/handler/AINodeRPCServiceThriftHandler.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/AINodeRPCServiceImpl.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCService.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCServiceMBean.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/config/LoadTsFileConfigurator.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/{execution/executor
=> task/execution}/SubscriptionSubtaskExecutor.java (89%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{execution
=> agent/task}/PipeConnectorSubtaskExecutorTest.java (83%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{execution
=> agent/task}/PipeProcessorSubtaskExecutorTest.java (80%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{execution
=> agent/task}/PipeSubtaskExecutorTest.java (96%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/AggregationMergeSortOperatorTest.java
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/BuiltinPipePlugin.java (71%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/PlaceholderConnector.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/donothing/DoNothingConnector.java (96%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/airgap/IoTDBAirGapConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=>
agent}/plugin/builtin/connector/iotdb/consensus/PipeConsensusAsyncConnector.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBLegacyPipeConnector.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBThriftAsyncConnector.java
(93%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBThriftConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSslConnector.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSyncConnector.java
(93%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/opcua/OpcUaConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/websocket/WebSocketConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/writeback/WriteBackConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/extractor/donothing/DoNothingExtractor.java (95%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/extractor/iotdb/IoTDBExtractor.java (96%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/PlaceHolderProcessor.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/aggregate/AggregateProcessor.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/aggregate/StandardStatisticsProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/aggregate/TumblingWindowingProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/donothing/DoNothingProcessor.java (96%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=>
agent}/plugin/builtin/processor/downsampling/ChangingValueSamplingProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=>
agent}/plugin/builtin/processor/downsampling/SwingingDoorTrendingSamplingProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=>
agent}/plugin/builtin/processor/downsampling/TumblingTimeSamplingProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/pipeconsensus/PipeConsensusProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/throwing/ThrowingExceptionProcessor.java
(97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/twostage/TwoStageCountProcessor.java (87%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/{
=> constructor}/PipeConnectorConstructor.java (89%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/{
=> constructor}/PipeExtractorConstructor.java (89%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/{
=> constructor}/PipePluginConstructor.java (92%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/{
=> constructor}/PipeProcessorConstructor.java (89%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/meta/ConfigNodePipePluginMetaKeeper.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/meta/DataNodePipePluginMetaKeeper.java (93%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/meta/PipePluginMeta.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/meta/PipePluginMetaKeeper.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/service/PipePluginClassLoader.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/service/PipePluginClassLoaderManager.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/service/PipePluginExecutableManager.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/PipeTask.java (94%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/PipeTaskManager.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/connection/BlockingPendingQueue.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/connection/BoundedBlockingPendingQueue.java (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{task =>
agent/task/connection}/EventSupplier.java (95%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/connection/UnboundedBlockingPendingQueue.java (95%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{execution/executor
=> agent/task/execution}/PipeSubtaskExecutor.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{execution/scheduler
=> agent/task/execution}/PipeSubtaskScheduler.java (95%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/meta/PipeMeta.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/meta/PipeMetaKeeper.java (99%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/meta/PipeRuntimeMeta.java (99%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/meta/PipeRuntimeMetaVersion.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/meta/PipeStaticMeta.java (99%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/meta/PipeStatus.java (96%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/meta/PipeTaskMeta.java (99%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/meta/PipeTemporaryMeta.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/meta/PipeType.java (95%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent/task}/progress/CommitterKey.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent/task}/progress/PipeEventCommitManager.java (99%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent/task}/progress/PipeEventCommitter.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/stage/PipeTaskStage.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/subtask/PipeAbstractConnectorSubtask.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/subtask/PipeReportableSubtask.java (99%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/task/subtask/PipeSubtask.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> datastructure}/pattern/IoTDBPipePattern.java (99%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> datastructure}/pattern/PipePattern.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> datastructure}/pattern/PrefixPipePattern.java (98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{connector
=> receiver}/PipeReceiverStatusHandler.java (98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/{
=> snapshot}/PipeSnapshotResourceManager.java (99%)
rename
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/task/{meta
=> }/PipeMetaDeSerTest.java (86%)
