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

类 AbstractInventoryIncrementalJobAPIImpl

java.lang.Object

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

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

所有已实现的接口:

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

直接已知子类:

MigrationJobAPIImpl

public abstract class AbstractInventoryIncrementalJobAPIImpl
extends AbstractPipelineJobAPIImpl
implements InventoryIncrementalJobAPI, InventoryIncrementalJobPublicAPI

Abstract inventory incremental job API implementation.

字段概要

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

DATE_TIME_FORMATTER

构造器概要

构造器

构造器和说明
AbstractInventoryIncrementalJobAPIImpl()

方法概要

限定符和类型	方法和说明
boolean	aggregateDataConsistencyCheckResults(String jobId, Map<String,DataConsistencyCheckResult> checkResults) Aggregate data consistency check results.
void	alterProcessConfiguration(PipelineProcessConfiguration processConfig)
DataConsistencyCalculateAlgorithm	buildDataConsistencyCalculateAlgorithm(PipelineJobConfiguration jobConfig, String algorithmType, Properties algorithmProps) Build data consistency calculate algorithm.
protected abstract PipelineDataConsistencyChecker	buildPipelineDataConsistencyChecker(PipelineJobConfiguration pipelineJobConfig, InventoryIncrementalProcessContext processContext, ConsistencyCheckJobItemContext checkJobItemContext)
abstract InventoryIncrementalProcessContext	buildPipelineProcessContext(PipelineJobConfiguration pipelineJobConfig) Build pipeline process context.
void	createProcessConfiguration(PipelineProcessConfiguration processConfig)
Map<String,DataConsistencyCheckResult>	dataConsistencyCheck(PipelineJobConfiguration jobConfig, DataConsistencyCalculateAlgorithm calculateAlgorithm, ConsistencyCheckJobItemContext checkJobItemContext) Do data consistency check.
void	dropProcessConfiguration(String confPath)
InventoryIncrementalJobItemProgress	getJobItemProgress(String jobId, int shardingItem) Get job item progress.
Map<Integer,InventoryIncrementalJobItemProgress>	getJobProgress(PipelineJobConfiguration jobConfig) Get job progress.
Map<Integer,InventoryIncrementalJobItemProgress>	getJobProgress(String jobId)
protected abstract String	getTargetDatabaseType(PipelineJobConfiguration pipelineJobConfig)
Collection<DataConsistencyCheckAlgorithmInfo>	listDataConsistencyCheckAlgorithms()
void	persistJobItemProgress(PipelineJobItemContext jobItemContext) Persist job item progress.
PipelineProcessConfiguration	showProcessConfiguration()
void	updateJobItemStatus(String jobId, int shardingItem, JobStatus status) Update job item status.

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

checkModeConfig, cleanJobItemErrorMessage, dropJob, getElasticJobConfigPOJO, getJobClassName, getJobConfiguration, getJobInfo, getJobItemErrorMessage, getType, list, marshalJobId, marshalJobIdLeftPart, persistJobItemErrorMessage, start, startDisabledJob, stop, swapToYamlJobConfiguration

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

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

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

buildTaskConfiguration, cleanJobItemErrorMessage, extendYamlJobConfiguration, getJobConfiguration, getJobItemErrorMessage, marshalJobId, persistJobItemErrorMessage, start

从接口继承的方法 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.data.pipeline.api.InventoryIncrementalJobPublicAPI

commit, rollback

构造器详细资料

AbstractInventoryIncrementalJobAPIImpl

public AbstractInventoryIncrementalJobAPIImpl()

方法详细资料

getTargetDatabaseType

protected abstract String getTargetDatabaseType(PipelineJobConfiguration pipelineJobConfig)

buildPipelineProcessContext

public abstract InventoryIncrementalProcessContext buildPipelineProcessContext(PipelineJobConfiguration pipelineJobConfig)

从接口复制的说明: PipelineJobAPI

Build pipeline process context.

指定者:

buildPipelineProcessContext 在接口中 PipelineJobAPI

参数:

pipelineJobConfig - pipeline job configuration

返回:

pipeline process context

createProcessConfiguration

public void createProcessConfiguration(PipelineProcessConfiguration processConfig)

指定者:

createProcessConfiguration 在接口中 InventoryIncrementalJobPublicAPI

