Juntao Hu created FLINK-28336: --------------------------------- Summary: Support parquet-avro format in PyFlink DataStream Key: FLINK-28336 URL: https://issues.apache.org/jira/browse/FLINK-28336 Project: Flink Issue Type: New Feature Components: API / Python Affects Versions: 1.15.0 Reporter: Juntao Hu Fix For: 1.16.0
Parquet-avro has three interfaces, ReflectData, SpecificData and GenericData, considered that the first two interface need cooresponding Java class, we just support GenericData in PyFlink, where users use strings to define Avro schema. -- This message was sent by Atlassian Jira (v8.20.10#820010)