Package org.apache.flink.cdc.connectors.mysql.source.events
-
Class Summary Class Description BinlogSplitAssignedEvent TheSourceEventthatMySqlSourceReadersends toMySqlSourceEnumeratorto notify theMySqlBinlogSplitassigned to itself.BinlogSplitMetaAssembledEvent TheSourceEventthatMySqlSourceReadersends toMySqlSourceEnumeratoronce it holds a completeMySqlBinlogSplit, signalling that all finished snapshot split metadata has been assembled by the reader.BinlogSplitMetaEvent BinlogSplitMetaRequestEvent BinlogSplitUpdateAckEvent TheSourceEventthatMySqlSourceReadersends toMySqlSourceEnumeratorto notify the binlog split reader has been updated.BinlogSplitUpdateRequestEvent TheSourceEventthatMySqlSourceEnumeratorbroadcasts toMySqlSourceReaderto tell the source reader to update the binlog split after newly added table snapshot splits finished.FinishedSnapshotSplitsAckEvent TheSourceEventthatMySqlSourceEnumeratorsends toMySqlSourceReaderto notify the finished snapshot splits has been received, i.e.FinishedSnapshotSplitsReportEvent TheSourceEventthatMySqlSourceReadersends toMySqlSourceEnumeratorto notify the snapshot split has read finished with the consistent binlog position.FinishedSnapshotSplitsRequestEvent TheSourceEventthatMySqlSourceEnumeratorsends toMySqlSourceReaderto notify reader should report its finished snapshot splits, i.e.LatestFinishedSplitsNumberEvent TheSourceEventthatMySqlSourceEnumeratorsends toMySqlSourceReaderto pass the latest finished snapshot splits number.LatestFinishedSplitsNumberRequestEvent TheSourceEventthatMySqlSourceReadersends toMySqlSourceEnumeratorto ask the latest finished snapshot splits number.