Class BinlogSplitUpdateRequestEvent

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.connector.source.SourceEvent

    public class BinlogSplitUpdateRequestEvent
    extends Object
    implements org.apache.flink.api.connector.source.SourceEvent
    The SourceEvent that MySqlSourceEnumerator broadcasts to MySqlSourceReader to tell the source reader to update the binlog split after newly added table snapshot splits finished.
    See Also:
    Serialized Form
    • Constructor Detail

      • BinlogSplitUpdateRequestEvent

        public BinlogSplitUpdateRequestEvent()