Package com.zendesk.maxwell.replication

Class BinlogConnectorEvent

java.lang.Object

com.zendesk.maxwell.replication.BinlogConnectorEvent

public class BinlogConnectorEvent
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	BEGIN
static String	COMMIT
static String	SAVEPOINT

Constructor Summary

Constructors

Constructor	Description
BinlogConnectorEvent(com.github.shyiko.mysql.binlog.event.Event event, String filename, String gtidSetStr, String gtid, MaxwellOutputConfig outputConfig)

Method Summary

Modifier and Type	Method	Description
com.github.shyiko.mysql.binlog.event.DeleteRowsEventData	deleteRowsData()
com.github.shyiko.mysql.binlog.event.Event	getEvent()
BinlogPosition	getNextPosition()
BinlogPosition	getPosition()
Long	getTableID()
com.github.shyiko.mysql.binlog.event.EventType	getType()
boolean	isCommitEvent()
List<RowMap>	jsonMaps(Table table, long lastHeartbeatRead, String rowQuery)
com.github.shyiko.mysql.binlog.event.MariadbGtidEventData	mariaGtidData()
com.github.shyiko.mysql.binlog.event.QueryEventData	queryData()
com.github.shyiko.mysql.binlog.event.TableMapEventData	tableMapData()
com.github.shyiko.mysql.binlog.event.UpdateRowsEventData	updateRowsData()
com.github.shyiko.mysql.binlog.event.WriteRowsEventData	writeRowsData()
com.github.shyiko.mysql.binlog.event.XidEventData	xidData()

Methods inherited from class java.lang.Object

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

Field Detail

BEGIN

public static final String BEGIN

See Also:

Constant Field Values

COMMIT

public static final String COMMIT

See Also:

Constant Field Values

SAVEPOINT

public static final String SAVEPOINT

See Also:

Constant Field Values

Constructor Detail

BinlogConnectorEvent

public BinlogConnectorEvent(com.github.shyiko.mysql.binlog.event.Event event,
                            String filename,
                            String gtidSetStr,
                            String gtid,
                            MaxwellOutputConfig outputConfig)

Method Detail

getEvent

public com.github.shyiko.mysql.binlog.event.Event getEvent()

writeRowsData

public com.github.shyiko.mysql.binlog.event.WriteRowsEventData writeRowsData()

updateRowsData

public com.github.shyiko.mysql.binlog.event.UpdateRowsEventData updateRowsData()

deleteRowsData

public com.github.shyiko.mysql.binlog.event.DeleteRowsEventData deleteRowsData()

queryData

public com.github.shyiko.mysql.binlog.event.QueryEventData queryData()

xidData

public com.github.shyiko.mysql.binlog.event.XidEventData xidData()

tableMapData

public com.github.shyiko.mysql.binlog.event.TableMapEventData tableMapData()

mariaGtidData

public com.github.shyiko.mysql.binlog.event.MariadbGtidEventData mariaGtidData()

getPosition

public BinlogPosition getPosition()

getNextPosition

public BinlogPosition getNextPosition()

getType

public com.github.shyiko.mysql.binlog.event.EventType getType()

getTableID

public Long getTableID()

isCommitEvent

public boolean isCommitEvent()

jsonMaps

public List<RowMap> jsonMaps(Table table,
                             long lastHeartbeatRead,
                             String rowQuery)
                      throws ColumnDefCastException

Throws:

ColumnDefCastException