Package org.apache.flink.cdc.connectors.mysql.source

Class MySqlEventDeserializer

java.lang.Object

org.apache.flink.cdc.debezium.event.SourceRecordEventDeserializer

org.apache.flink.cdc.debezium.event.DebeziumEventDeserializationSchema

org.apache.flink.cdc.connectors.mysql.source.MySqlEventDeserializer

All Implemented Interfaces:

Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<Event>, EventDeserializer<org.apache.kafka.connect.source.SourceRecord>, DebeziumDeserializationSchema<Event>

@Internal
public class MySqlEventDeserializer
extends DebeziumEventDeserializationSchema

Event deserializer for MySqlDataSource.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static String	SCHEMA_CHANGE_EVENT_KEY_NAME

Fields inherited from class org.apache.flink.cdc.debezium.event.DebeziumEventDeserializationSchema

changelogMode, schemaDataTypeInference

Constructor Summary

Constructors

Constructor	Description
MySqlEventDeserializer(DebeziumChangelogMode changelogMode, boolean includeSchemaChanges, boolean tinyInt1isBit, boolean isTableIdCaseInsensitive)
MySqlEventDeserializer(DebeziumChangelogMode changelogMode, boolean includeSchemaChanges, List<MySqlReadableMetadata> readableMetadataList, boolean includeComments, boolean tinyInt1isBit, boolean isTableIdCaseInsensitive)

Method Summary

Modifier and Type	Method	Description
protected Object	convertToString(Object dbzObj, org.apache.kafka.connect.data.Schema schema)
protected List<SchemaChangeEvent>	deserializeSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)	Deserialize given schema change record to SchemaChangeEvent.
protected Map<String,String>	getMetadata(org.apache.kafka.connect.source.SourceRecord record)	Get metadata from data change record.
protected TableId	getTableId(org.apache.kafka.connect.source.SourceRecord record)	Get TableId from data change record.
protected boolean	isDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)	Whether the given record is a data change record.
protected boolean	isSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)	Whether the given record is a schema change record.

Methods inherited from class org.apache.flink.cdc.debezium.event.DebeziumEventDeserializationSchema

applyChangeEvent, convertToArray, convertToBinary, convertToBoolean, convertToByte, convertToDate, convertToDecimal, convertToDouble, convertToFloat, convertToInt, convertToLocalTimeZoneTimestamp, convertToLong, convertToMap, convertToRecord, convertToShort, convertToTime, convertToTimestamp, createNotNullConverter, deserialize, deserializeDataChangeRecord, extractBeforeDataRecord, getCreateTableEventCache, getProducedType

Methods inherited from class org.apache.flink.cdc.debezium.event.SourceRecordEventDeserializer

deserialize, fieldSchema, fieldStruct

Methods inherited from class java.lang.Object

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

Field Detail

SCHEMA_CHANGE_EVENT_KEY_NAME

public static final String SCHEMA_CHANGE_EVENT_KEY_NAME

See Also:

Constant Field Values

Constructor Detail

MySqlEventDeserializer

public MySqlEventDeserializer(DebeziumChangelogMode changelogMode,
                              boolean includeSchemaChanges,
                              boolean tinyInt1isBit,
                              boolean isTableIdCaseInsensitive)

MySqlEventDeserializer

public MySqlEventDeserializer(DebeziumChangelogMode changelogMode,
                              boolean includeSchemaChanges,
                              List<MySqlReadableMetadata> readableMetadataList,
                              boolean includeComments,
                              boolean tinyInt1isBit,
                              boolean isTableIdCaseInsensitive)

Method Detail

deserializeSchemaChangeRecord

protected List<SchemaChangeEvent> deserializeSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Description copied from class: SourceRecordEventDeserializer

Deserialize given schema change record to SchemaChangeEvent.

Specified by:

deserializeSchemaChangeRecord in class SourceRecordEventDeserializer

isDataChangeRecord

protected boolean isDataChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Description copied from class: SourceRecordEventDeserializer

Whether the given record is a data change record.

Specified by:

isDataChangeRecord in class SourceRecordEventDeserializer

isSchemaChangeRecord

protected boolean isSchemaChangeRecord(org.apache.kafka.connect.source.SourceRecord record)

Description copied from class: SourceRecordEventDeserializer

Whether the given record is a schema change record.

Specified by:

isSchemaChangeRecord in class SourceRecordEventDeserializer

getTableId

protected TableId getTableId(org.apache.kafka.connect.source.SourceRecord record)

Description copied from class: SourceRecordEventDeserializer

Get TableId from data change record.

Specified by:

getTableId in class SourceRecordEventDeserializer

getMetadata

protected Map<String,String> getMetadata(org.apache.kafka.connect.source.SourceRecord record)

Description copied from class: SourceRecordEventDeserializer

Get metadata from data change record.

Specified by:

getMetadata in class SourceRecordEventDeserializer

convertToString

protected Object convertToString(Object dbzObj,
                                 org.apache.kafka.connect.data.Schema schema)

Overrides:

convertToString in class DebeziumEventDeserializationSchema