nikitagrover19 commented on issue #28162: URL: https://github.com/apache/beam/issues/28162#issuecomment-5182694962
Hi @robertwb, I'd like to pick this up. Dug into the code a bit, WriteToBigQuery's FILE_LOADS path currently requires an explicit schema (it only falls back to the destination table's existing schema, which doesn't help for new tables with CREATE_IF_NEEDED). StorageWriteToBigQuery already auto-infers schema from Row-typed PCollections via schema_from_element_type(), so I'm planning to bring that same pattern over to FILE_LOADS, plus a small helper to convert the inferred Beam schema into BQ's TableSchema format (JSON/Avro writers need plain dicts + BQ-style schemas, not Beam's schema proto). Let me know if this sounds like the right direction before I start on the PR. -- 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]
