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

Interface ErrorContainer<T>

Type Parameters:

T -

All Superinterfaces:

Serializable

public interface ErrorContainer<T>
extends Serializable

ErrorContainer interface.

Field Summary

Fields

Modifier and Type	Field	Description
static final ErrorContainer<BigQueryInsertError>	BIG_QUERY_INSERT_ERROR_ERROR_CONTAINER
static final ErrorContainer<com.google.api.services.bigquery.model.TableRow>	TABLE_ROW_ERROR_CONTAINER

Method Summary

Modifier and Type	Method	Description
void	add(List<ValueInSingleWindow<T>> failedInserts, com.google.api.services.bigquery.model.TableDataInsertAllResponse.InsertErrors error, com.google.api.services.bigquery.model.TableReference ref, FailsafeValueInSingleWindow<com.google.api.services.bigquery.model.TableRow,com.google.api.services.bigquery.model.TableRow> tableRow)

Field Details

TABLE_ROW_ERROR_CONTAINER

static final ErrorContainer<com.google.api.services.bigquery.model.TableRow> TABLE_ROW_ERROR_CONTAINER

BIG_QUERY_INSERT_ERROR_ERROR_CONTAINER

static final ErrorContainer<BigQueryInsertError> BIG_QUERY_INSERT_ERROR_ERROR_CONTAINER

Method Details

add

void add(List<ValueInSingleWindow<T>> failedInserts,
 com.google.api.services.bigquery.model.TableDataInsertAllResponse.InsertErrors error,
 com.google.api.services.bigquery.model.TableReference ref,
 FailsafeValueInSingleWindow<com.google.api.services.bigquery.model.TableRow,com.google.api.services.bigquery.model.TableRow> tableRow)