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

Class BinlogSplitMetaRequestEvent

java.lang.Object

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

All Implemented Interfaces:

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

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

The SourceEvent that MySqlSourceReader sends to MySqlSourceEnumerator to pull binlog meta data, i.e. sending BinlogSplitMetaEvent.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BinlogSplitMetaRequestEvent(String splitId, int requestMetaGroupId)

Method Summary

Modifier and Type	Method and Description
int	getRequestMetaGroupId()
String	getSplitId()

Methods inherited from class java.lang.Object

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

Constructor Detail

BinlogSplitMetaRequestEvent

public BinlogSplitMetaRequestEvent(String splitId,
                                   int requestMetaGroupId)

Method Detail

getSplitId

public String getSplitId()

getRequestMetaGroupId

public int getRequestMetaGroupId()