diff --git a/docs/dev_guide/KnowStreaming Task模块简介.md b/docs/dev_guide/KnowStreaming Task模块简介.md index b1316067..abe2b81d 100644 --- a/docs/dev_guide/KnowStreaming Task模块简介.md +++ b/docs/dev_guide/KnowStreaming Task模块简介.md @@ -199,16 +199,21 @@ public abstract class AbstractDispatchTask { +public abstract class AbstractClusterPhyDispatchTask extends AbstractDispatchTask { + // 执行被分配的任务,具体由子类实现 - protected abstract TaskResult processSubTask(ClusterPhy clusterPhy, long triggerTimeUnitMs) throws Exception; // 返回所有的Kafka集群 + protected abstract TaskResult processSubTask(ClusterPhy clusterPhy, long triggerTimeUnitMs) throws Exception; + + // 返回所有的Kafka集群 @Override public List listAllTasks() { return clusterPhyService.listAllClusters(); } + // 执行被分配给该KS主机的Kafka集群任务 @Override public TaskResult processTask(List subTaskList, long triggerTimeUnitMs) { // ... } + } ```