Details
-
Improvement
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
None
-
None
Description
When using `BigQueryIO.Write` and getting `WriteResult.getFailedInserts()` we get a `PCollection<TableRow>` which is fine, but in order to properly work on the errors downstream having extended information such as the `InsertError` fields and the `TableReference` it was routed to would be really valuable.
My suggestion is to create a new object that contains all that information and return a `PCollection` of those instead.
Attachments
Issue Links
- links to