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

接口 IndividualProcessable<T,C extends AbstractJobExecutionShardingContext>

类型参数:

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

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

所有已知实现类:

AbstractIndividualDataFlowElasticJob, AbstractIndividualSequenceDataFlowElasticJob, AbstractIndividualThroughputDataFlowElasticJob, AbstractPerpetualElasticJob, AbstractSequencePerpetualElasticJob

public interface IndividualProcessable<T,C extends AbstractJobExecutionShardingContext>

逐条处理数据的接口.

作者:

zhangliang

方法概要

方法

限定符和类型	方法和说明
boolean	processData(C shardingContext, T data) 处理数据.

方法详细资料

processData

boolean processData(C shardingContext,
                  T data)

处理数据.

参数:

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

data - 待处理的数据

返回:

数据是否处理成功