ConsistencyCheckJobAPIImpl (shardingsphere-data-pipeline-core 5.2.1 API)

java.lang.Object
- org.apache.shardingsphere.data.pipeline.core.api.impl.AbstractPipelineJobAPIImpl
- - org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobAPIImpl

所有已实现的接口:

ConsistencyCheckJobPublicAPI, PipelineJobPublicAPI, PipelineJobAPI, PipelineJobItemAPI, ConsistencyCheckJobAPI, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI, org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI
```
public final class ConsistencyCheckJobAPIImpl
extends AbstractPipelineJobAPIImpl
implements ConsistencyCheckJobAPI
```
Consistency check job API impl.

构造器概要

构造器
构造器和说明

ConsistencyCheckJobAPIImpl()

构造器
构造器和说明
`ConsistencyCheckJobAPIImpl()`

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`PipelineProcessContext`	`buildPipelineProcessContext(PipelineJobConfiguration pipelineJobConfig)` Build pipeline process context.
`PipelineTaskConfiguration`	`buildTaskConfiguration(PipelineJobConfiguration pipelineJobConfig, int jobShardingItem, PipelineProcessConfiguration pipelineProcessConfig)` Build task configuration.
`String`	`createJobAndStart(CreateConsistencyCheckJobParameter parameter)`
`void`	`extendYamlJobConfiguration(YamlPipelineJobConfiguration yamlJobConfig)` Extend YAML job configuration.
`protected String`	`getJobClassName()`
`protected ConsistencyCheckJobConfiguration`	`getJobConfiguration(org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO jobConfigPOJO)`
`ConsistencyCheckJobConfiguration`	`getJobConfiguration(String jobId)` Get job configuration.
`protected PipelineJobInfo`	`getJobInfo(String jobId)`
`ConsistencyCheckJobProgress`	`getJobItemProgress(String jobId, int shardingItem)` Get job item progress.
`ConsistencyCheckJobProgressInfo`	`getJobProgressInfo(String parentJobId)`
`JobType`	`getJobType()`
`Map<String,DataConsistencyCheckResult>`	`getLatestDataConsistencyCheckResult(String jobId)`
`protected String`	`marshalJobIdLeftPart(PipelineJobId pipelineJobId)`
`void`	`persistJobItemProgress(PipelineJobItemContext jobItemContext)` Persist job item progress.
`void`	`startByParentJobId(String parentJobId)`
`void`	`startDisabledJob(String jobId)`
`void`	`stopByParentJobId(String parentJobId)`
`protected YamlPipelineJobConfiguration`	`swapToYamlJobConfiguration(PipelineJobConfiguration jobConfig)`
`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, getJobItemErrorMessage, getType, list, marshalJobId, persistJobItemErrorMessage, start, stop

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

从接口继承的方法 org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI
cleanJobItemErrorMessage, getJobItemErrorMessage, marshalJobId, persistJobItemErrorMessage, start

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

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

- 构造器详细资料
  - ConsistencyCheckJobAPIImpl
```
public ConsistencyCheckJobAPIImpl()
```
- 方法详细资料
  - marshalJobIdLeftPart
```
protected String marshalJobIdLeftPart(PipelineJobId pipelineJobId)
```
    指定者:
    
    marshalJobIdLeftPart 在类中 AbstractPipelineJobAPIImpl
  - createJobAndStart
```
public String createJobAndStart(CreateConsistencyCheckJobParameter parameter)
```
    指定者:
    
    createJobAndStart 在接口中 ConsistencyCheckJobPublicAPI
  - getLatestDataConsistencyCheckResult
```
public Map<String,DataConsistencyCheckResult> getLatestDataConsistencyCheckResult(String jobId)
```
    指定者:
    
    getLatestDataConsistencyCheckResult 在接口中 ConsistencyCheckJobPublicAPI
  - persistJobItemProgress
```
public void persistJobItemProgress(PipelineJobItemContext jobItemContext)
```
    从接口复制的说明: PipelineJobItemAPI
    
    Persist job item progress.
    
    指定者:
    
    persistJobItemProgress 在接口中 PipelineJobItemAPI
    
    参数:
    
    jobItemContext - job item context
  - getJobItemProgress
```
public ConsistencyCheckJobProgress getJobItemProgress(String jobId,
                                                      int shardingItem)
