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

Class PostgresEventDeserializer

java.lang.Object

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

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

org.apache.flink.cdc.connectors.postgres.source.PostgresEventDeserializer

All Implemented Interfaces:

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

@Internal
public class PostgresEventDeserializer
extends DebeziumEventDeserializationSchema

Event deserializer for PostgresDataSource.

See Also:

Serialized Form

Field Summary

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

changelogMode, schemaDataTypeInference

Constructor Summary

Constructors

Constructor	Description
PostgresEventDeserializer(DebeziumChangelogMode changelogMode)
PostgresEventDeserializer(DebeziumChangelogMode changelogMode, List<PostgreSQLReadableMetadata> readableMetadataList)
PostgresEventDeserializer(DebeziumChangelogMode changelogMode, List<PostgreSQLReadableMetadata> readableMetadataList, boolean includeDatabaseInTableId)
PostgresEventDeserializer(DebeziumChangelogMode changelogMode, List<PostgreSQLReadableMetadata> readableMetadataList, boolean includeDatabaseInTableId, String databaseName)

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 RecordData	extractBeforeDataRecord(org.apache.kafka.connect.data.Struct value, org.apache.kafka.connect.data.Schema valueSchema)
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, 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

PostgresEventDeserializer

public PostgresEventDeserializer(DebeziumChangelogMode changelogMode)

PostgresEventDeserializer

public PostgresEventDeserializer(DebeziumChangelogMode changelogMode,
                                 List<PostgreSQLReadableMetadata> readableMetadataList)

PostgresEventDeserializer

public PostgresEventDeserializer(DebeziumChangelogMode changelogMode,
                                 List<PostgreSQLReadableMetadata> readableMetadataList,
                                 boolean includeDatabaseInTableId)

PostgresEventDeserializer

public PostgresEventDeserializer(DebeziumChangelogMode changelogMode,
                                 List<PostgreSQLReadableMetadata> readableMetadataList,
                                 boolean includeDatabaseInTableId,
                                 String databaseName)

Method Detail

extractBeforeDataRecord

protected RecordData extractBeforeDataRecord(org.apache.kafka.connect.data.Struct value,
                                             org.apache.kafka.connect.data.Schema valueSchema)
                                      throws Exception

Overrides:

extractBeforeDataRecord in class DebeziumEventDeserializationSchema

Throws:

Exception

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