com.ververica.cdc.connectors.mysql.source.events

Class BinlogSplitMetaEvent

java.lang.Object

com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaEvent

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.SourceEvent

public class BinlogSplitMetaEvent
extends Object
implements org.apache.flink.api.connector.source.SourceEvent

The SourceEvent that MySqlSourceEnumerator sends to MySqlSourceReader to pass binlog meta data, i.e. FinishedSnapshotSplitInfo.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BinlogSplitMetaEvent(String splitId, int metaGroupId, List<byte[]> metaGroup)

Method Summary

Modifier and Type	Method and Description
List<byte[]>	getMetaGroup()
int	getMetaGroupId()
String	getSplitId()

Methods inherited from class java.lang.Object

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

Constructor Detail

BinlogSplitMetaEvent

public BinlogSplitMetaEvent(String splitId,
                            int metaGroupId,
                            List<byte[]> metaGroup)

Method Detail

getSplitId

public String getSplitId()

getMetaGroupId

public int getMetaGroupId()

getMetaGroup

public List<byte[]> getMetaGroup()