Uses of Interface
com.ververica.cdc.debezium.DebeziumDeserializationSchema

Packages that use DebeziumDeserializationSchema

Package	Description
com.ververica.cdc.debezium
com.ververica.cdc.debezium.internal
com.ververica.cdc.debezium.table

Uses of DebeziumDeserializationSchema in com.ververica.cdc.debezium

Classes in com.ververica.cdc.debezium that implement DebeziumDeserializationSchema

Modifier and Type	Class and Description
class	JsonDebeziumDeserializationSchema A JSON format implementation of DebeziumDeserializationSchema which deserializes the received SourceRecord to JSON String.
class	StringDebeziumDeserializationSchema A simple implementation of DebeziumDeserializationSchema which converts the received SourceRecord into String.

Constructors in com.ververica.cdc.debezium with parameters of type DebeziumDeserializationSchema

Constructor and Description
DebeziumSourceFunction(DebeziumDeserializationSchema<T> deserializer, Properties properties, DebeziumOffset specificOffset, Validator validator)

Uses of DebeziumDeserializationSchema in com.ververica.cdc.debezium.internal

Constructors in com.ververica.cdc.debezium.internal with parameters of type DebeziumDeserializationSchema

Constructor and Description
DebeziumChangeFetcher(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T> sourceContext, DebeziumDeserializationSchema<T> deserialization, boolean isInDbSnapshotPhase, String heartbeatTopicPrefix, Handover handover)

Uses of DebeziumDeserializationSchema in com.ververica.cdc.debezium.table

Classes in com.ververica.cdc.debezium.table that implement DebeziumDeserializationSchema

Modifier and Type	Class and Description
class	RowDataDebeziumDeserializeSchema Deserialization schema from Debezium object to Flink Table/SQL internal data structure RowData.