T - 数据流作业处理的数据实体类型C - 作业运行时分片上下文类型public abstract class AbstractIndividualDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext> extends AbstractDataFlowElasticJob<T,C> implements IndividualProcessable<T,C>
| 构造器和说明 |
|---|
AbstractIndividualDataFlowElasticJob() |
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
processDataWithStatistics(C shardingContext,
List<T> data) |
executeJob, getExecutorService, handleJobExecutionException, updateOffsetexecute, setJobFacadeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprocessDatafetchData, isStreamingProcessprotected final void processDataWithStatistics(C shardingContext, List<T> data)
processDataWithStatistics 在类中 AbstractDataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext>Copyright © 2016. All rights reserved.