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

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.