org.apache.shardingsphere.data.pipeline.core.context

接口 InventoryIncrementalJobItemContext

所有超级接口:

PipelineJobItemContext, PipelineJobProgressListener

所有已知实现类:

MigrationJobItemContext

public interface InventoryIncrementalJobItemContext
extends PipelineJobItemContext, PipelineJobProgressListener

Inventory incremental job item context.

方法概要

限定符和类型	方法和说明
PipelineDataSourceManager	getDataSourceManager() Get data source manager.
Collection<IncrementalTask>	getIncrementalTasks() Get incremental tasks.
InventoryIncrementalJobItemProgress	getInitProgress() Get init progress.
Collection<InventoryTask>	getInventoryTasks() Get inventory tasks.
InventoryIncrementalProcessContext	getJobProcessContext()
long	getProcessedRecordsCount() Get processed record count.
PipelineTableMetaDataLoader	getSourceMetaDataLoader() Get source meta data loader.

从接口继承的方法 org.apache.shardingsphere.data.pipeline.api.context.PipelineJobItemContext

getDataSourceName, getJobConfig, getJobId, getShardingItem, getStatus, isStopping, setStatus, setStopping

从接口继承的方法 org.apache.shardingsphere.data.pipeline.api.job.progress.listener.PipelineJobProgressListener

onProgressUpdated

方法详细资料

getJobProcessContext

InventoryIncrementalProcessContext getJobProcessContext()

指定者:

getJobProcessContext 在接口中 PipelineJobItemContext

getInventoryTasks

Collection<InventoryTask> getInventoryTasks()

Get inventory tasks.

返回:

inventory tasks

getIncrementalTasks

Collection<IncrementalTask> getIncrementalTasks()

Get incremental tasks.

返回:

incremental tasks

getInitProgress

InventoryIncrementalJobItemProgress getInitProgress()

Get init progress.

返回:

init progress

getSourceMetaDataLoader

PipelineTableMetaDataLoader getSourceMetaDataLoader()

Get source meta data loader.

返回:

source meta data loader

getDataSourceManager

PipelineDataSourceManager getDataSourceManager()

Get data source manager.

返回:

data source manager

getProcessedRecordsCount

long getProcessedRecordsCount()

Get processed record count.

返回:

processed record count.