This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch IOTDB-5787 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 02f77a7000abd4f3a4a68a2b43e69987d83f0f97 Author: Steve Yurong Su <[email protected]> AuthorDate: Fri Apr 28 03:21:49 2023 +0800 interface for task management --- .../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 2 +- .../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 30 +++++++++++++++++++--- 2 files changed, 27 insertions(+), 5 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/agent/PipeAgent.java b/server/src/main/java/org/apache/iotdb/db/pipe/agent/PipeAgent.java index f490a171f15..501cbf0016d 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/agent/PipeAgent.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/agent/PipeAgent.java @@ -23,7 +23,7 @@ import org.apache.iotdb.db.pipe.agent.plugin.PipePluginAgent; import org.apache.iotdb.db.pipe.agent.runtime.PipeRuntimeAgent; import org.apache.iotdb.db.pipe.agent.task.PipeTaskAgent; -/** PipeAgent is the entry point of the pipe module in DatNode. */ +/** PipeAgent is the entry point of the pipe module in DataNode. */ public class PipeAgent { private final PipePluginAgent pipePluginAgent; diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java b/server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java index 9fffa867062..eb0ca8f6f26 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java @@ -19,8 +19,10 @@ package org.apache.iotdb.db.pipe.agent.task; +import org.apache.iotdb.common.rpc.thrift.TConsensusGroupId; import org.apache.iotdb.commons.pipe.task.meta.PipeMeta; import org.apache.iotdb.commons.pipe.task.meta.PipeMetaKeeper; +import org.apache.iotdb.commons.pipe.task.meta.PipeTaskMeta; public class PipeTaskAgent { @@ -30,8 +32,28 @@ public class PipeTaskAgent { pipeMetaKeeper = new PipeMetaKeeper(); } - // TODO: remove this method - public PipeMeta getPipeMeta(String pipeName) { - return pipeMetaKeeper.getPipeMeta(pipeName); - } + ////////////////////////// Pipe Task Management ////////////////////////// + + public void createPipe(PipeMeta pipeMeta) {} + + public void createPipeTaskByConsensusGroup( + String pipeName, + long creationTime, + TConsensusGroupId consensusGroupId, + PipeTaskMeta pipeTaskMeta) {} + + public void dropPipe(String pipeName, long creationTime) {} + + public void dropPipeTaskByConsensusGroup( + String pipeName, long creationTime, TConsensusGroupId consensusGroupId) {} + + public void startPipe(String pipeName, long creationTime) {} + + public void startPipeTaskByConsensusGroup( + String pipeName, long creationTime, TConsensusGroupId consensusGroupId) {} + + public void stopPipe(String pipeName, long creationTime) {} + + public void stopPipeTaskByConsensusGroup( + String pipeName, long creationTime, TConsensusGroupId consensusGroupId) {} }
