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 com.google.protobuf.DynamicMessage	messageFromBeamRow(com.google.protobuf.Descriptors.Descriptor descriptor, Row row, java.lang.String changeType, long changeSequenceNum) Forwards (@param changeSequenceNum) to #messageFromBeamRow(Descriptor, Row, String, String) via Long.toHexString(long).
static com.google.protobuf.DynamicMessage	messageFromBeamRow(com.google.protobuf.Descriptors.Descriptor descriptor, Row row, java.lang.String changeType, java.lang.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 Detail

BeamRowToStorageApiProto

public BeamRowToStorageApiProto()

Method Detail

messageFromBeamRow

public static com.google.protobuf.DynamicMessage messageFromBeamRow(com.google.protobuf.Descriptors.Descriptor descriptor,
                                                                    Row row,
                                                                    @Nullable
                                                                    java.lang.String changeType,
                                                                    long changeSequenceNum)

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

messageFromBeamRow

public static com.google.protobuf.DynamicMessage messageFromBeamRow(com.google.protobuf.Descriptors.Descriptor descriptor,
                                                                    Row row,
                                                                    @Nullable
                                                                    java.lang.String changeType,
                                                                    @Nullable
                                                                    java.lang.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.