Class LatestFinishedSplitsNumberEvent
- java.lang.Object
-
- org.apache.flink.cdc.connectors.mysql.source.events.LatestFinishedSplitsNumberEvent
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.connector.source.SourceEvent
public class LatestFinishedSplitsNumberEvent extends Object implements org.apache.flink.api.connector.source.SourceEvent
TheSourceEventthatMySqlSourceEnumeratorsends toMySqlSourceReaderto pass the latest finished snapshot splits number.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description LatestFinishedSplitsNumberEvent(int latestFinishedSplitsNumber)
-