Class 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
    The SourceEvent that MySqlSourceEnumerator sends to MySqlSourceReader to pass the latest finished snapshot splits number.
    See Also:
    Serialized Form
    • Constructor Detail

      • LatestFinishedSplitsNumberEvent

        public LatestFinishedSplitsNumberEvent​(int latestFinishedSplitsNumber)
    • Method Detail

      • getLatestFinishedSplitsNumber

        public int getLatestFinishedSplitsNumber()