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

类 MigrationJobAPIImpl

java.lang.Object

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

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

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

所有已实现的接口:

InventoryIncrementalJobPublicAPI, MigrationJobPublicAPI, PipelineJobPublicAPI, InventoryIncrementalJobAPI, PipelineJobAPI, PipelineJobItemAPI, MigrationJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI, org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

public final class MigrationJobAPIImpl
extends AbstractInventoryIncrementalJobAPIImpl
implements MigrationJobAPI

Migration job API impl.

字段概要

从类继承的字段 org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

DATE_TIME_FORMATTER

构造器概要

构造器

构造器和说明
MigrationJobAPIImpl()

方法概要

限定符和类型	方法和说明
void	addMigrationSourceResources(Map<String,DataSourceProperties> dataSourcePropsMap)
protected PipelineDataConsistencyChecker	buildPipelineDataConsistencyChecker(PipelineJobConfiguration pipelineJobConfig, InventoryIncrementalProcessContext processContext, ConsistencyCheckJobItemContext checkJobItemContext)
MigrationProcessContext	buildPipelineProcessContext(PipelineJobConfiguration pipelineJobConfig) Build pipeline process context.
MigrationTaskConfiguration	buildTaskConfiguration(PipelineJobConfiguration pipelineJobConfig, int jobShardingItem, PipelineProcessConfiguration pipelineProcessConfig) Build task configuration.
void	commit(String jobId)
String	createJobAndStart(CreateMigrationJobParameter parameter)
void	dropMigrationSourceResources(Collection<String> resourceNames)
void	extendYamlJobConfiguration(YamlPipelineJobConfiguration yamlJobConfig) Extend YAML job configuration.
protected String	getJobClassName()
protected MigrationJobConfiguration	getJobConfiguration(org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO jobConfigPOJO)
MigrationJobConfiguration	getJobConfiguration(String jobId) Get job configuration.
protected TableBasedPipelineJobInfo	getJobInfo(String jobId)
JobType	getJobType()
protected String	getTargetDatabaseType(PipelineJobConfiguration pipelineJobConfig)
Collection<Collection<Object>>	listMigrationSourceResources()
protected String	marshalJobIdLeftPart(PipelineJobId pipelineJobId)
void	rollback(String jobId)
void	startDisabledJob(String jobId)
void	stop(String jobId)
protected YamlPipelineJobConfiguration	swapToYamlJobConfiguration(PipelineJobConfiguration jobConfig)

从类继承的方法 org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractInventoryIncrementalJobAPIImpl

aggregateDataConsistencyCheckResults, alterProcessConfiguration, buildDataConsistencyCalculateAlgorithm, createProcessConfiguration, dataConsistencyCheck, dropProcessConfiguration, getJobItemProgress, getJobProgress, getJobProgress, listDataConsistencyCheckAlgorithms, persistJobItemProgress, showProcessConfiguration, updateJobItemStatus

从类继承的方法 org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl

checkModeConfig, cleanJobItemErrorMessage, dropJob, getElasticJobConfigPOJO, getJobItemErrorMessage, getType, list, marshalJobId, persistJobItemErrorMessage, start

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

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

从接口继承的方法 org.apache.shardingsphere.data.pipeline.core.api.InventoryIncrementalJobAPI

aggregateDataConsistencyCheckResults, buildDataConsistencyCalculateAlgorithm, dataConsistencyCheck, getJobItemProgress, getJobProgress

从接口继承的方法 org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI

cleanJobItemErrorMessage, getJobItemErrorMessage, marshalJobId, persistJobItemErrorMessage, start

从接口继承的方法 org.apache.shardingsphere.data.pipeline.core.api.PipelineJobItemAPI

persistJobItemProgress, updateJobItemStatus

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

alterProcessConfiguration, createProcessConfiguration, dropProcessConfiguration, getJobProgress, listDataConsistencyCheckAlgorithms, showProcessConfiguration

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

list

从接口继承的方法 org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

getType, getTypeAliases

从接口继承的方法 org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI

isDefault

构造器详细资料

MigrationJobAPIImpl

public MigrationJobAPIImpl()

方法详细资料

marshalJobIdLeftPart

protected String marshalJobIdLeftPart(PipelineJobId pipelineJobId)

指定者:

marshalJobIdLeftPart 在类中 AbstractPipelineJobAPIImpl

getJobInfo

protected TableBasedPipelineJobInfo getJobInfo(String jobId)

指定者:

getJobInfo 在类中 AbstractPipelineJobAPIImpl

extendYamlJobConfiguration

public void extendYamlJobConfiguration(YamlPipelineJobConfiguration yamlJobConfig)

