[
https://issues.apache.org/jira/browse/BEAM-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lars Almgren updated BEAM-9597:
-------------------------------
Description:
I'm building a pipeline where I'm reading a set of Avro files, all with same
schema, from a cloud provider. These Avro files all have the same schema
definition. To get GenericRecords, I today have to specify the schema for the
files in my pipeline. It would be very neat to use the fact that my Avro files
contains the schema definition already. Something like
AvroIO.readFilesGenericRecordsWithSchemaFromSource().
was:
I'm building a pipeline where I'm reading a set of Avro files, all with same
schema from a cloud provider. These Avro files all have the same schema
definition. To get GenericRecords, I today have to specify the schema for the
files in my pipeline. It would be very neat to use the fact that my Avro files
contains the schema definition already. Something like
AvroIO.readFilesGenericRecordsWithSchemaFromSource().
> Autodetect Avro schema from Avro file
> -------------------------------------
>
> Key: BEAM-9597
> URL: https://issues.apache.org/jira/browse/BEAM-9597
> Project: Beam
> Issue Type: Improvement
> Components: io-java-avro
> Reporter: Lars Almgren
> Priority: Minor
>
> I'm building a pipeline where I'm reading a set of Avro files, all with same
> schema, from a cloud provider. These Avro files all have the same schema
> definition. To get GenericRecords, I today have to specify the schema for the
> files in my pipeline. It would be very neat to use the fact that my Avro
> files contains the schema definition already. Something like
> AvroIO.readFilesGenericRecordsWithSchemaFromSource().
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
