类 MilvusTaskChannel
java.lang.Object
org.apache.dolphinscheduler.plugin.task.milvus.MilvusTaskChannel
- 所有已实现的接口:
org.apache.dolphinscheduler.plugin.task.api.TaskChannel
public class MilvusTaskChannel
extends Object
implements org.apache.dolphinscheduler.plugin.task.api.TaskChannel
-
构造器概要
构造器 -
方法概要
修饰符和类型方法说明voidcancelApplication(boolean status) org.apache.dolphinscheduler.plugin.task.api.AbstractTaskcreateTask(org.apache.dolphinscheduler.plugin.task.api.TaskExecutionContext taskExecutionContext) org.apache.dolphinscheduler.plugin.task.api.parameters.resource.ResourceParametersHelpergetResources(String taskParams) org.apache.dolphinscheduler.plugin.task.api.parameters.AbstractParametersparseParameters(org.apache.dolphinscheduler.plugin.task.api.parameters.ParametersNode parametersNode)
-
构造器详细资料
-
MilvusTaskChannel
public MilvusTaskChannel()
-
-
方法详细资料
-
cancelApplication
public void cancelApplication(boolean status) - 指定者:
cancelApplication在接口中org.apache.dolphinscheduler.plugin.task.api.TaskChannel
-
createTask
public org.apache.dolphinscheduler.plugin.task.api.AbstractTask createTask(org.apache.dolphinscheduler.plugin.task.api.TaskExecutionContext taskExecutionContext) - 指定者:
createTask在接口中org.apache.dolphinscheduler.plugin.task.api.TaskChannel
-
parseParameters
public org.apache.dolphinscheduler.plugin.task.api.parameters.AbstractParameters parseParameters(org.apache.dolphinscheduler.plugin.task.api.parameters.ParametersNode parametersNode) - 指定者:
parseParameters在接口中org.apache.dolphinscheduler.plugin.task.api.TaskChannel
-
getResources
public org.apache.dolphinscheduler.plugin.task.api.parameters.resource.ResourceParametersHelper getResources(String taskParams) - 指定者:
getResources在接口中org.apache.dolphinscheduler.plugin.task.api.TaskChannel
-