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

类 AbstractBatchSequenceDataFlowElasticJob<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.AbstractBatchDataFlowElasticJob<T,JobExecutionSingleShardingContext>

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

类型参数:

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

所有已实现的接口:

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

public abstract class AbstractBatchSequenceDataFlowElasticJob<T>
extends AbstractBatchDataFlowElasticJob<T,JobExecutionSingleShardingContext>

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

作者:

zhangliang

构造器概要

构造器

构造器和说明
AbstractBatchSequenceDataFlowElasticJob()

方法概要

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

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.BatchProcessable

processData

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

fetchData, isStreamingProcess

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

execute

构造器详细资料

AbstractBatchSequenceDataFlowElasticJob

public AbstractBatchSequenceDataFlowElasticJob()