[FLINK-3691] Extend AvroInputFormat to support Avro GenericRecord

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Implemented
• Fix Version/s: 1.1.0
• Assignee: Unassigned
• Reporter: Gna Phetsarath
• Created: 01/Apr/16 19:43
• Updated: 28/Feb/19 13:20
• Resolved: 04/May/16 19:26

Description

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.