snippet to write the avro records to big query

WriteAvroToBigQuery.java

//SomeRecord is generated via avro code generation, instance of SpecificRecord  
var tableSchema = AvroToTableSchemaConverter.convert({SomeRecord}.SCHEMA$);

BigQueryIO.<SomeRecord>write()
        .to(tableName.getValue())
        .withSchema("some-table-name")
        .useAvroLogicalTypes()
        .withAvroSchemaFactory(new SerializableFunction<TableSchema, Schema>() {
            @Override
            public Schema apply(TableSchema input) {
                return SomeRecord.SCHEMA$;
            }
        })
        .withAvroWriter(new SerializableFunction<Schema, DatumWriter<SomeRecord>>() {
            @Override
            public DatumWriter<SomeRecord> apply(Schema input) {
                return new SpecificDatumWriter<>(input);
            }
        })
        .withCreateDisposition(BigQueryIO.Write.CreateDisposition.CREATE_IF_NEEDED)
        .withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_TRUNCATE);