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

类 MigrationJobItemContext

java.lang.Object

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

所有已实现的接口:

PipelineJobItemContext, InventoryIncrementalJobItemContext

public final class MigrationJobItemContext
extends Object
implements InventoryIncrementalJobItemContext

Migration job item context.

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
PipelineDataSourceWrapper	getSourceDataSource() Get source data source.
PipelineTableMetaDataLoader	getSourceMetaDataLoader() Get source metadata loader.
boolean	isSourceTargetDatabaseTheSame() Is source and target database the same or not.

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

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

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

getIncrementalTasks, getInventoryTasks

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

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

构造器详细资料

MigrationJobItemContext

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

方法详细资料

getSourceDataSource

public PipelineDataSourceWrapper getSourceDataSource()

Get source data source.

返回:

source data source

getSourceMetaDataLoader

public PipelineTableMetaDataLoader getSourceMetaDataLoader()

Get source metadata loader.

返回:

source metadata loader

isSourceTargetDatabaseTheSame

public boolean isSourceTargetDatabaseTheSame()

Is source and target database the same or not.

返回:

true if source and target database the same, otherwise false