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

java.lang.Object
- org.apache.shardingsphere.data.pipeline.core.api.impl.GovernanceRepositoryAPIImpl

所有已实现的接口:: GovernanceRepositoryAPI

public final class GovernanceRepositoryAPIImpl
extends Object
implements GovernanceRepositoryAPI

Governance repository API impl.

构造器概要

构造器
构造器和说明

GovernanceRepositoryAPIImpl()

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

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`void`	`cleanJobItemErrorMessage(String jobId, int shardingItem)` Clean job item error message.
`void`	`deleteCheckJobResult(String jobId, String checkJobId)` Delete check job result.
`void`	`deleteJob(String jobId)` Delete job.
`Map<String,DataConsistencyCheckResult>`	`getCheckJobResult(String parentJobId, String checkJobId)` Get check job result.
`Optional<String>`	`getCheckLatestJobId(String jobId)` Get check latest job id.
`List<String>`	`getChildrenKeys(String key)` Get node's sub-nodes list.
`String`	`getJobItemErrorMessage(String jobId, int shardingItem)` Get job item error msg.
`String`	`getJobItemProgress(String jobId, int shardingItem)` Get job item progress.
`String`	`getMetaDataDataSources(JobType jobType)` Get meta data data sources.
`String`	`getMetaDataProcessConfiguration(JobType jobType)` Get meta data process configuration.
`List<Integer>`	`getShardingItems(String jobId)` Get sharding items of job.
`boolean`	`isExisted(String key)` Whether key existing or not.
`Collection<String>`	`listCheckJobIds(String jobId)` List check job ids.
`void`	`persist(String key, String value)` Persist data.
`void`	`persistCheckJobResult(String jobId, String checkJobId, Map<String,DataConsistencyCheckResult> checkResultMap)` Persist check job result.
`void`	`persistCheckLatestJobId(String jobId, String checkJobId)` Persist check latest job id.
`void`	`persistJobItemProgress(String jobId, int shardingItem, String progressValue)` Persist job item progress.
`void`	`persistMetaDataDataSources(JobType jobType, String metaDataDataSources)` Persist meta data data sources.
`void`	`persistMetaDataProcessConfiguration(JobType jobType, String processConfigYamlText)` Persist meta data process configuration.
`void`	`watch(String key, org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEventListener listener)` Watch key or path of governance server.

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

- 构造器详细资料
  - GovernanceRepositoryAPIImpl
```
public GovernanceRepositoryAPIImpl()
```
- 方法详细资料
  - isExisted
```
public boolean isExisted(String key)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Whether key existing or not.
    
    指定者:
    
    isExisted 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    key - registry center key
    
    返回:
    
    true if job exists, else false
  - persistJobItemProgress
```
public void persistJobItemProgress(String jobId,
                                   int shardingItem,
                                   String progressValue)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Persist job item progress.
    
    指定者:
    
    persistJobItemProgress 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    shardingItem - sharding item
    
    progressValue - progress value
  - getJobItemProgress
```
public String getJobItemProgress(String jobId,
                                 int shardingItem)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Get job item progress.
    
    指定者:
    
    getJobItemProgress 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    shardingItem - sharding item
    
    返回:
    
    job item progress
  - getCheckLatestJobId
```
public Optional<String> getCheckLatestJobId(String jobId)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Get check latest job id.
    
    指定者:
    
    getCheckLatestJobId 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    返回:
    
    check job id
  - persistCheckLatestJobId
```
public void persistCheckLatestJobId(String jobId,
                                    String checkJobId)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Persist check latest job id.
    
    指定者:
    
    persistCheckLatestJobId 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    checkJobId - check job id
  - getCheckJobResult
```
public Map<String,DataConsistencyCheckResult> getCheckJobResult(String parentJobId,
                                                                String checkJobId)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Get check job result.
    
    指定者:
    
    getCheckJobResult 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    parentJobId - job id
    
    checkJobId - check job id
    
    返回:
    
    check job result
  - persistCheckJobResult
