Uses of Class
com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader

Packages that use MySqlSplitReader

Package	Description
com.ververica.cdc.connectors.mysql.source.reader

Uses of MySqlSplitReader in com.ververica.cdc.connectors.mysql.source.reader

Constructor parameters in com.ververica.cdc.connectors.mysql.source.reader with type arguments of type MySqlSplitReader

Constructor and Description

MySqlSourceReader(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord>> elementQueue, java.util.function.Supplier<MySqlSplitReader> splitReaderSupplier, org.apache.flink.connector.base.source.reader.RecordEmitter<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplitState> recordEmitter, org.apache.flink.configuration.Configuration config, MySqlSourceReaderContext context, MySqlSourceConfig sourceConfig)