com.dangdang.ddframe.job.api

接口 DataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>

类型参数:

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

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

所有超级接口:

ElasticJob, org.quartz.Job

所有已知实现类:

AbstractBatchDataFlowElasticJob, AbstractBatchSequenceDataFlowElasticJob, AbstractBatchThroughputDataFlowElasticJob, AbstractDataFlowElasticJob, AbstractIndividualDataFlowElasticJob, AbstractIndividualSequenceDataFlowElasticJob, AbstractIndividualThroughputDataFlowElasticJob, AbstractPerpetualElasticJob, AbstractSequencePerpetualElasticJob

public interface DataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>
extends ElasticJob

保用于处理数据流程的作业接口.

作者:

zhangliang

方法概要

方法

限定符和类型	方法和说明
List<T>	fetchData(C shardingContext) 获取待处理的数据.
ExecutorService	getExecutorService() 获取线程执行服务.
boolean	isStreamingProcess() 配置是否流式处理数据.
void	updateOffset(int item, String offset) 更新数据处理位置.

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

handleJobExecutionException

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

execute

方法详细资料

fetchData

List<T> fetchData(C shardingContext)

获取待处理的数据.

参数:

shardingContext - 作业分片规则配置上下文

返回:

待处理的数据集合

isStreamingProcess

boolean isStreamingProcess()

配置是否流式处理数据. 如果流式处理数据, 则fetchData不返回空结果将持续执行作业. 如果非流式处理数据, 则处理数据完成后作业结束.

返回:

是否流式处理数据

updateOffset

void updateOffset(int item,
                String offset)

更新数据处理位置.

参数:

item - 分片项

offset - 数据处理位置

getExecutorService

ExecutorService getExecutorService()

获取线程执行服务.