com.dangdang.ddframe.job.internal.schedule

类 JobFacade

java.lang.Object

com.dangdang.ddframe.job.internal.schedule.JobFacade

public class JobFacade
extends Object

为调度器提供内部服务的门面类.

作者:

zhangliang

构造器概要

构造器

构造器和说明
JobFacade(CoordinatorRegistryCenter coordinatorRegistryCenter, JobConfiguration jobConfiguration, List<ElasticJobListener> elasticJobListeners)

方法概要

方法

限定符和类型	方法和说明
void	afterJobExecuted(JobExecutionMultipleShardingContext shardingContext) 作业执行后的执行的方法.
void	beforeJobExecuted(JobExecutionMultipleShardingContext shardingContext) 作业执行前的执行的方法.
void	checkMaxTimeDiffSecondsTolerable() 检查本机与注册中心的时间误差秒数是否在允许范围.
void	clearMisfire(List<Integer> shardingItems) 清除任务被错过执行的标记.
void	failoverIfNecessary() 如果需要失效转移, 则设置作业失效转移.
int	getConcurrentDataProcessThreadCount() 获取同时处理数据的并发线程数.
String	getJobName() 获取作业名称.
JobExecutionMultipleShardingContext	getShardingContext() 获取当前作业服务器运行时分片上下文.
boolean	isEligibleForJobRunning() 判断作业是否符合继续运行的条件.
boolean	isExecuteMisfired(List<Integer> shardingItems) 判断作业是否需要执行错过的任务.
boolean	isNeedSharding() 判断是否需要重分片.
boolean	misfireIfNecessary(List<Integer> shardingItems) 设置任务被错过执行的标记.
void	registerJobBegin(JobExecutionMultipleShardingContext shardingContext) 注册作业启动信息.
void	registerJobCompleted(JobExecutionMultipleShardingContext shardingContext) 注册作业完成信息.
void	updateOffset(int item, String offset) 更新数据处理位置.

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

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

构造器详细资料

JobFacade

public JobFacade(CoordinatorRegistryCenter coordinatorRegistryCenter,
         JobConfiguration jobConfiguration,
         List<ElasticJobListener> elasticJobListeners)

方法详细资料

getJobName

public String getJobName()

获取作业名称.

返回:

作业名称

getConcurrentDataProcessThreadCount

public int getConcurrentDataProcessThreadCount()

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

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

返回:

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

checkMaxTimeDiffSecondsTolerable

public void checkMaxTimeDiffSecondsTolerable()

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

failoverIfNecessary

public void failoverIfNecessary()

如果需要失效转移, 则设置作业失效转移.

registerJobBegin

public void registerJobBegin(JobExecutionMultipleShardingContext shardingContext)

注册作业启动信息.

参数:

shardingContext - 作业运行时分片上下文

registerJobCompleted

public void registerJobCompleted(JobExecutionMultipleShardingContext shardingContext)

注册作业完成信息.

参数:

shardingContext - 作业运行时分片上下文

getShardingContext

public JobExecutionMultipleShardingContext getShardingContext()

获取当前作业服务器运行时分片上下文.

返回:

当前作业服务器运行时分片上下文

misfireIfNecessary

public boolean misfireIfNecessary(List<Integer> shardingItems)

设置任务被错过执行的标记.

参数:

shardingItems - 需要设置错过执行的任务分片项

返回:

是否满足misfire条件

clearMisfire

public void clearMisfire(List<Integer> shardingItems)

清除任务被错过执行的标记.

参数:

shardingItems - 需要清除错过执行的任务分片项

isExecuteMisfired

public boolean isExecuteMisfired(List<Integer> shardingItems)

判断作业是否需要执行错过的任务.

参数:

shardingItems - 任务分片项集合

返回:

作业是否需要执行错过的任务

isEligibleForJobRunning

public boolean isEligibleForJobRunning()

判断作业是否符合继续运行的条件.

如果作业停止或需要重分片则作业将不会继续运行.

返回:

作业是否符合继续运行的条件

isNeedSharding

public boolean isNeedSharding()

判断是否需要重分片.

返回:

是否需要重分片

updateOffset

public void updateOffset(int item,
                String offset)

更新数据处理位置.

参数:

item - 分片项

offset - 数据处理位置

beforeJobExecuted

public void beforeJobExecuted(JobExecutionMultipleShardingContext shardingContext)

作业执行前的执行的方法.

参数:

shardingContext - 分片上下文

afterJobExecuted

public void afterJobExecuted(JobExecutionMultipleShardingContext shardingContext)

作业执行后的执行的方法.

参数:

shardingContext - 分片上下文