Serialized Form

Package org.apache.flink.formats.avro.registry.confluent

Class org.apache.flink.formats.avro.registry.confluent.ConfluentRegistryAvroDeserializationSchema extends org.apache.flink.formats.avro.RegistryAvroDeserializationSchema<T> implements Serializable

serialVersionUID:

-1671641202177852775L

Class org.apache.flink.formats.avro.registry.confluent.ConfluentRegistryAvroSerializationSchema extends org.apache.flink.formats.avro.RegistryAvroSerializationSchema<T> implements Serializable

serialVersionUID:

-1771641202177852775L

Package org.apache.flink.formats.avro.registry.confluent.debezium

Class org.apache.flink.formats.avro.registry.confluent.debezium.DebeziumAvroDeserializationSchema extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

avroDeserializer

org.apache.flink.formats.avro.AvroRowDataDeserializationSchema avroDeserializer

The deserializer to deserialize Debezium Avro data.

producedTypeInfo

org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> producedTypeInfo

TypeInformation of the produced RowData.

Class org.apache.flink.formats.avro.registry.confluent.debezium.DebeziumAvroSerializationSchema extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

avroSerializer

org.apache.flink.formats.avro.AvroRowDataSerializationSchema avroSerializer

The deserializer to deserialize Debezium Avro data.