org.apache.shardingsphere.data.pipeline.core.task

接口 PipelineTask

所有已知实现类:

IncrementalTask, InventoryTask

public interface PipelineTask

Pipeline task interface.

方法概要

限定符和类型	方法和说明
String	getTaskId() Get task id.
TaskProgress	getTaskProgress() Get task progress.
CompletableFuture<?>	start() Start task.
void	stop() Stop task.

方法详细资料

start

CompletableFuture<?> start()

Start task.

返回:

future

stop

void stop()

Stop task.

getTaskId

String getTaskId()

Get task id.

返回:

task id

getTaskProgress

TaskProgress getTaskProgress()

Get task progress.

返回:

task progress