T - 数据流作业处理的数据实体类型C - 作业运行时分片上下文类型public abstract class AbstractDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext> extends AbstractElasticJob implements DataFlowElasticJob<T,C>
| 构造器和说明 |
|---|
AbstractDataFlowElasticJob() |
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
executeJob(JobExecutionMultipleShardingContext shardingContext) |
ExecutorService |
getExecutorService()
获取线程执行服务.
|
void |
handleJobExecutionException(org.quartz.JobExecutionException jobExecutionException)
处理作业执行时异常.
|
protected abstract void |
processDataWithStatistics(C shardingContext,
List<T> data) |
void |
updateOffset(int item,
String offset)
更新数据处理位置.
|
execute, setJobFacadeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitfetchData, isStreamingProcessprotected final void executeJob(JobExecutionMultipleShardingContext shardingContext)
executeJob 在类中 AbstractElasticJobprotected abstract void processDataWithStatistics(C shardingContext, List<T> data)
public final void updateOffset(int item,
String offset)
DataFlowElasticJobupdateOffset 在接口中 DataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>item - 分片项offset - 数据处理位置public ExecutorService getExecutorService()
DataFlowElasticJobgetExecutorService 在接口中 DataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>public void handleJobExecutionException(org.quartz.JobExecutionException jobExecutionException)
throws org.quartz.JobExecutionException
ElasticJobhandleJobExecutionException 在接口中 ElasticJobhandleJobExecutionException 在类中 AbstractElasticJobjobExecutionException - 作业执行时异常org.quartz.JobExecutionException - 作业执行时异常Copyright © 2016. All rights reserved.