Package org.apache.flink.cdc.debezium

Interface DebeziumDeserializationSchema<T>

Type Parameters:

T - The type created by the deserialization schema.

All Superinterfaces:

org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, Serializable

All Known Implementing Classes:

DebeziumEventDeserializationSchema, JsonDebeziumDeserializationSchema, MongoDBConnectorDeserializationSchema, MongoDBConnectorFullChangelogDeserializationSchema, MySqlEventDeserializer, OracleEventDeserializer, PostgresEventDeserializer, RowDataDebeziumDeserializeSchema, SeekBinlogToTimestampFilter, SqlServerEventDeserializer, StringDebeziumDeserializationSchema

@PublicEvolving
public interface DebeziumDeserializationSchema<T>
extends Serializable, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>

The deserialization schema describes how to turn the Debezium SourceRecord into data types (Java/Scala objects) that are processed by Flink.

Method Summary

Modifier and Type	Method	Description
void	deserialize(org.apache.kafka.connect.source.SourceRecord record, org.apache.flink.util.Collector<T> out)	Deserialize the Debezium record, it is represented in Kafka SourceRecord.

Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable

getProducedType

Method Detail

deserialize

void deserialize(org.apache.kafka.connect.source.SourceRecord record,
                 org.apache.flink.util.Collector<T> out)
          throws Exception

Deserialize the Debezium record, it is represented in Kafka SourceRecord.

Throws:

Exception