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

Class LatestFinishedSplitsSizeEvent

java.lang.Object

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

All Implemented Interfaces:

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

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

The SourceEvent that MySqlSourceEnumerator sends to MySqlSourceReader to pass the latest finished snapshot splits size.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
LatestFinishedSplitsSizeEvent(int latestFinishedSplitsSize)

Method Summary

Modifier and Type	Method and Description
int	getLatestFinishedSplitsSize()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LatestFinishedSplitsSizeEvent

public LatestFinishedSplitsSizeEvent(int latestFinishedSplitsSize)

Method Detail

getLatestFinishedSplitsSize

public int getLatestFinishedSplitsSize()

toString

public String toString()

Overrides:

toString in class Object