net.neoremind.fountain.support
类 RowsLogEventCallback<T extends RowsLogEvent>

java.lang.Object
  继承者 net.neoremind.fountain.support.RowsLogEventCallback<T>
所有已实现的接口:
EventCallback<T>

public class RowsLogEventCallback<T extends RowsLogEvent>
extends Object
implements EventCallback<T>

RowsLogEvent事件回调器

主要针对百度MySQL Ares 5.1版本,在BinlogEventHeader中存在一个groupid,就是gtid,设置到TrxContext.currGtId中

作者:
zhangxu

构造方法摘要
RowsLogEventCallback()
           
 
方法摘要
 void handle(T event, TrxContext trxContext)
          在当前ThreadLocal上下文中处理某个event,一般的操作是根据event传输数据的内容设置context一些上下文
 
从类 java.lang.Object 继承的方法
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

构造方法详细信息

RowsLogEventCallback

public RowsLogEventCallback()
方法详细信息

handle

public void handle(T event,
                   TrxContext trxContext)
从接口 EventCallback 复制的描述
在当前ThreadLocal上下文中处理某个event,一般的操作是根据event传输数据的内容设置context一些上下文

指定者:
接口 EventCallback<T extends RowsLogEvent> 中的 handle
参数:
event - binglog事件
trxContext - 事务上下文


Copyright © 2016 neoremind. All rights reserved.