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

Class BeamRowToStorageApiProto

java.lang.Object

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

public class BeamRowToStorageApiProto
extends Object

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

Constructor Summary

Constructors

Constructor	Description
BeamRowToStorageApiProto()

Method Summary

Modifier and Type	Method	Description
static DynamicMessage	messageFromBeamRow(Descriptors.Descriptor descriptor, Row row, String changeType, long changeSequenceNum)	Forwards (@param changeSequenceNum) to messageFromBeamRow(Descriptor, Row, String, String) via Long.toHexString(long).
static DynamicMessage	messageFromBeamRow(Descriptors.Descriptor descriptor, Row row, String changeType, String changeSequenceNum)	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 Details

BeamRowToStorageApiProto

public BeamRowToStorageApiProto()

Method Details

messageFromBeamRow

public static DynamicMessage messageFromBeamRow(Descriptors.Descriptor descriptor,
 Row row,
 @Nullable
 String changeType,
 long changeSequenceNum)

Forwards (@param changeSequenceNum) to messageFromBeamRow(Descriptor, Row, String, String) via Long.toHexString(long).

messageFromBeamRow

public static DynamicMessage messageFromBeamRow(Descriptors.Descriptor descriptor,
 Row row,
 @Nullable
 String changeType,
 @Nullable
 String changeSequenceNum)

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