org.apache.nifi.cdc.mysql.event

Class CommitTransactionEventInfo

java.lang.Object

org.apache.nifi.cdc.event.BaseEventInfo

org.apache.nifi.cdc.mysql.event.BaseBinlogEventInfo

org.apache.nifi.cdc.mysql.event.CommitTransactionEventInfo

All Implemented Interfaces:

EventInfo, BinlogEventInfo

public class CommitTransactionEventInfo
extends BaseBinlogEventInfo

An event implementation corresponding to the beginning of a MySQL transaction (update rows, e.g.)

Field Summary

Fields inherited from interface org.apache.nifi.cdc.mysql.event.BinlogEventInfo

BINLOG_FILENAME_KEY, BINLOG_POSITION_KEY

Fields inherited from interface org.apache.nifi.cdc.event.EventInfo

BEGIN_EVENT, COMMIT_EVENT, DDL_EVENT, DELETE_EVENT, INSERT_EVENT, UPDATE_EVENT

Constructor Summary

Constructors

Constructor and Description
CommitTransactionEventInfo(java.lang.String databaseName, java.lang.Long timestamp, java.lang.String binlogFilename, long binlogPosition)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getDatabaseName()

Methods inherited from class org.apache.nifi.cdc.mysql.event.BaseBinlogEventInfo

getBinlogFilename, getBinlogPosition

Methods inherited from class org.apache.nifi.cdc.event.BaseEventInfo

getEventType, getTimestamp

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nifi.cdc.event.EventInfo

getEventType, getTimestamp

Constructor Detail

CommitTransactionEventInfo

public CommitTransactionEventInfo(java.lang.String databaseName,
                                  java.lang.Long timestamp,
                                  java.lang.String binlogFilename,
                                  long binlogPosition)

Method Detail

getDatabaseName

public java.lang.String getDatabaseName()