-
Type:
Improvement
-
Status: Resolved
-
Priority:
P2
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: 2.28.0
-
Component/s: sdk-java-core
-
Labels:None
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.
- links to