steveniemitz commented on code in PR #22718:
URL: https://github.com/apache/beam/pull/22718#discussion_r946906252
##########
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java:
##########
@@ -804,6 +827,10 @@ public enum Method {
abstract Builder<T> setParseFn(SerializableFunction<SchemaAndRecord, T>
parseFn);
+ abstract Builder<T>
setReaderDatumFactory(AvroSource.DatumReaderFactory<T> factory);
Review Comment:
I'm not sure I'm a big fan of using things from avro IO here, particularly
since this is a very simple interface, it might be better to just redefine it
here?
--
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]
