net.neoremind.fountain.eventposition
类 BinlogAndOffsetSyncPoint

java.lang.Object
  net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint

所有已实现的接口：

SyncPoint

public class BinlogAndOffsetSyncPoint
extends Object
implements SyncPoint

描述传统row base binlog同步点

作者：

hexiufeng

嵌套类摘要

static class

BinlogAndOffsetSyncPoint.MysqlSyncPoint 描述传统的mysql的同步点

构造方法摘要

BinlogAndOffsetSyncPoint()
无参数构造方法

BinlogAndOffsetSyncPoint(List<BinlogAndOffsetSyncPoint.MysqlSyncPoint> syncPointGroup)
有参数构造反复

方法摘要

void	addSyncPoint(String host, int port, String binlogName, BigInteger offset) 增加sync point
BinlogAndOffsetSyncPoint.MysqlSyncPoint	getPointByHostAndPort(String host, int port) 根据host和port获取MysqlSyncPoint对象，使用MysqlSyncPoint中的binlogname和offset来同步数据
BinlogAndOffsetSyncPoint.MysqlSyncPoint	getPointByHostAndPort(String host, String ip, int port) 根据host或者ip和port获取MysqlSyncPoint对象，使用MysqlSyncPoint中的binlogname和offset来同步数据
List<BinlogAndOffsetSyncPoint.MysqlSyncPoint>	getSyncPointGroup()
void	parse(byte[] buf) 转换数组为同步点对象
byte[]	toBytes() convert 同步点对象为byte数组
String	toString()

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

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

构造方法详细信息

BinlogAndOffsetSyncPoint

public BinlogAndOffsetSyncPoint()

无参数构造方法

BinlogAndOffsetSyncPoint

public BinlogAndOffsetSyncPoint(List<BinlogAndOffsetSyncPoint.MysqlSyncPoint> syncPointGroup)

有参数构造反复

参数：

syncPointGroup - MysqlSyncPoint list

方法详细信息

getPointByHostAndPort

public BinlogAndOffsetSyncPoint.MysqlSyncPoint getPointByHostAndPort(String host,
                                                                     String ip,
                                                                     int port)

根据host或者ip和port获取MysqlSyncPoint对象，使用MysqlSyncPoint中的binlogname和offset来同步数据

参数：

host - host

ip - ip

port - port

返回：

MysqlSyncPoint

getPointByHostAndPort

public BinlogAndOffsetSyncPoint.MysqlSyncPoint getPointByHostAndPort(String host,
                                                                     int port)

根据host和port获取MysqlSyncPoint对象，使用MysqlSyncPoint中的binlogname和offset来同步数据

参数：

host - host

port - port

返回：

MysqlSyncPoint

addSyncPoint

public void addSyncPoint(String host,
                         int port,
                         String binlogName,
                         BigInteger offset)

增加sync point

参数：

host - host

port - port

binlogName - binlog file name

offset - binlog file内偏移地址

toBytes

public byte[] toBytes()

从接口 SyncPoint 复制的描述

convert 同步点对象为byte数组

指定者：

接口 SyncPoint 中的 toBytes

返回：

byte array

toString

public String toString()

覆盖：

类 Object 中的 toString

parse

public void parse(byte[] buf)

从接口 SyncPoint 复制的描述

转换数组为同步点对象

指定者：

接口 SyncPoint 中的 parse

参数：

buf - 同步点数组

getSyncPointGroup

public List<BinlogAndOffsetSyncPoint.MysqlSyncPoint> getSyncPointGroup()