Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Won't Do
-
None
-
None
Description
Similarly to https://issues.apache.org/jira/browse/BEAM-2677, we should be able to write to avro files using AvroIO without specifying a schema at build time. Consider the following use case: a user has a PCollection<GenericRecord> but the schema is only known while running the pipeline. AvroIO.writeGenericRecords needs the schema, but the schema is already available in GenericRecord. We should be able to call AvroIO.writeGenericRecords() with no schema.
Attachments
Issue Links
- links to