flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3691) Extend AvroInputFormat to support Avro GenericRecord
Date Mon, 04 Apr 2016 08:54:25 GMT

    [ https://issues.apache.org/jira/browse/FLINK-3691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15223841#comment-15223841
] 

Robert Metzger commented on FLINK-3691:
---------------------------------------

Feel free to open a pull request for allowing to read GenericRecords from Avro.
I thought that our current implementation already supports GenericRecords.
There are certainly tests ensuring that Flink's serialization framework is able to handle
GenericRecords. Sadly, there is no test case for reading GenericRecord with the InputFormat.

> Extend AvroInputFormat to support Avro GenericRecord
> ----------------------------------------------------
>
>                 Key: FLINK-3691
>                 URL: https://issues.apache.org/jira/browse/FLINK-3691
>             Project: Flink
>          Issue Type: Improvement
>          Components: Core
>            Reporter: Gna Phetsarath
>            Priority: Minor
>
> Extend AvroInputFormat to support Avro GenericRecord: 
> Sometimes the calling application will have access to the schema but not the implementing
class for Avro files.  
> Using a GenericDatumReader will allow the AvroInput format to read records in the Avro
Generic Record Format.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message