com.dangdang.ddframe.job.internal.job.dataflow

类 AbstractDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>

java.lang.Object

com.dangdang.ddframe.job.internal.job.AbstractElasticJob

com.dangdang.ddframe.job.internal.job.dataflow.AbstractDataFlowElasticJob<T,C>

类型参数:

T - 数据流作业处理的数据实体类型

C - 作业运行时分片上下文类型

所有已实现的接口:

DataFlowElasticJob<T,C>, ElasticJob, org.quartz.Job

直接已知子类:

AbstractBatchDataFlowElasticJob, AbstractIndividualDataFlowElasticJob

public abstract class AbstractDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>
extends AbstractElasticJob
implements DataFlowElasticJob<T,C>

用于处理数据流程的作业抽象类.

作者:

zhangliang

构造器概要

构造器

构造器和说明
AbstractDataFlowElasticJob()

方法概要

方法

限定符和类型	方法和说明
protected void	executeJob(JobExecutionMultipleShardingContext shardingContext)
ExecutorService	getExecutorService() 获取线程执行服务.
void	handleJobExecutionException(org.quartz.JobExecutionException jobExecutionException) 处理作业执行时异常.
protected abstract void	processDataWithStatistics(C shardingContext, List<T> data)
void	updateOffset(int item, String offset) 更新数据处理位置.

从类继承的方法 com.dangdang.ddframe.job.internal.job.AbstractElasticJob

execute, setJobFacade

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

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

从接口继承的方法 com.dangdang.ddframe.job.api.DataFlowElasticJob

fetchData, isStreamingProcess

从接口继承的方法 org.quartz.Job

execute

构造器详细资料

AbstractDataFlowElasticJob

public AbstractDataFlowElasticJob()

方法详细资料

executeJob

protected final void executeJob(JobExecutionMultipleShardingContext shardingContext)

指定者:

executeJob 在类中 AbstractElasticJob

processDataWithStatistics

protected abstract void processDataWithStatistics(C shardingContext,
                             List<T> data)

updateOffset

public final void updateOffset(int item,
                String offset)

从接口复制的说明: DataFlowElasticJob

更新数据处理位置.

指定者:

updateOffset 在接口中 DataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>

参数:

item - 分片项

offset - 数据处理位置

getExecutorService

public ExecutorService getExecutorService()

从接口复制的说明: DataFlowElasticJob

获取线程执行服务.

指定者:

getExecutorService 在接口中 DataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>

handleJobExecutionException

public void handleJobExecutionException(org.quartz.JobExecutionException jobExecutionException)
                                 throws org.quartz.JobExecutionException

从接口复制的说明: ElasticJob

处理作业执行时异常.

指定者:

handleJobExecutionException 在接口中 ElasticJob

覆盖:

handleJobExecutionException 在类中 AbstractElasticJob

参数:

jobExecutionException - 作业执行时异常

抛出:

org.quartz.JobExecutionException - 作业执行时异常