com.dangdang.ddframe.job.plugin.job.type.dataflow

类 AbstractIndividualSequenceDataFlowElasticJob<T>

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,JobExecutionSingleShardingContext>

com.dangdang.ddframe.job.plugin.job.type.dataflow.AbstractIndividualSequenceDataFlowElasticJob<T>

类型参数:

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

所有已实现的接口:

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

public abstract class AbstractIndividualSequenceDataFlowElasticJob<T>
extends AbstractIndividualDataFlowElasticJob<T,JobExecutionSingleShardingContext>

保证同一分片顺序性的逐条处理数据流程的作业.

作者:

zhangliang

构造器概要

构造器

构造器和说明
AbstractIndividualSequenceDataFlowElasticJob()

方法概要

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

processDataWithStatistics

从类继承的方法 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

构造器详细资料

AbstractIndividualSequenceDataFlowElasticJob

public AbstractIndividualSequenceDataFlowElasticJob()