```
    从接口复制的说明: PipelineJobItemAPI
    
    Get job item progress.
    
    指定者:
    
    getJobItemProgress 在接口中 PipelineJobItemAPI
    
    参数:
    
    jobId - job id
    
    shardingItem - sharding item
    
    返回:
    
    job item progress, may be null
  - 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
  - startDisabledJob
```
public void startDisabledJob(String jobId)
```
    指定者:
    
    startDisabledJob 在接口中 PipelineJobPublicAPI
    
    覆盖:
    
    startDisabledJob 在类中 AbstractPipelineJobAPIImpl
  - startByParentJobId
```
public void startByParentJobId(String parentJobId)
```
    指定者:
    
    startByParentJobId 在接口中 ConsistencyCheckJobPublicAPI
  - stopByParentJobId
```
public void stopByParentJobId(String parentJobId)
```
    指定者:
    
    stopByParentJobId 在接口中 ConsistencyCheckJobPublicAPI
  - getJobProgressInfo
```
public ConsistencyCheckJobProgressInfo getJobProgressInfo(String parentJobId)
```
    指定者:
    
    getJobProgressInfo 在接口中 ConsistencyCheckJobPublicAPI
  - getJobConfiguration
```
public ConsistencyCheckJobConfiguration getJobConfiguration(String jobId)
```
    从接口复制的说明: PipelineJobAPI
    
    Get job configuration.
    
    指定者:
    
    getJobConfiguration 在接口中 PipelineJobAPI
    
    参数:
    
    jobId - job id
    
    返回:
    
    job configuration
  - getJobConfiguration
```
protected ConsistencyCheckJobConfiguration getJobConfiguration(org.apache.shardingsphere.elasticjob.infra.pojo.JobConfigurationPOJO jobConfigPOJO)
```
    指定者:
    
    getJobConfiguration 在类中 AbstractPipelineJobAPIImpl
  - swapToYamlJobConfiguration
```
protected YamlPipelineJobConfiguration swapToYamlJobConfiguration(PipelineJobConfiguration jobConfig)
```
    指定者:
    
    swapToYamlJobConfiguration 在类中 AbstractPipelineJobAPIImpl
  - extendYamlJobConfiguration
```
public void extendYamlJobConfiguration(YamlPipelineJobConfiguration yamlJobConfig)
```
    从接口复制的说明: PipelineJobAPI
    
    Extend YAML job configuration.
    
    指定者:
    
    extendYamlJobConfiguration 在接口中 PipelineJobAPI
    
    参数:
    
    yamlJobConfig - YAML job configuration
  - buildTaskConfiguration
```
public PipelineTaskConfiguration 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
```
public PipelineProcessContext buildPipelineProcessContext(PipelineJobConfiguration pipelineJobConfig)
```
    从接口复制的说明: PipelineJobAPI
    
    Build pipeline process context.
    
    指定者:
    
    buildPipelineProcessContext 在接口中 PipelineJobAPI
    
    参数:
    
    pipelineJobConfig - pipeline job configuration
    
    返回:
    
    pipeline process context
  - getJobInfo
```
protected PipelineJobInfo getJobInfo(String jobId)
```
    指定者:
    
    getJobInfo 在类中 AbstractPipelineJobAPIImpl
  - getJobClassName
```
protected String getJobClassName()
```
    指定者:
    
    getJobClassName 在类中 AbstractPipelineJobAPIImpl
  - getJobType
```
public JobType getJobType()
```
    指定者:
    
    getJobType 在接口中 PipelineJobPublicAPI

类 ConsistencyCheckJobAPIImpl

构造器概要

方法概要

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

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

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

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

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

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

构造器详细资料

ConsistencyCheckJobAPIImpl

方法详细资料

marshalJobIdLeftPart

createJobAndStart

getLatestDataConsistencyCheckResult

persistJobItemProgress

getJobItemProgress

updateJobItemStatus

startDisabledJob

startByParentJobId

stopByParentJobId

getJobProgressInfo

getJobConfiguration

getJobConfiguration

swapToYamlJobConfiguration

extendYamlJobConfiguration

buildTaskConfiguration

buildPipelineProcessContext

getJobInfo

getJobClassName

getJobType