alterProcessConfiguration

public void alterProcessConfiguration(PipelineProcessConfiguration processConfig)

指定者:

alterProcessConfiguration 在接口中 InventoryIncrementalJobPublicAPI

dropProcessConfiguration

public void dropProcessConfiguration(String confPath)

指定者:

dropProcessConfiguration 在接口中 InventoryIncrementalJobPublicAPI

showProcessConfiguration

public PipelineProcessConfiguration showProcessConfiguration()

指定者:

showProcessConfiguration 在接口中 InventoryIncrementalJobPublicAPI

getJobProgress

public Map<Integer,InventoryIncrementalJobItemProgress> getJobProgress(String jobId)

指定者:

getJobProgress 在接口中 InventoryIncrementalJobPublicAPI

getJobProgress

public Map<Integer,InventoryIncrementalJobItemProgress> getJobProgress(PipelineJobConfiguration jobConfig)

从接口复制的说明: InventoryIncrementalJobAPI

Get job progress.

指定者:

getJobProgress 在接口中 InventoryIncrementalJobAPI

参数:

jobConfig - job configuration

返回:

each sharding item progress

getJobItemProgress

public InventoryIncrementalJobItemProgress getJobItemProgress(String jobId,
                                                              int shardingItem)

从接口复制的说明: PipelineJobItemAPI

Get job item progress.

指定者:

getJobItemProgress 在接口中 InventoryIncrementalJobAPI

指定者:

getJobItemProgress 在接口中 PipelineJobItemAPI

参数:

jobId - job id

shardingItem - sharding item

返回:

job item progress, may be null

persistJobItemProgress

public void persistJobItemProgress(PipelineJobItemContext jobItemContext)

从接口复制的说明: PipelineJobItemAPI

Persist job item progress.

指定者:

persistJobItemProgress 在接口中 PipelineJobItemAPI

参数:

jobItemContext - job item context

updateJobItemStatus

public void updateJobItemStatus(String jobId,
                                int shardingItem,
                                JobStatus status)

从接口复制的说明: PipelineJobItemAPI

Update job item status.

指定者:

updateJobItemStatus 在接口中 PipelineJobItemAPI

参数:

jobId - job id

shardingItem - sharding item

status - status

listDataConsistencyCheckAlgorithms

public Collection<DataConsistencyCheckAlgorithmInfo> listDataConsistencyCheckAlgorithms()

指定者:

listDataConsistencyCheckAlgorithms 在接口中 InventoryIncrementalJobPublicAPI

buildDataConsistencyCalculateAlgorithm

public DataConsistencyCalculateAlgorithm buildDataConsistencyCalculateAlgorithm(PipelineJobConfiguration jobConfig,
                                                                                String algorithmType,
                                                                                Properties algorithmProps)

从接口复制的说明: InventoryIncrementalJobAPI

Build data consistency calculate algorithm.

指定者:

buildDataConsistencyCalculateAlgorithm 在接口中 InventoryIncrementalJobAPI

参数:

jobConfig - job configuration

algorithmType - algorithm type

algorithmProps - algorithm properties

返回:

calculate algorithm

dataConsistencyCheck

public Map<String,DataConsistencyCheckResult> dataConsistencyCheck(PipelineJobConfiguration jobConfig,
                                                                   DataConsistencyCalculateAlgorithm calculateAlgorithm,
                                                                   ConsistencyCheckJobItemContext checkJobItemContext)

从接口复制的说明: InventoryIncrementalJobAPI

Do data consistency check.

指定者:

dataConsistencyCheck 在接口中 InventoryIncrementalJobAPI

参数:

jobConfig - job configuration

calculateAlgorithm - calculate algorithm

checkJobItemContext - consistency check job item context

返回:

each logic table check result

buildPipelineDataConsistencyChecker

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

aggregateDataConsistencyCheckResults

public boolean aggregateDataConsistencyCheckResults(String jobId,
                                                    Map<String,DataConsistencyCheckResult> checkResults)

从接口复制的说明: InventoryIncrementalJobAPI

Aggregate data consistency check results.

指定者:

aggregateDataConsistencyCheckResults 在接口中 InventoryIncrementalJobAPI

参数:

jobId - job id

checkResults - check results

返回:

check success or not