net.neoremind.fountain.rowbaselog.event
类 BinlogEventHeader

java.lang.Object
  继承者 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader
所有已实现的接口:
EventHeader

public class BinlogEventHeader
extends Object
implements EventHeader

MySQL binglog header

对于一个binlog event来说,它分为三个部分,header,post-header以及payload。 实际处理event的时候,把post-header和payload当成了一个整体body。

MySQL的binlog event有很多版本,这里只支持version 4的,也就是从MySQL 5.1.x之后支持的版本。

从以下版本开始:
2013-7-15
作者:
hanxu03, zhangxu
另请参见:
binlog-event-header

构造方法摘要
BinlogEventHeader(int extraHeadersLength)
          构造方法
 
方法摘要
 int getEventLength()
           
 byte[] getExtraHeaders()
           
 int getFlags()
           
 BigInteger getGroupId()
           
 long getNextPosition()
           
 int getServerId()
           
 long getTimestamp()
           
 byte getTypeCode()
           
 void parseHeader(ByteBuffer buff)
           
 void setEventLength(int eventLength)
           
 void setExtraHeaders(byte[] extraHeaders)
           
 void setFlags(int flags)
           
 void setNextPosition(long nextPosition)
           
 void setServerId(int serverId)
           
 void setTimestamp(long timestamp)
           
 void setTypeCode(byte typeCode)
           
 
从类 java.lang.Object 继承的方法
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

构造方法详细信息

BinlogEventHeader

public BinlogEventHeader(int extraHeadersLength)
构造方法

参数:
extraHeadersLength -
方法详细信息

getTimestamp

public long getTimestamp()
指定者:
接口 EventHeader 中的 getTimestamp

setTimestamp

public void setTimestamp(long timestamp)

getTypeCode

public byte getTypeCode()

setTypeCode

public void setTypeCode(byte typeCode)

getServerId

public int getServerId()

setServerId

public void setServerId(int serverId)

getEventLength

public int getEventLength()

setEventLength

public void setEventLength(int eventLength)

getNextPosition

public long getNextPosition()

setNextPosition

public void setNextPosition(long nextPosition)

getFlags

public int getFlags()

setFlags

public void setFlags(int flags)

getExtraHeaders

public byte[] getExtraHeaders()

setExtraHeaders

public void setExtraHeaders(byte[] extraHeaders)

getGroupId

public BigInteger getGroupId()
指定者:
接口 EventHeader 中的 getGroupId

parseHeader

public void parseHeader(ByteBuffer buff)
指定者:
接口 EventHeader 中的 parseHeader


Copyright © 2016 neoremind. All rights reserved.