com.dangdang.ddframe.job.internal.offset

类 OffsetService

java.lang.Object

com.dangdang.ddframe.job.internal.offset.OffsetService

public class OffsetService
extends Object

数据处理位置服务.

作者:

zhangliang

构造器概要

构造器

构造器和说明
OffsetService(CoordinatorRegistryCenter coordinatorRegistryCenter, JobConfiguration jobConfiguration)

方法概要

方法

限定符和类型	方法和说明
Map<Integer,String>	getOffsets(List<Integer> items) 获取数据分片项和数据处理位置Map.
void	updateOffset(int item, String offset) 更新数据处理位置.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

OffsetService

public OffsetService(CoordinatorRegistryCenter coordinatorRegistryCenter,
             JobConfiguration jobConfiguration)

方法详细资料

updateOffset

public void updateOffset(int item,
                String offset)

更新数据处理位置.

参数:

item - 分片项

offset - 数据处理位置

getOffsets

public Map<Integer,String> getOffsets(List<Integer> items)

获取数据分片项和数据处理位置Map.

参数:

items - 分片项集合

返回:

数据分片项和数据处理位置Map