从接口复制的说明: PipelineJobAPI

Extend YAML job configuration.

指定者:

extendYamlJobConfiguration 在接口中 PipelineJobAPI

参数:

yamlJobConfig - YAML job configuration

swapToYamlJobConfiguration

protected YamlPipelineJobConfiguration swapToYamlJobConfiguration(PipelineJobConfiguration jobConfig)

指定者:

swapToYamlJobConfiguration 在类中 AbstractPipelineJobAPIImpl

getJobConfiguration

public MigrationJobConfiguration getJobConfiguration(String jobId)

从接口复制的说明: PipelineJobAPI

Get job configuration.

指定者:

getJobConfiguration 在接口中 PipelineJobAPI

指定者:

getJobConfiguration 在接口中 MigrationJobAPI

参数:

jobId - job id

返回:

job configuration

getJobConfiguration

protected MigrationJobConfiguration getJobConfiguration(org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO jobConfigPOJO)

指定者:

getJobConfiguration 在类中 AbstractPipelineJobAPIImpl

getTargetDatabaseType

protected String getTargetDatabaseType(PipelineJobConfiguration pipelineJobConfig)

指定者:

getTargetDatabaseType 在类中 AbstractInventoryIncrementalJobAPIImpl

buildTaskConfiguration

public MigrationTaskConfiguration buildTaskConfiguration(PipelineJobConfiguration pipelineJobConfig,
                                                         int jobShardingItem,
                                                         PipelineProcessConfiguration pipelineProcessConfig)

从接口复制的说明: PipelineJobAPI

Build task configuration.

指定者:

buildTaskConfiguration 在接口中 PipelineJobAPI

指定者:

buildTaskConfiguration 在接口中 MigrationJobAPI

参数:

pipelineJobConfig - pipeline job configuration

jobShardingItem - job sharding item

pipelineProcessConfig - pipeline process configuration

返回:

task configuration

buildPipelineProcessContext

public MigrationProcessContext buildPipelineProcessContext(PipelineJobConfiguration pipelineJobConfig)

从接口复制的说明: PipelineJobAPI

Build pipeline process context.

指定者:

buildPipelineProcessContext 在接口中 PipelineJobAPI

指定者:

buildPipelineProcessContext 在接口中 MigrationJobAPI

指定者:

buildPipelineProcessContext 在类中 AbstractInventoryIncrementalJobAPIImpl

参数:

pipelineJobConfig - pipeline job configuration

返回:

pipeline process context

buildPipelineDataConsistencyChecker

protected PipelineDataConsistencyChecker buildPipelineDataConsistencyChecker(PipelineJobConfiguration pipelineJobConfig,
                                                                             InventoryIncrementalProcessContext processContext,
                                                                             ConsistencyCheckJobItemContext checkJobItemContext)

指定者:

buildPipelineDataConsistencyChecker 在类中 AbstractInventoryIncrementalJobAPIImpl

startDisabledJob

public void startDisabledJob(String jobId)

指定者:

startDisabledJob 在接口中 PipelineJobPublicAPI

覆盖:

startDisabledJob 在类中 AbstractPipelineJobAPIImpl

stop

public void stop(String jobId)

指定者:

stop 在接口中 PipelineJobPublicAPI

覆盖:

stop 在类中 AbstractPipelineJobAPIImpl

rollback

public void rollback(String jobId)
              throws SQLException

指定者:

rollback 在接口中 InventoryIncrementalJobPublicAPI

抛出:

SQLException

commit

public void commit(String jobId)

指定者:

commit 在接口中 InventoryIncrementalJobPublicAPI

addMigrationSourceResources

public void addMigrationSourceResources(Map<String,DataSourceProperties> dataSourcePropsMap)

指定者:

addMigrationSourceResources 在接口中 MigrationJobPublicAPI

dropMigrationSourceResources

public void dropMigrationSourceResources(Collection<String> resourceNames)

指定者:

dropMigrationSourceResources 在接口中 MigrationJobPublicAPI

listMigrationSourceResources

public Collection<Collection<Object>> listMigrationSourceResources()

指定者:

listMigrationSourceResources 在接口中 MigrationJobPublicAPI

createJobAndStart

public String createJobAndStart(CreateMigrationJobParameter parameter)

指定者:

createJobAndStart 在接口中 MigrationJobPublicAPI

getJobType

public JobType getJobType()

指定者:

getJobType 在接口中 PipelineJobPublicAPI

getJobClassName

protected String getJobClassName()

指定者:

getJobClassName 在类中 AbstractPipelineJobAPIImpl