You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2022/07/04 07:15:00 UTC

[jira] [Closed] (FLINK-28336) Support parquet-avro format in PyFlink DataStream

     [ https://issues.apache.org/jira/browse/FLINK-28336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dian Fu closed FLINK-28336.
---------------------------
      Assignee: Juntao Hu
    Resolution: Fixed

Merged to master via 75024ceba42faef164325ed583c84c08a0e869ff

> 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
>            Assignee: Juntao Hu
>            Priority: Major
>              Labels: pull-request-available
>             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)