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

类 AbstractIndividualDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>

java.lang.Object

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

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

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

类型参数:

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

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

所有已实现的接口:

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

直接已知子类:

AbstractIndividualSequenceDataFlowElasticJob, AbstractIndividualThroughputDataFlowElasticJob, AbstractPerpetualElasticJob, AbstractSequencePerpetualElasticJob

public abstract class AbstractIndividualDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>
extends AbstractDataFlowElasticJob<T,C>
implements IndividualProcessable<T,C>

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

作者:

zhangliang

构造器概要

构造器

构造器和说明
AbstractIndividualDataFlowElasticJob()

方法概要

方法

限定符和类型	方法和说明
protected void	processDataWithStatistics(C shardingContext, List<T> data)

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

executeJob, getExecutorService, handleJobExecutionException, updateOffset

从类继承的方法 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.internal.job.dataflow.IndividualProcessable

processData

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

fetchData, isStreamingProcess

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

execute

构造器详细资料

AbstractIndividualDataFlowElasticJob

public AbstractIndividualDataFlowElasticJob()

方法详细资料

processDataWithStatistics

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

指定者:

processDataWithStatistics 在类中 AbstractDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>