net.neoremind.fountain.eventposition
类 DelayGtIdDisposeEventPosition

java.lang.Object
  net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition
      net.neoremind.fountain.eventposition.DelayGtIdDisposeEventPosition

所有已实现的接口：

DisposeEventPosition

public class DelayGtIdDisposeEventPosition
extends AbstractProxyDisposeEventPosition
implements DisposeEventPosition

不用延迟直接存储GtId，针对MySQL5.6本身会Server，fountain会传递自己的executed gtid set，以GtIdSet中的GtId.intervalStart和 GtId.intervalEnd表示，这里面GtId.intervalEnd是个开区间，最后一个点会重新下发。

作者：

zhangxu

另请参见：

GtIdSyncPoint

字段摘要

从类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 继承的字段

delegate

构造方法摘要

DelayGtIdDisposeEventPosition()

方法摘要

void	registerInstance(String insName) 注册生产者实例的名称,在采用文件保存gt id时会使用该name作为文件名称
void	saveSyncPoint(SyncPoint point) 保存同步点
void	setDisposeEventPositionBridge(DisposeEventPositionBridge disposeEventPositionBridge)

从类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 继承的方法

getDelegate, loadSyncPoint, setDelegate

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

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

从接口 net.neoremind.fountain.eventposition.DisposeEventPosition 继承的方法

loadSyncPoint

构造方法详细信息

DelayGtIdDisposeEventPosition

public DelayGtIdDisposeEventPosition()

方法详细信息

saveSyncPoint

public void saveSyncPoint(SyncPoint point)

从接口 DisposeEventPosition 复制的描述

保存同步点

指定者：

接口 DisposeEventPosition 中的 saveSyncPoint

参数：

point - SyncPoint

registerInstance

public void registerInstance(String insName)

从接口 DisposeEventPosition 复制的描述

注册生产者实例的名称,在采用文件保存gt id时会使用该name作为文件名称

指定者：

接口 DisposeEventPosition 中的 registerInstance

覆盖：

类 AbstractProxyDisposeEventPosition 中的 registerInstance

参数：

insName - producer实例名称

setDisposeEventPositionBridge

public void setDisposeEventPositionBridge(DisposeEventPositionBridge disposeEventPositionBridge)