com.taobao.tddl.dbsync.binlog

类 LogDecoder

java.lang.Object

com.taobao.tddl.dbsync.binlog.LogDecoder

public final class LogDecoder
extends java.lang.Object

Implements a binary-log decoder.

 LogDecoder decoder = new LogDecoder();
 decoder.handle(...);
 
 LogEvent event;
 do
 {
     event = decoder.decode(buffer, context);
 
     // process log event.
 }
 while (event != null);
 // no more events in buffer.
 

版本:

1.0

作者:

Changyuan.lh

字段概要

字段

限定符和类型	字段和说明
protected java.util.BitSet	handleSet
protected static org.apache.commons.logging.Log	logger

构造器概要

构造器

构造器和说明
LogDecoder()
LogDecoder(int fromIndex, int toIndex)

方法概要

限定符和类型	方法和说明
LogEvent	decode(LogBuffer buffer, LogContext context) Decoding an event from binary-log buffer.
static LogEvent	decode(LogBuffer buffer, LogHeader header, LogContext context) Deserialize an event from buffer.
void	handle(int flagIndex)
void	handle(int fromIndex, int toIndex)

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

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

字段详细资料

logger

protected static final org.apache.commons.logging.Log logger

handleSet

protected final java.util.BitSet handleSet

构造器详细资料

LogDecoder

public LogDecoder()

LogDecoder

public LogDecoder(int fromIndex,
                  int toIndex)

方法详细资料

handle

public final void handle(int fromIndex,
                         int toIndex)

handle

public final void handle(int flagIndex)

decode

public LogEvent decode(LogBuffer buffer,
                       LogContext context)
                throws java.io.IOException

Decoding an event from binary-log buffer.

返回:

UknownLogEvent if event type is unknown or skipped, null if buffer is not including a full event.

抛出:

java.io.IOException

decode

public static LogEvent decode(LogBuffer buffer,
                              LogHeader header,
                              LogContext context)
                       throws java.io.IOException

Deserialize an event from buffer.

返回:

UknownLogEvent if event type is unknown or skipped.

抛出:

java.io.IOException