diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BQTableSchemaToProtoDescriptor.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BQTableSchemaToProtoDescriptor.java index 2b105bcbaf..6ca2ca1f9f 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BQTableSchemaToProtoDescriptor.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BQTableSchemaToProtoDescriptor.java @@ -49,7 +49,7 @@ public class BQTableSchemaToProtoDescriptor { .put(Table.TableFieldSchema.Type.DATE, FieldDescriptorProto.Type.TYPE_INT32) .put(Table.TableFieldSchema.Type.DATETIME, FieldDescriptorProto.Type.TYPE_INT64) .put(Table.TableFieldSchema.Type.DOUBLE, FieldDescriptorProto.Type.TYPE_DOUBLE) - .put(Table.TableFieldSchema.Type.GEOGRAPHY, FieldDescriptorProto.Type.TYPE_BYTES) + .put(Table.TableFieldSchema.Type.GEOGRAPHY, FieldDescriptorProto.Type.TYPE_STRING) .put(Table.TableFieldSchema.Type.INT64, FieldDescriptorProto.Type.TYPE_INT64) .put(Table.TableFieldSchema.Type.NUMERIC, FieldDescriptorProto.Type.TYPE_BYTES) .put(Table.TableFieldSchema.Type.STRING, FieldDescriptorProto.Type.TYPE_STRING) diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BQTableSchemaToProtoDescriptorTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BQTableSchemaToProtoDescriptorTest.java index fcca818afc..c39a251590 100644 --- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BQTableSchemaToProtoDescriptorTest.java +++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BQTableSchemaToProtoDescriptorTest.java @@ -41,7 +41,7 @@ public class BQTableSchemaToProtoDescriptorTest { .put(Table.TableFieldSchema.Type.DATE, Int32Type.getDescriptor()) .put(Table.TableFieldSchema.Type.DATETIME, Int64Type.getDescriptor()) .put(Table.TableFieldSchema.Type.DOUBLE, DoubleType.getDescriptor()) - .put(Table.TableFieldSchema.Type.GEOGRAPHY, BytesType.getDescriptor()) + .put(Table.TableFieldSchema.Type.GEOGRAPHY, StringType.getDescriptor()) .put(Table.TableFieldSchema.Type.INT64, Int64Type.getDescriptor()) .put(Table.TableFieldSchema.Type.NUMERIC, BytesType.getDescriptor()) .put(Table.TableFieldSchema.Type.STRING, StringType.getDescriptor())