This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-task-schedule in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2b6cdaaebada5b89196339ec6401885f6b70f932 Author: Steve Yurong Su <[email protected]> AuthorDate: Mon May 22 22:46:18 2023 +0800 rename package --- .../org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java | 1 - .../{ => execution}/executor/PipeConnectorSubtaskExecutorTest.java | 3 +-- .../{ => execution}/executor/PipeProcessorSubtaskExecutorTest.java | 3 +-- .../db/pipe/{ => execution}/executor/PipeSubtaskExecutorTest.java | 3 +-- 4 files changed, 3 insertions(+), 7 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java b/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java index 1bd8a6ed515..742b2230fa6 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java @@ -49,7 +49,6 @@ public class PipeConnectorSubtask extends PipeSubtask { this.outputPipeConnector = outputPipeConnector; } - // TODO: for a while @Override protected synchronized boolean executeOnce() { try { diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/executor/PipeConnectorSubtaskExecutorTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutorTest.java similarity index 92% rename from server/src/test/java/org/apache/iotdb/db/pipe/executor/PipeConnectorSubtaskExecutorTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutorTest.java index 4c572438955..52acbe9c2ff 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/executor/PipeConnectorSubtaskExecutorTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutorTest.java @@ -17,9 +17,8 @@ * under the License. */ -package org.apache.iotdb.db.pipe.executor; +package org.apache.iotdb.db.pipe.execution.executor; -import org.apache.iotdb.db.pipe.execution.executor.PipeConnectorSubtaskExecutor; import org.apache.iotdb.db.pipe.task.queue.ListenableBlockingPendingQueue; import org.apache.iotdb.db.pipe.task.subtask.PipeConnectorSubtask; import org.apache.iotdb.pipe.api.PipeConnector; diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/executor/PipeProcessorSubtaskExecutorTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutorTest.java similarity index 92% rename from server/src/test/java/org/apache/iotdb/db/pipe/executor/PipeProcessorSubtaskExecutorTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutorTest.java index a8a8659f7fa..d0a5208d537 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/executor/PipeProcessorSubtaskExecutorTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutorTest.java @@ -17,9 +17,8 @@ * under the License. */ -package org.apache.iotdb.db.pipe.executor; +package org.apache.iotdb.db.pipe.execution.executor; -import org.apache.iotdb.db.pipe.execution.executor.PipeProcessorSubtaskExecutor; import org.apache.iotdb.db.pipe.task.queue.EventSupplier; import org.apache.iotdb.db.pipe.task.subtask.PipeProcessorSubtask; import org.apache.iotdb.pipe.api.PipeProcessor; diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/executor/PipeSubtaskExecutorTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutorTest.java similarity index 97% rename from server/src/test/java/org/apache/iotdb/db/pipe/executor/PipeSubtaskExecutorTest.java rename to server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutorTest.java index f70d6874211..d24efc3fb7f 100644 --- a/server/src/test/java/org/apache/iotdb/db/pipe/executor/PipeSubtaskExecutorTest.java +++ b/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutorTest.java @@ -17,9 +17,8 @@ * under the License. */ -package org.apache.iotdb.db.pipe.executor; +package org.apache.iotdb.db.pipe.execution.executor; -import org.apache.iotdb.db.pipe.execution.executor.PipeSubtaskExecutor; import org.apache.iotdb.db.pipe.task.subtask.PipeSubtask; import org.junit.After;
