Details
-
Improvement
-
Status: Triage Needed
-
P2
-
Resolution: Fixed
-
None
-
None
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.
Attachments
Issue Links
- links to