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

接口 GovernanceRepositoryAPI

所有已知实现类:

GovernanceRepositoryAPIImpl

public interface GovernanceRepositoryAPI

Governance repository API.

方法概要

限定符和类型	方法和说明
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.

方法详细资料

isExisted

boolean isExisted(String key)

Whether key existing or not.

参数:

key - registry center key

返回:

true if job exists, else false

persistJobItemProgress

void persistJobItemProgress(String jobId,
                            int shardingItem,
                            String progressValue)

Persist job item progress.

参数:

jobId - job id

shardingItem - sharding item

progressValue - progress value

getJobItemProgress

String getJobItemProgress(String jobId,
                          int shardingItem)

Get job item progress.

参数:

jobId - job id

shardingItem - sharding item

返回:

job item progress

getCheckLatestJobId

Optional<String> getCheckLatestJobId(String jobId)

Get check latest job id.

参数:

jobId - job id

返回:

check job id

persistCheckLatestJobId

void persistCheckLatestJobId(String jobId,
                             String checkJobId)

Persist check latest job id.

参数:

jobId - job id

checkJobId - check job id

getCheckJobResult

Map<String,DataConsistencyCheckResult> getCheckJobResult(String parentJobId,
                                                         String checkJobId)

Get check job result.

参数:

parentJobId - job id

checkJobId - check job id

返回:

check job result

persistCheckJobResult

void persistCheckJobResult(String jobId,
                           String checkJobId,
                           Map<String,DataConsistencyCheckResult> checkResultMap)

Persist check job result.

参数:

jobId - job id

checkJobId - check job id

checkResultMap - check result map

deleteCheckJobResult

void deleteCheckJobResult(String jobId,
                          String checkJobId)

Delete check job result.

参数:

jobId - job id

checkJobId - check job id

listCheckJobIds

Collection<String> listCheckJobIds(String jobId)

List check job ids.

参数:

jobId - job id

返回:

check job ids

deleteJob

void deleteJob(String jobId)

Delete job.

参数:

jobId - job id

getChildrenKeys

List<String> getChildrenKeys(String key)

Get node's sub-nodes list.

参数:

key - key of data

返回:

sub-nodes name list

watch

void watch(String key,
           org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEventListener listener)

Watch key or path of governance server.

参数:

key - key of data

listener - data changed event listener

persist

void persist(String key,
             String value)

Persist data.

参数:

key - key of data

value - value of data

getShardingItems

List<Integer> getShardingItems(String jobId)

Get sharding items of job.

参数:

jobId - job id

返回:

sharding items

getMetaDataDataSources

String getMetaDataDataSources(JobType jobType)

Get meta data data sources.

参数:

jobType - job type

返回:

data source properties

persistMetaDataDataSources

void persistMetaDataDataSources(JobType jobType,
                                String metaDataDataSources)

Persist meta data data sources.

参数:

jobType - job type

metaDataDataSources - data source properties

getMetaDataProcessConfiguration

String getMetaDataProcessConfiguration(JobType jobType)

Get meta data process configuration.

参数:

jobType - job type, nullable

返回:

process configuration YAML text

persistMetaDataProcessConfiguration

void persistMetaDataProcessConfiguration(JobType jobType,
                                         String processConfigYamlText)

Persist meta data process configuration.

参数:

jobType - job type, nullable

processConfigYamlText - process configuration YAML text

getJobItemErrorMessage

String getJobItemErrorMessage(String jobId,
                              int shardingItem)

Get job item error msg.

参数:

jobId - job id

shardingItem - sharding item

返回:

error msg

cleanJobItemErrorMessage

void cleanJobItemErrorMessage(String jobId,
                              int shardingItem)

Clean job item error message.

参数:

jobId - job id

shardingItem - sharding item