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

Class MySqlRecordEmitter<T>

java.lang.Object

com.ververica.cdc.connectors.mysql.source.reader.MySqlRecordEmitter<T>

All Implemented Interfaces:

org.apache.flink.connector.base.source.reader.RecordEmitter<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplitState>

public final class MySqlRecordEmitter<T>
extends Object
implements org.apache.flink.connector.base.source.reader.RecordEmitter<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplitState>

The RecordEmitter implementation for MySqlSourceReader.

The RecordEmitter buffers the snapshot records of split and call the binlog reader to emit records rather than emit the records directly.

Constructor Summary

Constructors

Constructor and Description
MySqlRecordEmitter(com.ververica.cdc.debezium.DebeziumDeserializationSchema<T> debeziumDeserializationSchema, MySqlSourceReaderMetrics sourceReaderMetrics, boolean includeSchemaChanges)

Method Summary

Modifier and Type	Method and Description
void	emitRecord(org.apache.kafka.connect.source.SourceRecord element, org.apache.flink.api.connector.source.SourceOutput<T> output, MySqlSplitState splitState)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MySqlRecordEmitter

public MySqlRecordEmitter(com.ververica.cdc.debezium.DebeziumDeserializationSchema<T> debeziumDeserializationSchema,
                          MySqlSourceReaderMetrics sourceReaderMetrics,
                          boolean includeSchemaChanges)

Method Detail

emitRecord

public void emitRecord(org.apache.kafka.connect.source.SourceRecord element,
                       org.apache.flink.api.connector.source.SourceOutput<T> output,
                       MySqlSplitState splitState)
                throws Exception

Specified by:

emitRecord in interface org.apache.flink.connector.base.source.reader.RecordEmitter<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplitState>

Throws:

Exception