```
public void persistCheckJobResult(String jobId,
                                  String checkJobId,
                                  Map<String,DataConsistencyCheckResult> checkResultMap)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Persist check job result.
    
    指定者:
    
    persistCheckJobResult 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    checkJobId - check job id
    
    checkResultMap - check result map
  - deleteCheckJobResult
```
public void deleteCheckJobResult(String jobId,
                                 String checkJobId)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Delete check job result.
    
    指定者:
    
    deleteCheckJobResult 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    checkJobId - check job id
  - listCheckJobIds
```
public Collection<String> listCheckJobIds(String jobId)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    List check job ids.
    
    指定者:
    
    listCheckJobIds 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    返回:
    
    check job ids
  - deleteJob
```
public void deleteJob(String jobId)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Delete job.
    
    指定者:
    
    deleteJob 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
  - getChildrenKeys
```
public List<String> getChildrenKeys(String key)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Get node's sub-nodes list.
    
    指定者:
    
    getChildrenKeys 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    key - key of data
    
    返回:
    
    sub-nodes name list
  - watch
```
public void watch(String key,
                  org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEventListener listener)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Watch key or path of governance server.
    
    指定者:
    
    watch 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    key - key of data
    
    listener - data changed event listener
  - persist
```
public void persist(String key,
                    String value)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Persist data.
    
    指定者:
    
    persist 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    key - key of data
    
    value - value of data
  - getShardingItems
```
public List<Integer> getShardingItems(String jobId)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Get sharding items of job.
    
    指定者:
    
    getShardingItems 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    返回:
    
    sharding items
  - getMetaDataDataSources
```
public String getMetaDataDataSources(JobType jobType)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Get meta data data sources.
    
    指定者:
    
    getMetaDataDataSources 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobType - job type
    
    返回:
    
    data source properties
  - persistMetaDataDataSources
```
public void persistMetaDataDataSources(JobType jobType,
                                       String metaDataDataSources)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Persist meta data data sources.
    
    指定者:
    
    persistMetaDataDataSources 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobType - job type
    
    metaDataDataSources - data source properties
  - getMetaDataProcessConfiguration
```
public String getMetaDataProcessConfiguration(JobType jobType)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Get meta data process configuration.
    
    指定者:
    
    getMetaDataProcessConfiguration 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobType - job type, nullable
    
    返回:
    
    process configuration YAML text
  - persistMetaDataProcessConfiguration
```
public void persistMetaDataProcessConfiguration(JobType jobType,
                                                String processConfigYamlText)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Persist meta data process configuration.
    
    指定者:
    
    persistMetaDataProcessConfiguration 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobType - job type, nullable
    
    processConfigYamlText - process configuration YAML text
  - getJobItemErrorMessage
```
public String getJobItemErrorMessage(String jobId,
                                     int shardingItem)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Get job item error msg.
    
    指定者:
    
    getJobItemErrorMessage 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    shardingItem - sharding item
    
    返回:
    
    error msg
  - cleanJobItemErrorMessage
```
public void cleanJobItemErrorMessage(String jobId,
                                     int shardingItem)
```
    从接口复制的说明: GovernanceRepositoryAPI
    
    Clean job item error message.
    
    指定者:
    
    cleanJobItemErrorMessage 在接口中 GovernanceRepositoryAPI
    
    参数:
    
    jobId - job id
    
    shardingItem - sharding item

类 GovernanceRepositoryAPIImpl

构造器概要

方法概要

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

构造器详细资料

GovernanceRepositoryAPIImpl

方法详细资料

isExisted

persistJobItemProgress

getJobItemProgress

getCheckLatestJobId

persistCheckLatestJobId

getCheckJobResult

persistCheckJobResult

deleteCheckJobResult

listCheckJobIds

deleteJob

getChildrenKeys

watch

persist

getShardingItems

getMetaDataDataSources

persistMetaDataDataSources

getMetaDataProcessConfiguration

persistMetaDataProcessConfiguration

getJobItemErrorMessage

cleanJobItemErrorMessage