org.apache.shardingsphere.data.pipeline.scenario.migration

类 MigrationJobItemContext

java.lang.Object

org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobItemContext

所有已实现的接口:

PipelineJobItemContext, PipelineJobProgressListener, InventoryIncrementalJobItemContext

public final class MigrationJobItemContext
extends Object
implements InventoryIncrementalJobItemContext

Migration job item context.

构造器概要

构造器

构造器和说明
MigrationJobItemContext(MigrationJobConfiguration jobConfig, int shardingItem, InventoryIncrementalJobItemProgress initProgress, MigrationProcessContext jobProcessContext, MigrationTaskConfiguration taskConfig, PipelineDataSourceManager dataSourceManager)

方法概要

限定符和类型	方法和说明
long	getProcessedRecordsCount() Get processed record count.
PipelineDataSourceWrapper	getSourceDataSource() Get source data source.
PipelineTableMetaDataLoader	getSourceMetaDataLoader() Get source meta data loader.
boolean	isSourceTargetDatabaseTheSame() Is source and target database the same or not.
void	onProgressUpdated(PipelineJobProgressUpdatedParameter parameter)

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

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

从接口继承的方法 org.apache.shardingsphere.data.pipeline.core.context.InventoryIncrementalJobItemContext

getDataSourceManager, getIncrementalTasks, getInitProgress, getInventoryTasks, getJobProcessContext

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

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

构造器详细资料

MigrationJobItemContext

public MigrationJobItemContext(MigrationJobConfiguration jobConfig,
                               int shardingItem,
                               InventoryIncrementalJobItemProgress initProgress,
                               MigrationProcessContext jobProcessContext,
                               MigrationTaskConfiguration taskConfig,
                               PipelineDataSourceManager dataSourceManager)

方法详细资料

getSourceDataSource

public PipelineDataSourceWrapper getSourceDataSource()

Get source data source.

返回:

source data source

getSourceMetaDataLoader

public PipelineTableMetaDataLoader getSourceMetaDataLoader()

从接口复制的说明: InventoryIncrementalJobItemContext

Get source meta data loader.

指定者:

getSourceMetaDataLoader 在接口中 InventoryIncrementalJobItemContext

返回:

source meta data loader

isSourceTargetDatabaseTheSame

public boolean isSourceTargetDatabaseTheSame()

Is source and target database the same or not.

返回:

true if source and target database the same, otherwise false

onProgressUpdated

public void onProgressUpdated(PipelineJobProgressUpdatedParameter parameter)

指定者:

onProgressUpdated 在接口中 PipelineJobProgressListener

getProcessedRecordsCount

public long getProcessedRecordsCount()

从接口复制的说明: InventoryIncrementalJobItemContext

Get processed record count.

指定者:

getProcessedRecordsCount 在接口中 InventoryIncrementalJobItemContext

返回:

processed record count.