Swapna Marru created FLINK-39023:
------------------------------------
Summary: Implement Avro To Variant Type converter
Key: FLINK-39023
URL: https://issues.apache.org/jira/browse/FLINK-39023
Project: Flink
Issue Type: Improvement
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Affects Versions: 2.1.1
Reporter: Swapna Marru
Current we have AvroToRowDataConverters,
an utility class to convert from Avro (GenericRecord) to RowData.
With new Variant data type integrated into Flink with
[Flip-521|https://cwiki.apache.org/confluence/display/FLINK/FLIP-521%3A+Integrating+Variant+Type+into+Flink%3A+Enabling+Efficient+Semi-Structured+Data+Processing]
, add utility classes to convert from Avro to Variant type.
This is useful for implementing Kafka Serialization/Deserialization formats
that can support reading or writing data with dynamic schemas into a topic
using SQL.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
