为了阅读 Avro 数据来源 Kafka 我们有 AvroDeserializationSchema . 但是写作呢？
Avro
Kafka
AvroDeserializationSchema
8zzbczxx1#
这就是 AvroRowSerializationSchema 可以用来序列化 Rows . 如果您需要序列化特定类型，那么我建议您实现自己的模式，因为flink不提供任何其他avro SerializationSchemas 目前。
AvroRowSerializationSchema
Rows
SerializationSchemas
1条答案
按热度按时间8zzbczxx1#
这就是
AvroRowSerializationSchema可以用来序列化Rows. 如果您需要序列化特定类型，那么我建议您实现自己的模式，因为flink不提供任何其他avroSerializationSchemas目前。