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

类 GovernanceRepositoryAPIImpl

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()

方法概要

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

从类继承的方法 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

persistJobCheckResult

public void persistJobCheckResult(String jobId,
                                  boolean checkSuccess)

从接口复制的说明: GovernanceRepositoryAPI

Persist job check result.

指定者:

persistJobCheckResult 在接口中 GovernanceRepositoryAPI

参数:

jobId - job id

checkSuccess - check success

getJobCheckResult

public Optional<Boolean> getJobCheckResult(String jobId)

从接口复制的说明: GovernanceRepositoryAPI

Get job check result.

指定者:

getJobCheckResult 在接口中 GovernanceRepositoryAPI

参数:

jobId - job id

返回:

job check result

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