public class TableRowToStorageApiProto
extends java.lang.Object
TableRow
objects to dynamic protocol message, for use
with the Storage write API.Modifier and Type | Class and Description |
---|---|
static class |
TableRowToStorageApiProto.SchemaDoesntMatchException |
static class |
TableRowToStorageApiProto.SchemaTooNarrowException |
static class |
TableRowToStorageApiProto.SingleValueConversionException |
Constructor and Description |
---|
TableRowToStorageApiProto() |
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.Descriptors.Descriptor |
getDescriptorFromTableSchema(TableSchema jsonSchema,
boolean respectRequired,
boolean includeCdcColumns) |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptorFromTableSchema(com.google.cloud.bigquery.storage.v1.TableSchema tableSchema,
boolean respectRequired,
boolean includeCdcColumns)
Given a BigQuery TableSchema, returns a protocol-buffer Descriptor that can be used to write
data using the BigQuery Storage API.
|
static java.lang.Object |
jsonValueFromMessageValue(com.google.protobuf.Descriptors.FieldDescriptor fieldDescriptor,
java.lang.Object fieldValue,
boolean expandRepeated) |
static com.google.protobuf.DynamicMessage |
messageFromMap(org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaInformation schemaInformation,
com.google.protobuf.Descriptors.Descriptor descriptor,
java.util.AbstractMap<java.lang.String,java.lang.Object> map,
boolean ignoreUnknownValues,
boolean allowMissingRequiredFields,
@Nullable TableRow unknownFields,
@Nullable java.lang.String changeType,
@Nullable java.lang.String changeSequenceNum) |
static com.google.protobuf.DynamicMessage |
messageFromTableRow(org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaInformation schemaInformation,
com.google.protobuf.Descriptors.Descriptor descriptor,
TableRow tableRow,
boolean ignoreUnknownValues,
boolean allowMissingRequiredFields,
@Nullable TableRow unknownFields,
@Nullable java.lang.String changeType,
long changeSequenceNum)
Forwards to
#messageFromTableRow(SchemaInformation,
Descriptor, TableRow, boolean, boolean, TableRow, String, String) via Long.toHexString(long) . |
static com.google.protobuf.DynamicMessage |
messageFromTableRow(org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaInformation schemaInformation,
com.google.protobuf.Descriptors.Descriptor descriptor,
TableRow tableRow,
boolean ignoreUnknownValues,
boolean allowMissingRequiredFields,
@Nullable TableRow unknownFields,
@Nullable java.lang.String changeType,
@Nullable java.lang.String changeSequenceNum)
Given a BigQuery TableRow, returns a protocol-buffer message that can be used to write data
using the BigQuery Storage API.
|
static com.google.cloud.bigquery.storage.v1.TableFieldSchema.Mode |
modeToProtoMode(@Nullable java.lang.String defaultValueExpression,
java.lang.String mode) |
static java.lang.String |
protoModeToJsonMode(com.google.cloud.bigquery.storage.v1.TableFieldSchema.Mode protoMode) |
static TableSchema |
protoSchemaToTableSchema(com.google.cloud.bigquery.storage.v1.TableSchema protoTableSchema) |
static TableFieldSchema |
protoTableFieldToTableField(com.google.cloud.bigquery.storage.v1.TableFieldSchema protoTableField) |
static java.lang.String |
protoTypeToJsonType(com.google.cloud.bigquery.storage.v1.TableFieldSchema.Type protoType) |
static com.google.cloud.bigquery.storage.v1.TableSchema |
schemaToProtoTableSchema(TableSchema tableSchema) |
static com.google.cloud.bigquery.storage.v1.TableFieldSchema |
tableFieldToProtoTableField(TableFieldSchema field) |
static TableRow |
tableRowFromMessage(com.google.protobuf.Message message,
boolean includeCdcColumns) |
static com.google.cloud.bigquery.storage.v1.TableFieldSchema.Type |
typeToProtoType(java.lang.String type) |
static com.google.protobuf.Descriptors.Descriptor |
wrapDescriptorProto(com.google.protobuf.DescriptorProtos.DescriptorProto descriptorProto) |
public static com.google.cloud.bigquery.storage.v1.TableFieldSchema.Mode modeToProtoMode(@Nullable java.lang.String defaultValueExpression, java.lang.String mode)
public static java.lang.String protoModeToJsonMode(com.google.cloud.bigquery.storage.v1.TableFieldSchema.Mode protoMode)
public static java.lang.String protoTypeToJsonType(com.google.cloud.bigquery.storage.v1.TableFieldSchema.Type protoType)
public static com.google.cloud.bigquery.storage.v1.TableFieldSchema.Type typeToProtoType(java.lang.String type)
public static TableSchema protoSchemaToTableSchema(com.google.cloud.bigquery.storage.v1.TableSchema protoTableSchema)
public static TableFieldSchema protoTableFieldToTableField(com.google.cloud.bigquery.storage.v1.TableFieldSchema protoTableField)
public static com.google.cloud.bigquery.storage.v1.TableSchema schemaToProtoTableSchema(TableSchema tableSchema)
public static com.google.cloud.bigquery.storage.v1.TableFieldSchema tableFieldToProtoTableField(TableFieldSchema field)
public static com.google.protobuf.Descriptors.Descriptor getDescriptorFromTableSchema(TableSchema jsonSchema, boolean respectRequired, boolean includeCdcColumns) throws com.google.protobuf.Descriptors.DescriptorValidationException
com.google.protobuf.Descriptors.DescriptorValidationException
public static com.google.protobuf.Descriptors.Descriptor getDescriptorFromTableSchema(com.google.cloud.bigquery.storage.v1.TableSchema tableSchema, boolean respectRequired, boolean includeCdcColumns) throws com.google.protobuf.Descriptors.DescriptorValidationException
com.google.protobuf.Descriptors.DescriptorValidationException
public static com.google.protobuf.Descriptors.Descriptor wrapDescriptorProto(com.google.protobuf.DescriptorProtos.DescriptorProto descriptorProto) throws com.google.protobuf.Descriptors.DescriptorValidationException
com.google.protobuf.Descriptors.DescriptorValidationException
public static com.google.protobuf.DynamicMessage messageFromMap(org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaInformation schemaInformation, com.google.protobuf.Descriptors.Descriptor descriptor, java.util.AbstractMap<java.lang.String,java.lang.Object> map, boolean ignoreUnknownValues, boolean allowMissingRequiredFields, @Nullable TableRow unknownFields, @Nullable java.lang.String changeType, @Nullable java.lang.String changeSequenceNum) throws org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException
org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException
public static com.google.protobuf.DynamicMessage messageFromTableRow(org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaInformation schemaInformation, com.google.protobuf.Descriptors.Descriptor descriptor, TableRow tableRow, boolean ignoreUnknownValues, boolean allowMissingRequiredFields, @Nullable TableRow unknownFields, @Nullable java.lang.String changeType, long changeSequenceNum) throws org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException
#messageFromTableRow(SchemaInformation,
Descriptor, TableRow, boolean, boolean, TableRow, String, String)
via Long.toHexString(long)
.org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException
public static com.google.protobuf.DynamicMessage messageFromTableRow(org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaInformation schemaInformation, com.google.protobuf.Descriptors.Descriptor descriptor, TableRow tableRow, boolean ignoreUnknownValues, boolean allowMissingRequiredFields, @Nullable TableRow unknownFields, @Nullable java.lang.String changeType, @Nullable java.lang.String changeSequenceNum) throws org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException
org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException
public static TableRow tableRowFromMessage(com.google.protobuf.Message message, boolean includeCdcColumns)
public static java.lang.Object jsonValueFromMessageValue(com.google.protobuf.Descriptors.FieldDescriptor fieldDescriptor, java.lang.Object fieldValue, boolean expandRepeated)