[ https://issues.apache.org/jira/browse/BEAM-4257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chamikara Jayalath updated BEAM-4257: ------------------------------------- Component/s: (was: sdk-java-core) io-java-gcp > Add error reason and table destination to BigQueryIO streaming failed inserts > ----------------------------------------------------------------------------- > > Key: BEAM-4257 > URL: https://issues.apache.org/jira/browse/BEAM-4257 > Project: Beam > Issue Type: Improvement > Components: io-java-gcp > Reporter: Carlos Alonso > Assignee: Kenneth Knowles > Priority: Minor > > 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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)