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

接口 GovernanceRepositoryAPI

所有已知实现类:

GovernanceRepositoryAPIImpl

public interface GovernanceRepositoryAPI

Governance repository API.

方法概要

限定符和类型	方法和说明
void	deleteJob(String jobId) Delete job.
List<String>	getChildrenKeys(String key) Get node's sub-nodes list.
Optional<Boolean>	getJobCheckResult(String jobId) Get job check result.
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.
void	persist(String key, String value) Persist data.
void	persistJobCheckResult(String jobId, boolean checkSuccess) Persist job check result.
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

persistJobCheckResult

void persistJobCheckResult(String jobId,
                           boolean checkSuccess)

Persist job check result.

参数:

jobId - job id

checkSuccess - check success

getJobCheckResult

Optional<Boolean> getJobCheckResult(String jobId)

Get job check result.

参数:

jobId - job id

返回:

job check result

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