net.neoremind.fountain.changedata
类 ChangeDataSet

java.lang.Object
  net.neoremind.fountain.changedata.ChangeDataSet

所有已实现的接口：

BinlogTraceable

public class ChangeDataSet
extends Object
implements BinlogTraceable

描述变化的数据的数据结构，类似jdbc的RowsSet，包括元数据和数据变化。
元数据包括:

• 1）Global transaction id，简称gtid
• 2）数据来源，指代生产者标示instanceName和数据源IP:PORT
• 3）表schema描述,数据以Map<String,List<ColumnMeta>>的形式呈现，key表示表名，value是一个List，描述对应该表的数据,每一个元素是一个 ColumnMeta对象

数据变化包括:

• 数据以Map<String,List<RowData>>的形式呈现，key表示表名，value是一个List，描述对应该表的数据,每一个元素是一个 RowData对象，包括修改前后的数据详细信息。

作者：

zhangxu

构造方法摘要

ChangeDataSet()
构造方法

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

方法摘要

long	getBirthTime()
List<ColumnMeta>	getColumnMetaByFullTableName(String tableFullName) 根据表的全名获取列的信息,表的全名比如beidou.cproplan
int	getDataSize() 对象的size
BigInteger	getGtId()
String	getInstanceName() 生产者的实例
long	getSendTime()
String	getSrcDbHost()
SyncPoint	getSyncPoint() 同步点
Map<String,List<RowData>>	getTableData()
Map<String,List<ColumnMeta>>	getTableDef()
List<String>	getTableNameList() 获取所有的表名，表名为全名,比如beidou.cproplan
List<RowData>	getTableRowDatasByFullTableName(String tableFullName) 根据表的全名获取表的数据,表的全名比如beidou.cproplan
void	setBirthTime(long birthTime)
void	setDataSize(int dataSize)
void	setGtId(BigInteger gtId)
void	setInstanceName(String instanceName)
void	setSendTime(long sendTime)
void	setSrcDbHost(String srcDbHost)
void	setSyncPoint(SyncPoint syncPoint)
void	setTableData(Map<String,List<RowData>> tableData)
void	setTableDef(Map<String,List<ColumnMeta>> tableDef)
String	toString()

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

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

构造方法详细信息

ChangeDataSet

public ChangeDataSet()

构造方法

ChangeDataSet

public ChangeDataSet(SyncPoint syncPoint,
                     String instanceName)

构造方法

参数：

syncPoint - 同步点

instanceName - 生产者实例名称

方法详细信息

getColumnMetaByFullTableName

public List<ColumnMeta> getColumnMetaByFullTableName(String tableFullName)

根据表的全名获取列的信息,表的全名比如beidou.cproplan

参数：

tableFullName -

返回：

getTableRowDatasByFullTableName

public List<RowData> getTableRowDatasByFullTableName(String tableFullName)

根据表的全名获取表的数据,表的全名比如beidou.cproplan

参数：

tableFullName -

返回：

getTableNameList

public List<String> getTableNameList()

获取所有的表名，表名为全名,比如beidou.cproplan

返回：

toString

public String toString()

覆盖：

类 Object 中的 toString

getSyncPoint

public SyncPoint getSyncPoint()

从接口 BinlogTraceable 复制的描述

同步点

指定者：

接口 BinlogTraceable 中的 getSyncPoint

返回：

SyncPoint

getInstanceName

public String getInstanceName()

从接口 BinlogTraceable 复制的描述

生产者的实例

指定者：

接口 BinlogTraceable 中的 getInstanceName

返回：

string

setInstanceName

public void setInstanceName(String instanceName)

getDataSize

public int getDataSize()

从接口 BinlogTraceable 复制的描述

对象的size

指定者：

接口 BinlogTraceable 中的 getDataSize

返回：

int

setDataSize

public void setDataSize(int dataSize)

setSyncPoint

public void setSyncPoint(SyncPoint syncPoint)

getSrcDbHost

public String getSrcDbHost()

setSrcDbHost

public void setSrcDbHost(String srcDbHost)

getSendTime

public long getSendTime()

setSendTime

public void setSendTime(long sendTime)

getGtId

public BigInteger getGtId()

setGtId

public void setGtId(BigInteger gtId)

getTableDef

public Map<String,List<ColumnMeta>> getTableDef()

setTableDef

public void setTableDef(Map<String,List<ColumnMeta>> tableDef)

getTableData

public Map<String,List<RowData>> getTableData()

setTableData

public void setTableData(Map<String,List<RowData>> tableData)

getBirthTime

public long getBirthTime()

setBirthTime

public void setBirthTime(long birthTime)