com.dangdang.ddframe.job.api

类 AbstractSequencePerpetualElasticJob<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.api.AbstractSequencePerpetualElasticJob<T>

类型参数:

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

所有已实现的接口:

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

已过时。

.

@Deprecated
public abstract class AbstractSequencePerpetualElasticJob<T>
extends AbstractIndividualDataFlowElasticJob<T,JobExecutionSingleShardingContext>

不断获取最新数据并保证同一分片顺序性的处理数据流程作业.

同一个分片用同一个线程处理, 保证顺序性和一致性, 类似kafka. 作业执行过程中不断的获取是否有新数据. 有新数据则作业一直不停止. 适用于流式数据处理.

包结构调整, 作业类型全部迁移至plugin包. 未来版本将删除, 请从旧版本升级的程序升级.

作者:

zhangliang

另请参阅:

AbstractIndividualDataFlowElasticJob

构造器概要

构造器

构造器和说明
AbstractSequencePerpetualElasticJob() 已过时。

方法概要

方法

限定符和类型	方法和说明
boolean	isStreamingProcess() 已过时。 配置是否流式处理数据.

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

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

execute

构造器详细资料

AbstractSequencePerpetualElasticJob

public AbstractSequencePerpetualElasticJob()

已过时。

方法详细资料

isStreamingProcess

public boolean isStreamingProcess()

已过时。

从接口复制的说明: DataFlowElasticJob

配置是否流式处理数据. 如果流式处理数据, 则fetchData不返回空结果将持续执行作业. 如果非流式处理数据, 则处理数据完成后作业结束.

返回:

是否流式处理数据