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

Class BeamRowToStorageApiProto

java.lang.Object

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

public class BeamRowToStorageApiProto
extends java.lang.Object

Utility methods for converting Beam Row objects to dynamic protocol message, for use with the Storage write API.

Constructor Summary

Constructors

Constructor and Description
BeamRowToStorageApiProto()

Method Summary

Modifier and Type	Method and Description
static Descriptors.Descriptor	getDescriptorFromSchema(Schema schema) Given a Beam Schema, returns a protocol-buffer Descriptor that can be used to write data using the BigQuery Storage API.
static DynamicMessage	messageFromBeamRow(Descriptors.Descriptor descriptor, Row row) Given a Beam Row object, returns a protocol-buffer message that can be used to write data using the BigQuery Storage streaming API.

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamRowToStorageApiProto

public BeamRowToStorageApiProto()

Method Detail

getDescriptorFromSchema

public static Descriptors.Descriptor getDescriptorFromSchema(Schema schema)
                                                      throws Descriptors.DescriptorValidationException

Given a Beam Schema, returns a protocol-buffer Descriptor that can be used to write data using the BigQuery Storage API.

Throws:

Descriptors.DescriptorValidationException

messageFromBeamRow

public static DynamicMessage messageFromBeamRow(Descriptors.Descriptor descriptor,
                                                Row row)

Given a Beam Row object, returns a protocol-buffer message that can be used to write data using the BigQuery Storage streaming API.