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<TableRow>	TABLE_ROW_ERROR_CONTAINER

Method Summary

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

Field Details

TABLE_ROW_ERROR_CONTAINER

static final ErrorContainer<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,
 TableDataInsertAllResponse.InsertErrors error,
 TableReference ref,
 FailsafeValueInSingleWindow<TableRow,TableRow> tableRow)