Merge pull request #14964: [BEAM-12460] Provide a simpler interface t…

…o convert Beam Row to GenericRecord

sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroUtils.java

@@ -369,6 +369,14 @@ public static Row toBeamRowStrict(GenericRecord record, @Nullable Schema schema)
     return builder.build();
   }
 
+  /**
+   * Convert from a Beam Row to an AVRO GenericRecord. The Avro Schema is inferred from the Beam
+   * schema on the row.
+   */
+  public static GenericRecord toGenericRecord(Row row) {
+    return toGenericRecord(row, null);
+  }
+
   /**
    * Convert from a Beam Row to an AVRO GenericRecord. If a Schema is not provided, one is inferred
    * from the Beam schema on the row.

sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/utils/AvroUtilsTest.java

@@ -721,6 +721,13 @@ public void testBeamRowToGenericRecord() {
     assertEquals(getGenericRecord(), genericRecord);
   }
 
+  @Test
+  public void testBeamRowToGenericRecordInferSchema() {
+    GenericRecord genericRecord = AvroUtils.toGenericRecord(getBeamRow());
+    assertEquals(getAvroSchema(), genericRecord.getSchema());
+    assertEquals(getGenericRecord(), genericRecord);
+  }
+
   @Test
   public void testRowToGenericRecordFunction() {
     SerializableUtils.ensureSerializable(AvroUtils.getRowToGenericRecordFunction(NULL_SCHEMA));