Hello, I have a streaming use case, where I execute a query on a Table. I take the ResolvedSchema of the table and convert it to an Avro-Schema using the AvroSchemaConverter. Now I want to do the same for JSON and Protobuf. However, it seems there is nothing similar to AvroSchemaConverter - I wonder if I have to code the Mapping of Flinks DataType to JSON and Protobuf myself now, or if I missed something. I would be glad if someone could point me in the right direction here.
Yours sincerely, Theo
smime.p7s
Description: S/MIME cryptographic signature