T - 数据流作业处理的数据实体类型C - 作业运行时分片上下文类型public interface DataFlowElasticJob<T,C extends AbstractJobExecutionShardingContext> extends ElasticJob
| 限定符和类型 | 方法和说明 |
|---|---|
List<T> |
fetchData(C shardingContext)
获取待处理的数据.
|
ExecutorService |
getExecutorService()
获取线程执行服务.
|
boolean |
isStreamingProcess()
配置是否流式处理数据.
|
void |
updateOffset(int item,
String offset)
更新数据处理位置.
|
handleJobExecutionExceptionList<T> fetchData(C shardingContext)
shardingContext - 作业分片规则配置上下文boolean isStreamingProcess()
void updateOffset(int item,
String offset)
item - 分片项offset - 数据处理位置ExecutorService getExecutorService()
Copyright © 2016. All rights reserved.