Package org.apache.beam.sdk.io.gcp.bigquery

Class InsertRetryPolicy.Context

java.lang.Object
org.apache.beam.sdk.io.gcp.bigquery.InsertRetryPolicy.Context
Enclosing class:
InsertRetryPolicy
public static class InsertRetryPolicy.Context extends Object
Contains information about a failed insert.

Currently only the list of errors returned from BigQuery. In the future this may contain more information - e.g. how many times this insert has been retried, and for how long.

  • Constructor Summary

    Constructors
    Constructor
    Description
    Context(com.google.api.services.bigquery.model.TableDataInsertAllResponse.InsertErrors errors)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    com.google.api.services.bigquery.model.TableDataInsertAllResponse.InsertErrors
    getInsertErrors()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • Context

      public Context(com.google.api.services.bigquery.model.TableDataInsertAllResponse.InsertErrors errors)

  • Method Details

    • getInsertErrors

      public com.google.api.services.bigquery.model.TableDataInsertAllResponse.InsertErrors getInsertErrors()