com.dangdang.ddframe.job.internal.config

类 ConfigurationService

java.lang.Object

com.dangdang.ddframe.job.internal.config.ConfigurationService

public class ConfigurationService
extends Object

弹性化分布式作业配置服务.

作者:

zhangliang

构造器概要

构造器

构造器和说明
ConfigurationService(CoordinatorRegistryCenter coordinatorRegistryCenter, JobConfiguration jobConfiguration)

方法概要

方法

限定符和类型	方法和说明
void	checkMaxTimeDiffSecondsTolerable() 检查本机与注册中心的时间误差秒数是否在允许范围.
int	getConcurrentDataProcessThreadCount() 获取同时处理数据的并发线程数.
String	getCron() 获取作业启动时间的cron表达式.
int	getFetchDataCount() 获取每次抓取的数据量.
String	getJobName() 获取作业名称.
String	getJobParameter() 获取作业自定义参数.
String	getJobShardingStrategyClass() 获取作业分片策略实现类全路径.
int	getMonitorPort() 获取作业监控端口.
int	getProcessCountIntervalSeconds() 获取统计作业处理数据数量的间隔时间.
Map<Integer,String>	getShardingItemParameters() 获取分片序列号和个性化参数对照表.
int	getShardingTotalCount() 获取作业分片总数.
boolean	isFailover() 获取是否开启失效转移.
boolean	isMisfire() 获取是否开启misfire.
boolean	isMonitorExecution() 获取是否监控作业运行时状态.
void	persistJobConfiguration() 持久化分布式作业配置信息.

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ConfigurationService

public ConfigurationService(CoordinatorRegistryCenter coordinatorRegistryCenter,
                    JobConfiguration jobConfiguration)

方法详细资料

persistJobConfiguration

public void persistJobConfiguration()

持久化分布式作业配置信息.

getShardingTotalCount

public int getShardingTotalCount()

获取作业分片总数.

返回:

作业分片总数

getShardingItemParameters

public Map<Integer,String> getShardingItemParameters()

获取分片序列号和个性化参数对照表.

返回:

分片序列号和个性化参数对照表

getJobParameter

public String getJobParameter()

获取作业自定义参数.

返回:

作业自定义参数

getCron

public String getCron()

获取作业启动时间的cron表达式.

返回:

作业启动时间的cron表达式

isMonitorExecution

public boolean isMonitorExecution()

获取是否监控作业运行时状态.

返回:

是否监控作业运行时状态

getProcessCountIntervalSeconds

public int getProcessCountIntervalSeconds()

获取统计作业处理数据数量的间隔时间.

返回:

统计作业处理数据数量的间隔时间

getConcurrentDataProcessThreadCount

public int getConcurrentDataProcessThreadCount()

获取同时处理数据的并发线程数.

不能小于1. 仅ThroughputDataFlow作业有效.

返回:

同时处理数据的并发线程数

getFetchDataCount

public int getFetchDataCount()

获取每次抓取的数据量.

返回:

每次抓取的数据量

checkMaxTimeDiffSecondsTolerable

public void checkMaxTimeDiffSecondsTolerable()

检查本机与注册中心的时间误差秒数是否在允许范围.

isFailover

public boolean isFailover()

获取是否开启失效转移.

返回:

是否开启失效转移

isMisfire

public boolean isMisfire()

获取是否开启misfire.

返回:

是否开启misfire

getJobShardingStrategyClass

public String getJobShardingStrategyClass()

获取作业分片策略实现类全路径.

返回:

作业分片策略实现类全路径

getMonitorPort

public int getMonitorPort()

获取作业监控端口.

返回:

作业监控端口

getJobName

public String getJobName()

获取作业名称.

返回:

作业名称