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

Class SqlServerEventDeserializer

java.lang.Object

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

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

org.apache.flink.cdc.connectors.sqlserver.source.SqlServerEventDeserializer

All Implemented Interfaces:

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

@Internal
public class SqlServerEventDeserializer
extends DebeziumEventDeserializationSchema

Event deserializer for SqlServerDataSource.

See Also:

Serialized Form

Field Summary

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

changelogMode, schemaDataTypeInference

Constructor Summary

Constructors

Constructor	Description
SqlServerEventDeserializer(DebeziumChangelogMode changelogMode, boolean includeSchemaChanges)
SqlServerEventDeserializer(DebeziumChangelogMode changelogMode, boolean includeSchemaChanges, List<SqlServerReadableMetadata> readableMetadataList)

Method Summary

Modifier and Type	Method	Description
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, convertToString, 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

Constructor Detail

SqlServerEventDeserializer

public SqlServerEventDeserializer(DebeziumChangelogMode changelogMode,
                                  boolean includeSchemaChanges)

SqlServerEventDeserializer

public SqlServerEventDeserializer(DebeziumChangelogMode changelogMode,
                                  boolean includeSchemaChanges,
                                  List<SqlServerReadableMetadata> readableMetadataList)

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