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

接口 BatchProcessable<T,C extends AbstractJobExecutionShardingContext>

类型参数:

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

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

所有已知实现类:

AbstractBatchDataFlowElasticJob, AbstractBatchSequenceDataFlowElasticJob, AbstractBatchThroughputDataFlowElasticJob

public interface BatchProcessable<T,C extends AbstractJobExecutionShardingContext>

批量处理数据的接口.

作者:

zhangliang

方法概要

方法

限定符和类型	方法和说明
int	processData(C shardingContext, List<T> data) 批量处理数据.

方法详细资料

processData

int processData(C shardingContext,
              List<T> data)

批量处理数据.

参数:

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

data - 待处理的数据集合

返回:

成功处理的数据数