steveniemitz commented on code in PR #22718:
URL: https://github.com/apache/beam/pull/22718#discussion_r946906935
##########
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java:
##########
@@ -606,6 +607,28 @@ public static <T> TypedRead<T>
read(SerializableFunction<SchemaAndRecord, T> par
.build();
}
+ /**
+ * Reads from a BigQuery table or query and returns a {@link PCollection}
with one element per
+ * each row of the table or query result, where the custom {@link
org.apache.avro.io.DatumReader}
+ * implementation is used to parse from the BigQuery AVRO format.
+ *
+ * <p> This API allows direct deserialization of AVRO data to the target
class.
+ */
+ public static <T> TypedRead<T> readWithDatumReader(
Review Comment:
rather than a new method, can we just add `withDatumReaderFactory` on
TypedRead?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
