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

Class TableRowToStorageApiProto.ErrorCollector

java.lang.Object

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

Enclosing class:

TableRowToStorageApiProto

public static class TableRowToStorageApiProto.ErrorCollector
extends Object

This class collects errors encountered while attempting to convert a json message into its matching protocol-buffer message.

Field Summary

Fields

Modifier and Type	Field	Description
static final TableRowToStorageApiProto.ErrorCollector	DONT_COLLECT

Constructor Summary

Constructors

Constructor	Description
ErrorCollector(Predicate<org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException> shouldCollect)

Method Summary

Modifier and Type	Method	Description
void	mergeInto(TableRowToStorageApiProto.ErrorCollector other)

Methods inherited from class java.lang.Object

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

Field Details

DONT_COLLECT

public static final TableRowToStorageApiProto.ErrorCollector DONT_COLLECT

Constructor Details

ErrorCollector

public ErrorCollector(Predicate<org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException> shouldCollect)

Method Details

mergeInto

public void mergeInto(TableRowToStorageApiProto.ErrorCollector other)
               throws org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException

Throws:

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