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

接口 MigrationJobAPI

所有超级接口:

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

所有已知实现类:

MigrationJobAPIImpl

public interface MigrationJobAPI
extends InventoryIncrementalJobAPI, MigrationJobPublicAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI

Migration job API.

方法概要

限定符和类型	方法和说明
MigrationProcessContext	buildPipelineProcessContext(PipelineJobConfiguration pipelineJobConfig) Build pipeline process context.
MigrationTaskConfiguration	buildTaskConfiguration(PipelineJobConfiguration pipelineJobConfig, int jobShardingItem, PipelineProcessConfiguration pipelineProcessConfig) Build task configuration.
MigrationJobConfiguration	getJobConfiguration(String jobId) Get job configuration.

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

aggregateDataConsistencyCheckResults, buildDataConsistencyCalculateAlgorithm, dataConsistencyCheck, getJobItemProgress, getJobProgress

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

cleanJobItemErrorMessage, extendYamlJobConfiguration, getJobItemErrorMessage, marshalJobId, persistJobItemErrorMessage, start

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

persistJobItemProgress, updateJobItemStatus

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

addMigrationSourceResources, createJobAndStart, dropMigrationSourceResources, listMigrationSourceResources

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

alterProcessConfiguration, commit, createProcessConfiguration, dropProcessConfiguration, getJobProgress, listDataConsistencyCheckAlgorithms, rollback, showProcessConfiguration

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

getJobType, list, startDisabledJob, stop

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

getType, getTypeAliases

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

isDefault

方法详细资料

getJobConfiguration

MigrationJobConfiguration getJobConfiguration(String jobId)

从接口复制的说明: PipelineJobAPI

Get job configuration.

指定者:

getJobConfiguration 在接口中 PipelineJobAPI

参数:

jobId - job id

返回:

job configuration

buildTaskConfiguration

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

从接口复制的说明: PipelineJobAPI

Build task configuration.

指定者:

buildTaskConfiguration 在接口中 PipelineJobAPI

参数:

pipelineJobConfig - pipeline job configuration

jobShardingItem - job sharding item

pipelineProcessConfig - pipeline process configuration

返回:

task configuration

buildPipelineProcessContext

MigrationProcessContext buildPipelineProcessContext(PipelineJobConfiguration pipelineJobConfig)

从接口复制的说明: PipelineJobAPI

Build pipeline process context.

指定者:

buildPipelineProcessContext 在接口中 PipelineJobAPI

参数:

pipelineJobConfig - pipeline job configuration

返回:

pipeline process context