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

接口 InventoryIncrementalJobAPI

所有超级接口:

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

所有已知子接口:

MigrationJobAPI

所有已知实现类:

AbstractInventoryIncrementalJobAPIImpl, MigrationJobAPIImpl

public interface InventoryIncrementalJobAPI
extends PipelineJobAPI

Inventory incremental job API.

方法概要

限定符和类型	方法和说明
boolean	aggregateDataConsistencyCheckResults(String jobId, Map<String,DataConsistencyCheckResult> checkResults) Aggregate data consistency check results.
DataConsistencyCalculateAlgorithm	buildDataConsistencyCalculateAlgorithm(PipelineJobConfiguration jobConfig, String algorithmType, Properties algorithmProps) Build data consistency calculate algorithm.
Map<String,DataConsistencyCheckResult>	dataConsistencyCheck(PipelineJobConfiguration pipelineJobConfig, DataConsistencyCalculateAlgorithm calculateAlgorithm, ConsistencyCheckJobItemContext checkJobItemContext) Do data consistency check.
InventoryIncrementalJobItemProgress	getJobItemProgress(String jobId, int shardingItem) Get job item progress.
Map<Integer,InventoryIncrementalJobItemProgress>	getJobProgress(PipelineJobConfiguration pipelineJobConfig) Get job progress.

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

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

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

getJobType, list, startDisabledJob, stop

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

persistJobItemProgress, updateJobItemStatus

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

getType, getTypeAliases

方法详细资料

getJobProgress

Map<Integer,InventoryIncrementalJobItemProgress> getJobProgress(PipelineJobConfiguration pipelineJobConfig)

Get job progress.

参数:

pipelineJobConfig - job configuration

返回:

each sharding item progress

getJobItemProgress

InventoryIncrementalJobItemProgress getJobItemProgress(String jobId,
                                                       int shardingItem)

从接口复制的说明: PipelineJobItemAPI

Get job item progress.

指定者:

getJobItemProgress 在接口中 PipelineJobItemAPI

参数:

jobId - job id

shardingItem - sharding item

返回:

job item progress, may be null

buildDataConsistencyCalculateAlgorithm

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

Build data consistency calculate algorithm.

参数:

jobConfig - job configuration

algorithmType - algorithm type

algorithmProps - algorithm properties

返回:

calculate algorithm

dataConsistencyCheck

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

Do data consistency check.

参数:

pipelineJobConfig - job configuration

calculateAlgorithm - calculate algorithm

checkJobItemContext - consistency check job item context

返回:

each logic table check result

aggregateDataConsistencyCheckResults

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

Aggregate data consistency check results.

参数:

jobId - job id

checkResults - check results

返回:

check success or not