This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch refactor-pipe-package
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a4030612f2f refactor
add 9e105cbc7ec refactor common
No new revisions were added by this update.
Summary of changes:
.../write/pipe/runtime/PipeHandleMetaChangePlan.java | 2 +-
.../request/write/pipe/task/AlterPipePlanV2.java | 4 ++--
.../request/write/pipe/task/CreatePipePlanV2.java | 4 ++--
.../request/write/pipe/task/SetPipeStatusPlanV2.java | 2 +-
.../consensus/response/pipe/task/PipeTableResp.java | 10 +++++-----
.../pipe/agent/runtime/PipeConfigNodeRuntimeAgent.java | 2 +-
.../manager/pipe/agent/task/PipeConfigNodeTaskAgent.java | 8 ++++----
.../coordinator/runtime/heartbeat/PipeHeartbeat.java | 4 ++--
.../runtime/heartbeat/PipeHeartbeatParser.java | 12 ++++++------
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 2 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 2 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 2 +-
.../pipe/metric/PipeConfigNodeRemainingTimeMetrics.java | 2 +-
.../manager/pipe/metric/PipeTemporaryMetaMetrics.java | 4 ++--
.../manager/pipe/task/PipeConfigNodeSubtask.java | 6 +++---
.../manager/pipe/task/PipeConfigNodeSubtaskExecutor.java | 2 +-
.../confignode/manager/pipe/task/PipeConfigNodeTask.java | 2 +-
.../manager/pipe/task/PipeConfigNodeTaskBuilder.java | 10 +++++-----
.../manager/pipe/task/PipeConfigNodeTaskStage.java | 4 ++--
.../iotdb/confignode/persistence/pipe/PipeInfo.java | 2 +-
.../iotdb/confignode/persistence/pipe/PipeTaskInfo.java | 16 ++++++++--------
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 2 +-
.../impl/pipe/runtime/PipeHandleMetaChangeProcedure.java | 2 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 2 +-
.../procedure/impl/pipe/task/AlterPipeProcedureV2.java | 10 +++++-----
.../procedure/impl/pipe/task/CreatePipeProcedureV2.java | 10 +++++-----
.../procedure/impl/pipe/task/StartPipeProcedureV2.java | 2 +-
.../procedure/impl/pipe/task/StopPipeProcedureV2.java | 2 +-
.../AbstractOperateSubscriptionAndPipeProcedure.java | 2 +-
.../subscription/CreateSubscriptionProcedure.java | 2 +-
.../subscription/DropSubscriptionProcedure.java | 2 +-
.../consensus/request/ConfigPhysicalPlanSerDeTest.java | 13 +++++++------
.../consensus/response/pipe/PipeTableRespTest.java | 8 ++++----
.../execution/PipeConfigNodeSubtaskExecutorTest.java | 6 +++---
.../iotdb/confignode/persistence/PipeInfoTest.java | 8 ++++----
.../org/apache/iotdb/consensus/pipe/PipeConsensus.java | 2 +-
.../iotdb/consensus/pipe/PipeConsensusServerImpl.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 2 +-
.../consensus/pipe/consensuspipe/ConsensusPipeName.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeSelector.java | 2 +-
.../iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../db/pipe/agent/runtime/PipeDataNodeRuntimeAgent.java | 2 +-
.../agent/runtime/PipeSchemaRegionListenerManager.java | 2 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java | 12 ++++++------
.../pipeconsensus/PipeConsensusAsyncConnector.java | 2 +-
.../iotdb/db/pipe/event/UserDefinedEnrichedEvent.java | 2 +-
.../pipe/event/common/heartbeat/PipeHeartbeatEvent.java | 4 ++--
.../iotdb/db/pipe/event/common/row/PipeRowCollector.java | 2 +-
.../common/schema/PipeSchemaRegionSnapshotEvent.java | 2 +-
.../common/schema/PipeSchemaRegionWritePlanEvent.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 2 +-
.../event/common/tablet/PipeRawTabletInsertionEvent.java | 2 +-
.../common/tablet/TabletInsertionDataContainer.java | 2 +-
.../pipe/event/common/terminate/PipeTerminateEvent.java | 2 +-
.../event/common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../tsfile/container/TsFileInsertionDataContainer.java | 2 +-
.../container/TsFileInsertionDataContainerProvider.java | 2 +-
.../query/TsFileInsertionQueryDataContainer.java | 2 +-
.../container/scan/TsFileInsertionScanDataContainer.java | 2 +-
.../iotdb/db/pipe/event/realtime/PipeRealtimeEvent.java | 2 +-
.../extractor/dataregion/DataRegionListeningFilter.java | 2 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 2 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 4 ++--
.../metric/PipeDataNodeRemainingEventAndTimeMetrics.java | 2 +-
.../db/pipe/processor/aggregate/AggregateProcessor.java | 2 +-
.../twostage/plugin/TwoStageCountProcessor.java | 2 +-
.../org/apache/iotdb/db/pipe/task/PipeDataNodeTask.java | 4 ++--
.../iotdb/db/pipe/task/builder/PipeDataNodeBuilder.java | 10 +++++-----
.../db/pipe/task/builder/PipeDataNodeTaskBuilder.java | 6 +++---
.../db/pipe/task/connection/PipeEventCollector.java | 4 ++--
.../task/execution/PipeConnectorSubtaskExecutor.java | 2 +-
.../task/execution/PipeProcessorSubtaskExecutor.java | 2 +-
.../iotdb/db/pipe/task/stage/PipeTaskConnectorStage.java | 4 ++--
.../iotdb/db/pipe/task/stage/PipeTaskExtractorStage.java | 6 +++---
.../iotdb/db/pipe/task/stage/PipeTaskProcessorStage.java | 8 ++++----
.../task/subtask/connector/PipeConnectorSubtask.java | 4 ++--
.../subtask/connector/PipeConnectorSubtaskLifeCycle.java | 2 +-
.../subtask/connector/PipeConnectorSubtaskManager.java | 4 ++--
.../connector/PipeRealtimePriorityBlockingQueue.java | 4 ++--
.../task/subtask/processor/PipeProcessorSubtask.java | 8 ++++----
.../thrift/impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../broker/SubscriptionBlockingPendingQueue.java | 2 +-
.../iotdb/db/subscription/broker/SubscriptionBroker.java | 2 +-
.../broker/TsFileDeduplicationBlockingPendingQueue.java | 2 +-
.../task/stage/SubscriptionTaskConnectorStage.java | 2 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 2 +-
.../subtask/SubscriptionConnectorSubtaskLifeCycle.java | 2 +-
.../subtask/SubscriptionConnectorSubtaskManager.java | 4 ++--
.../pipe/execution/PipeConnectorSubtaskExecutorTest.java | 2 +-
.../pipe/execution/PipeProcessorSubtaskExecutorTest.java | 2 +-
.../iotdb/db/pipe/execution/PipeSubtaskExecutorTest.java | 4 ++--
.../pipe/PipeRuntimeConnectorCriticalException.java | 2 +-
.../exception/pipe/PipeRuntimeCriticalException.java | 2 +-
.../commons/exception/pipe/PipeRuntimeExceptionType.java | 2 +-
.../exception/pipe/PipeRuntimeNonCriticalException.java | 2 +-
.../pipe/PipeRuntimeOutOfMemoryCriticalException.java | 2 +-
.../iotdb/commons/pipe/{ => agent}/task/PipeTask.java | 2 +-
.../iotdb/commons/pipe/agent/task/PipeTaskAgent.java | 14 ++++++--------
.../commons/pipe/{ => agent}/task/PipeTaskManager.java | 4 ++--
.../task/connection/BlockingPendingQueue.java | 2 +-
.../task/connection/BoundedBlockingPendingQueue.java | 2 +-
.../pipe/{ => agent}/task/connection/EventSupplier.java | 2 +-
.../task/connection/UnboundedBlockingPendingQueue.java | 2 +-
.../task/execution}/PipeSubtaskExecutor.java | 5 ++---
.../task/execution}/PipeSubtaskScheduler.java | 3 +--
.../commons/pipe/{ => agent}/task/meta/PipeMeta.java | 2 +-
.../pipe/{ => agent}/task/meta/PipeMetaKeeper.java | 2 +-
.../pipe/{ => agent}/task/meta/PipeRuntimeMeta.java | 2 +-
.../{ => agent}/task/meta/PipeRuntimeMetaVersion.java | 2 +-
.../pipe/{ => agent}/task/meta/PipeStaticMeta.java | 2 +-
.../commons/pipe/{ => agent}/task/meta/PipeStatus.java | 2 +-
.../commons/pipe/{ => agent}/task/meta/PipeTaskMeta.java | 2 +-
.../pipe/{ => agent}/task/meta/PipeTemporaryMeta.java | 2 +-
.../commons/pipe/{ => agent}/task/meta/PipeType.java | 2 +-
.../pipe/{ => agent}/task/progress/CommitterKey.java | 2 +-
.../task/progress/PipeEventCommitManager.java | 2 +-
.../{ => agent}/task/progress/PipeEventCommitter.java | 2 +-
.../pipe/{ => agent}/task/stage/PipeTaskStage.java | 4 ++--
.../task/subtask/PipeAbstractConnectorSubtask.java | 4 ++--
.../{ => agent}/task/subtask/PipeReportableSubtask.java | 2 +-
.../pipe/{ => agent}/task/subtask/PipeSubtask.java | 4 ++--
.../plugin/env/PipeTaskExtractorRuntimeEnvironment.java | 2 +-
.../plugin/env/PipeTaskProcessorRuntimeEnvironment.java | 2 +-
.../queue/listening/AbstractPipeListeningQueue.java | 2 +-
.../apache/iotdb/commons/pipe/event/EnrichedEvent.java | 6 +++---
.../iotdb/commons/pipe/event/PipeSnapshotEvent.java | 2 +-
.../iotdb/commons/pipe/event/PipeWritePlanEvent.java | 2 +-
.../iotdb/commons/pipe/event/ProgressReportEvent.java | 2 +-
.../iotdb/commons/pipe/extractor/IoTDBExtractor.java | 2 +-
.../commons/pipe/metric/PipeEventCommitMetrics.java | 2 +-
.../commons/pipe/receiver/PipeReceiverStatusHandler.java | 2 +-
.../commons/exception/pipe/PipeRuntimeExceptionTest.java | 2 +-
.../commons/pipe/task/{meta => }/PipeMetaDeSerTest.java | 7 ++++++-
134 files changed, 232 insertions(+), 230 deletions(-)
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/{
=> 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/{task/execution/executor
=> agent/task/execution}/PipeSubtaskExecutor.java (96%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{task/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/test/java/org/apache/iotdb/commons/pipe/task/{meta
=> }/PipeMetaDeSerTest.java (94%)
