[BEAM-11571] Support Conversion to GenericRecords in Convert.to transform

• Type: Improvement
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.28.0
• Component/s: sdk-java-core
• Assignee: Ismaël Mejía
• Reporter: Ismaël Mejía
• Created: 05/Jan/21 23:21
• Updated: 02/Mar/21 13:37
• Resolved: 09/Jan/21 07:53

Description

Beam's Convert transform allows to 'automatically' convert from a Schema based PCollection into a target type.
The current implementation fails if the target PCollection is backed by GenericRecord. Supporting this type of conversion is important because many IOs e.g. AvroIO, ParquetIO have write/sink transforms that depend on the input PCollection in GenericRecord form.

Issue Links

• links to: GitHub Pull Request #13671