Open yuehuaz opened 7 years ago
Thanks for reporting. Since we're using GenericRecord
, there's no way to get schema from the type and we have to read it from Avro file header instead.
I'm out till Dec and may not look at this at time soon. You wanna give it a shot and submit a PR?
Gotcha. I am using a workaround by returning an option instead.
Seems like it always tries to get the schema from the first record: https://github.com/spotify/spark-bigquery/blob/master/src/main/scala/com/spotify/spark/bigquery/package.scala#L122