org.apache.shardingsphere.data.pipeline.core.api

接口 PipelineJobItemAPI

所有已知子接口:

ConsistencyCheckJobAPI, InventoryIncrementalJobAPI, MigrationJobAPI, PipelineJobAPI

所有已知实现类:

AbstractInventoryIncrementalJobAPIImpl, AbstractPipelineJobAPIImpl, ConsistencyCheckJobAPIImpl, InventoryIncrementalJobItemAPIImpl, MigrationJobAPIImpl

public interface PipelineJobItemAPI

Pipeline job item API.

方法概要

限定符和类型	方法和说明
PipelineJobItemProgress	getJobItemProgress(String jobId, int shardingItem) Get job item progress.
void	persistJobItemProgress(PipelineJobItemContext jobItemContext) Persist job item progress.
void	updateJobItemStatus(String jobId, int shardingItem, JobStatus status) Update job item status.

方法详细资料

persistJobItemProgress

void persistJobItemProgress(PipelineJobItemContext jobItemContext)

Persist job item progress.

参数:

jobItemContext - job item context

getJobItemProgress

PipelineJobItemProgress getJobItemProgress(String jobId,
                                           int shardingItem)

Get job item progress.

参数:

jobId - job id

shardingItem - sharding item

返回:

job item progress, may be null

updateJobItemStatus

void updateJobItemStatus(String jobId,
                         int shardingItem,
                         JobStatus status)

Update job item status.

参数:

jobId - job id

shardingItem - sharding item

status - status