net.wicp.tams.commons.binlog.event

类 AbsEvent

java.lang.Object

net.wicp.tams.commons.binlog.event.AbsEvent

所有已实现的接口:

IEventRead

直接已知子类:

FormatDescription, GtidEvent, ParserNo, QueryEvent, RotateEvent, RowsEvent, StopEvent, TableMapEvent, XidEvent

public abstract class AbsEvent
extends Object
implements IEventRead

字段概要

字段

限定符和类型	字段和说明
protected int	curpos
protected EventBean	event
protected byte[]	eventbytes
static ThreadLocal<Host>	hosts

构造器概要

构造器

构造器和说明
AbsEvent(EventBean event)

方法概要

方法

限定符和类型	方法和说明
protected boolean	hasMore()
protected ICol	paseCol(ColumnType colType, String colName, int meta, boolean isnull)
protected byte	readByte()
protected byte[]	readRest() 读剩余字节
protected byte[]	readSubByte(int length)
UnsignedLong	readUnsignedLong() 首个字节的值小于251用一个byte存储，如果值大于251，fc + 2-byte ，fd + 3-byte integer，fe + 8-byte
static String	row(Integer num)
static String	row(Long num)
void	rowlog(String info)
protected void	skip(int length)

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

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

从接口继承的方法 net.wicp.tams.commons.binlog.IEventRead

parseBody

字段详细资料

event

protected final EventBean event

eventbytes

protected byte[] eventbytes

curpos

protected int curpos

hosts

public static ThreadLocal<Host> hosts

构造器详细资料

AbsEvent

public AbsEvent(EventBean event)

方法详细资料

readSubByte

protected byte[] readSubByte(int length)

hasMore

protected boolean hasMore()

readByte

protected byte readByte()

skip

protected void skip(int length)

readRest

protected byte[] readRest()

读剩余字节

返回:

readUnsignedLong

public UnsignedLong readUnsignedLong()

首个字节的值小于251用一个byte存储，如果值大于251，fc + 2-byte ，fd + 3-byte integer，fe + 8-byte

返回:

rowlog

public void rowlog(String info)

paseCol

protected ICol paseCol(ColumnType colType,
           String colName,
           int meta,
           boolean isnull)

row

public static String row(Long num)

row

public static String row(Integer num)