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 9e105cbc7ec refactor common
add 9f314035d16 refactor
No new revisions were added by this update.
Summary of changes:
.../pipe/{ => agent}/task/PipeConfigNodeSubtask.java | 2 +-
.../{ => agent}/task/PipeConfigNodeSubtaskExecutor.java | 2 +-
.../pipe/{ => agent}/task/PipeConfigNodeTask.java | 2 +-
.../manager/pipe/agent/task/PipeConfigNodeTaskAgent.java | 3 ---
.../pipe/{ => agent}/task/PipeConfigNodeTaskBuilder.java | 2 +-
.../pipe/{ => agent}/task/PipeConfigNodeTaskStage.java | 2 +-
.../pipe/metric/PipeConfigNodeRemainingTimeOperator.java | 2 +-
.../pipe/metric/PipeConfigRegionConnectorMetrics.java | 2 +-
.../iotdb/confignode/persistence/pipe/PipeInfo.java | 2 +-
.../PipeConfigNodeSubtaskExecutorTest.java | 6 +++---
.../iotdb/db/pipe/{ => agent}/task/PipeDataNodeTask.java | 2 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java | 5 ++---
.../{ => agent}/task/builder/PipeDataNodeBuilder.java | 2 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 16 ++++++++--------
.../pipe/{ => agent}/task/connection/EnrichedDeque.java | 2 +-
.../{ => agent}/task/connection/PipeEventCollector.java | 2 +-
.../task/execution/PipeConnectorSubtaskExecutor.java | 2 +-
.../task/execution/PipeProcessorSubtaskExecutor.java | 2 +-
.../task/execution/PipeSubtaskExecutorManager.java | 2 +-
.../{ => agent}/task/stage/PipeTaskConnectorStage.java | 6 +++---
.../{ => agent}/task/stage/PipeTaskExtractorStage.java | 2 +-
.../{ => agent}/task/stage/PipeTaskProcessorStage.java | 8 ++++----
.../task/subtask/connector/PipeConnectorSubtask.java | 2 +-
.../subtask/connector/PipeConnectorSubtaskLifeCycle.java | 4 ++--
.../subtask/connector/PipeConnectorSubtaskManager.java | 4 ++--
.../connector/PipeRealtimePriorityBlockingQueue.java | 4 ++--
.../task/subtask/processor/PipeProcessorSubtask.java | 4 ++--
.../subtask/processor/PipeProcessorSubtaskWorker.java | 2 +-
.../processor/PipeProcessorSubtaskWorkerManager.java | 2 +-
.../thrift/async/IoTDBDataRegionAsyncConnector.java | 2 +-
.../db/pipe/consensus/PipeConsensusSubtaskExecutor.java | 2 +-
.../pipe/event/common/terminate/PipeTerminateEvent.java | 2 +-
.../metric/PipeDataNodeRemainingEventAndTimeMetrics.java | 4 ++--
.../PipeDataNodeRemainingEventAndTimeOperator.java | 4 ++--
.../db/pipe/metric/PipeDataRegionConnectorMetrics.java | 2 +-
.../iotdb/db/pipe/metric/PipeProcessorMetrics.java | 2 +-
.../db/pipe/metric/PipeSchemaRegionConnectorMetrics.java | 2 +-
.../execution/executor/SubscriptionSubtaskExecutor.java | 2 +-
.../task/stage/SubscriptionTaskConnectorStage.java | 4 ++--
.../task/subtask/SubscriptionConnectorSubtask.java | 2 +-
.../subtask/SubscriptionConnectorSubtaskLifeCycle.java | 6 +++---
.../subtask/SubscriptionConnectorSubtaskManager.java | 8 ++++----
.../task}/PipeConnectorSubtaskExecutorTest.java | 6 +++---
.../task}/PipeProcessorSubtaskExecutorTest.java | 8 ++++----
.../task}/PipeSubtaskExecutorTest.java | 2 +-
45 files changed, 76 insertions(+), 80 deletions(-)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> agent}/task/PipeConfigNodeSubtask.java (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> agent}/task/PipeConfigNodeSubtaskExecutor.java (96%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> agent}/task/PipeConfigNodeTask.java (95%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> agent}/task/PipeConfigNodeTaskBuilder.java (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/{
=> agent}/task/PipeConfigNodeTaskStage.java (97%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/{execution
=> agent}/PipeConfigNodeSubtaskExecutorTest.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/PipeDataNodeTask.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/builder/PipeDataNodeBuilder.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/builder/PipeDataNodeTaskBuilder.java (93%)
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 (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/execution/PipeConnectorSubtaskExecutor.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/execution/PipeProcessorSubtaskExecutor.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/execution/PipeSubtaskExecutorManager.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/stage/PipeTaskConnectorStage.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/stage/PipeTaskExtractorStage.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/stage/PipeTaskProcessorStage.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/connector/PipeConnectorSubtask.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/connector/PipeConnectorSubtaskLifeCycle.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/connector/PipeConnectorSubtaskManager.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/connector/PipeRealtimePriorityBlockingQueue.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/{ =>
agent}/task/subtask/processor/PipeProcessorSubtask.java (98%)
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/test/java/org/apache/iotdb/db/pipe/{execution
=> agent/task}/PipeConnectorSubtaskExecutorTest.java (88%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{execution
=> agent/task}/PipeProcessorSubtaskExecutorTest.java (84%)
rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{execution
=> agent/task}/PipeSubtaskExecutorTest.java (99%)
