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

Class BinlogSplitMetaRequestEvent

java.lang.Object

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
BinlogSplitMetaRequestEvent(String splitId, int requestMetaGroupId, int totalFinishedSplitSize)

Method Summary

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

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,
                                   int totalFinishedSplitSize)

Method Detail

getSplitId

public String getSplitId()

getRequestMetaGroupId

public int getRequestMetaGroupId()

getTotalFinishedSplitSize

public int getTotalFinishedSplitSize()