接口 net.neoremind.fountain.eventposition.SyncPoint
的使用

使用 SyncPoint 的软件包

net.neoremind.fountain.changedata
net.neoremind.fountain.eventposition
net.neoremind.fountain.eventposition.factory
net.neoremind.fountain.support

net.neoremind.fountain.changedata 中 SyncPoint 的使用

返回 SyncPoint 的 net.neoremind.fountain.changedata 中的方法

SyncPoint	ChangeDataSet.getSyncPoint()
SyncPoint	BinlogTraceable.getSyncPoint() 同步点

参数类型为 SyncPoint 的 net.neoremind.fountain.changedata 中的方法

void	ChangeDataSet.setSyncPoint(SyncPoint syncPoint)

参数类型为 SyncPoint 的 net.neoremind.fountain.changedata 中的构造方法

ChangeDataSet(SyncPoint syncPoint, String instanceName)
构造方法

net.neoremind.fountain.eventposition 中 SyncPoint 的使用

net.neoremind.fountain.eventposition 中 SyncPoint 的子接口

interface

GroupIdSyncPoint 支持groupId SyncPoint

实现 SyncPoint 的 net.neoremind.fountain.eventposition 中的类

class	BaiduGroupIdSyncPoint 描述百度mysql分支的group id
class	BinlogAndOffsetSyncPoint 描述传统row base binlog同步点
class	GtIdSyncPoint 描述MySQL5.6版本的gtid同步点

返回 SyncPoint 的 net.neoremind.fountain.eventposition 中的方法

protected SyncPoint	LocalFileGtIdSetDisposeEventPosition.createSyncPoint()
protected SyncPoint	LocalFileDisposeEventPosition.createSyncPoint() 构建SyncPoint对象，继承类可以override该方法
protected SyncPoint	LocalFileBinlogAndOffsetDisposeEventPosition.createSyncPoint()
SyncPoint	LocalFileDisposeEventPosition.loadSyncPoint()
SyncPoint	DisposeEventPosition.loadSyncPoint() 加载同步点
SyncPoint	AsyncFixedRateDisposeEventPosition.loadSyncPoint() 这里简化下从prev中获取
SyncPoint	AbstractProxyDisposeEventPosition.loadSyncPoint()

参数类型为 SyncPoint 的 net.neoremind.fountain.eventposition 中的方法

BinlogAndOffsetSyncPoint	EventPositionExtender.extend(SyncPoint groupIdPoint, MysqlDataSource dataSource) 从给定的数据源中读取与global transaction id有关的信息,比如binlog file name和position用于同步
boolean	GroupIdSyncPoint.isSame(SyncPoint syncPoint) 和指定的SyncPoint是否相同
boolean	BaiduGroupIdSyncPoint.isSame(SyncPoint syncPoint)
void	ReadonlyDisposeEventPosition.saveSyncPoint(SyncPoint point)
void	LocalFileDisposeEventPosition.saveSyncPoint(SyncPoint point)
void	DisposeEventPosition.saveSyncPoint(SyncPoint point) 保存同步点
void	DelayGtIdDisposeEventPosition.saveSyncPoint(SyncPoint point)
void	DelayGroupIdDisposeEventPosition.saveSyncPoint(SyncPoint point)
void	AsyncFixedRateDisposeEventPosition.saveSyncPoint(SyncPoint point)

net.neoremind.fountain.eventposition.factory 中 SyncPoint 的使用

返回 SyncPoint 的 net.neoremind.fountain.eventposition.factory 中的方法

SyncPoint	SyncPointFactory.factory() 生成SyncPoint
SyncPoint	GtIdSyncPointFactory.factory()
SyncPoint	BinlogAndOffsetSyncPointFactory.factory()
SyncPoint	BaiduGroupIdSyncPointFactory.factory()

net.neoremind.fountain.support 中 SyncPoint 的使用

类型参数类型为 SyncPoint 的 net.neoremind.fountain.support 中的字段

static ThreadLocal<SyncPoint>

ThreadHolder.SYNC_POINT_CACHE SyncPoint的内存缓存，缓存当producer中已经接收到的最后的SyncPoint，当数据源不可用并选择新的数据源时 直接使用该SyncPoint继续接收。