Package org.apache.flink.cdc.connectors.mysql.source.reader
-
Class Summary Class Description MySqlPipelineRecordEmitter TheRecordEmitterimplementation for pipeline mysql connector.MySqlRecordEmitter<T> TheRecordEmitterimplementation forMySqlSourceReader.MySqlSourceReader<T> The source reader for MySQL source splits.MySqlSourceReaderContext A wrapper class that wrapsSourceReaderContextfor sharing message betweenMySqlSourceReaderandMySqlSplitReader.MySqlSplitReader TheSplitReaderimplementation for theMySqlSource.