Package org.apache.flink.cdc.connectors.mysql.source.events

Class BinlogSplitMetaEvent

java.lang.Object

org.apache.flink.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 metadata, i.e. FinishedSnapshotSplitInfo.

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

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

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,
                            @Nullable
                            List<byte[]> metaGroup,
                            int totalFinishedSplitSize,
                            long binlogAssignmentGeneration)

Method Detail

getSplitId

public String getSplitId()

getMetaGroupId

public int getMetaGroupId()

getMetaGroup

public List<byte[]> getMetaGroup()

getTotalFinishedSplitSize

public int getTotalFinishedSplitSize()

getBinlogAssignmentGeneration

public long getBinlogAssignmentGeneration()