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

类 InventoryIncrementalJobItemAPIImpl

java.lang.Object

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

所有已实现的接口:

PipelineJobItemAPI

public final class InventoryIncrementalJobItemAPIImpl
extends Object
implements PipelineJobItemAPI

Inventory incremental job item API implementation.

构造器概要

构造器

构造器和说明
InventoryIncrementalJobItemAPIImpl()

方法概要

限定符和类型	方法和说明
InventoryIncrementalJobItemProgress	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.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

InventoryIncrementalJobItemAPIImpl

public InventoryIncrementalJobItemAPIImpl()

方法详细资料

persistJobItemProgress

public void persistJobItemProgress(PipelineJobItemContext jobItemContext)

从接口复制的说明: PipelineJobItemAPI

Persist job item progress.

指定者:

persistJobItemProgress 在接口中 PipelineJobItemAPI

参数:

jobItemContext - job item context

getJobItemProgress

public InventoryIncrementalJobItemProgress getJobItemProgress(String jobId,
                                                              int shardingItem)

从接口复制的说明: PipelineJobItemAPI

Get job item progress.

指定者:

getJobItemProgress 在接口中 PipelineJobItemAPI

参数:

jobId - job id

shardingItem - sharding item

返回:

job item progress, may be null

updateJobItemStatus

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

从接口复制的说明: PipelineJobItemAPI

Update job item status.

指定者:

updateJobItemStatus 在接口中 PipelineJobItemAPI

参数:

jobId - job id

shardingItem - sharding item

status - status