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

Interface ErrorContainer<T>

Type Parameters:

T -

All Superinterfaces:

java.io.Serializable

public interface ErrorContainer<T>
extends java.io.Serializable

ErrorContainer interface.

Field Summary

Fields

Modifier and Type	Field and Description
static ErrorContainer<BigQueryInsertError>	BIG_QUERY_INSERT_ERROR_ERROR_CONTAINER
static ErrorContainer<TableRow>	TABLE_ROW_ERROR_CONTAINER

Method Summary

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

Field Detail

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 Detail

add

void add(java.util.List<ValueInSingleWindow<T>> failedInserts,
         TableDataInsertAllResponse.InsertErrors error,
         TableReference ref,
         FailsafeValueInSingleWindow<TableRow,TableRow> tableRow)