Hi Everyone, I am trying to insert Avro data into BigQuery using BigQueryIO. We use beam because we have additional hydration steps for our avro files and we use a group by in order to set up multiple load jobs in a window. I see a direct conversion of Avro into a BigQuery TableRow but they are protected and only available to Apache Beam Package, (see https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtils.java )
The public class seems to want the user to go from Avro(Generic Record) -> Beam Row -> TableRow ( https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java). I am guessing this is the suggested path of conversion but is there a specific reason for this method? Thank you for your time. -Theo
