diff --git a/.github/.OwlBot.lock.yaml b/.github/.OwlBot.lock.yaml
index 88d9b926c1..e04f94284f 100644
--- a/.github/.OwlBot.lock.yaml
+++ b/.github/.OwlBot.lock.yaml
@@ -1,3 +1,3 @@
 docker:
   image: gcr.io/cloud-devrel-public-resources/owlbot-java:latest
-  digest: sha256:5b8c790f57cca57e6b37ba25f79291265c218cea3e6ba9714b001910ab3f1419
+  digest: sha256:55d5d3c72e1c065f018e423e122a22fb55c8daa36f6f17f540774779ed659ab9
diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/util/Errors.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/util/Errors.java
index 7af0523493..cc768e554e 100644
--- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/util/Errors.java
+++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/util/Errors.java
@@ -23,7 +23,8 @@
 
 /** Static utility methods for working with Errors returned from the service. */
 public class Errors {
-  private Errors() {};
+  private Errors() {}
+  ;
 
   public static class IsRetryableStatusResult {
     public boolean isRetryable = false;
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWriteImpl.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWriteImpl.java
index 33d2a5ef3d..f7691734d0 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWriteImpl.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWriteImpl.java
@@ -174,7 +174,8 @@ public void batchCommitWriteStreams(
       responseObserver.onError(
           new IllegalArgumentException(
               String.format(
-                  "Unrecognized response type %s for method BatchCommitWriteStreams, expected %s or %s",
+                  "Unrecognized response type %s for method BatchCommitWriteStreams, expected %s or"
+                      + " %s",
                   response == null ? "null" : response.getClass().getName(),
                   BatchCommitWriteStreamsResponse.class.getName(),
                   Exception.class.getName())));
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/ProtoSchemaConverterTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/ProtoSchemaConverterTest.java
index 8a2b8dc97b..9e3eafbb82 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/ProtoSchemaConverterTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/ProtoSchemaConverterTest.java
@@ -163,7 +163,8 @@ public void convertRecursiveTopMessage() {
       Assert.fail("No exception raised");
     } catch (InvalidArgumentException e) {
       Assert.assertEquals(
-          "Recursive type is not supported:com.google.cloud.bigquery.storage.test.RecursiveTypeTopMessage",
+          "Recursive type is not"
+              + " supported:com.google.cloud.bigquery.storage.test.RecursiveTypeTopMessage",
           e.getMessage());
     }
   }
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/StreamWriterTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/StreamWriterTest.java
index b95c981bf3..025e1cc402 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/StreamWriterTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/StreamWriterTest.java
@@ -345,7 +345,8 @@ public void testAppendFailedOnDone() throws Exception {
     StatusRuntimeException exception =
         new StatusRuntimeException(
             io.grpc.Status.INVALID_ARGUMENT.withDescription(
-                "io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Input schema has more fields than BigQuery schema"));
+                "io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Input schema has more fields"
+                    + " than BigQuery schema"));
 
     testBigQueryWrite.addResponse(createAppendResponse(0));
     testBigQueryWrite.addException(exception);
@@ -360,7 +361,8 @@ public void testAppendFailedOnDone() throws Exception {
         actualError
             .getMessage()
             .contains(
-                "io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Input schema has more fields than BigQuery schema"));
+                "io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Input schema has more fields"
+                    + " than BigQuery schema"));
 
     writer.close();
   }
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryStorageLongRunningTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryStorageLongRunningTest.java
index f376565947..02abced7ea 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryStorageLongRunningTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryStorageLongRunningTest.java
@@ -102,7 +102,8 @@ public void testLongRunningReadSession() throws InterruptedException, ExecutionE
 
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         5,
         session.getStreamsCount());
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryStorageTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryStorageTest.java
index b80c2c3e86..12edc7df4d 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryStorageTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryStorageTest.java
@@ -136,7 +136,8 @@ public void testSimpleRead() {
             /* maxStreamCount = */ 1);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
@@ -171,7 +172,8 @@ public void testSimpleReadAndResume() {
             /* maxStreamCount = */ 1);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
@@ -223,7 +225,8 @@ public void testFilter() throws IOException {
     ReadSession session = client.createReadSession(request);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
@@ -285,7 +288,8 @@ public void testColumnSelection() throws IOException {
     ReadSession session = client.createReadSession(request);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
@@ -740,16 +744,10 @@ public void testStructAndArraySqlTypes() throws InterruptedException, IOExceptio
     String tableName = "test_struct_and_array_sql_types";
     String createTableStatement =
         String.format(
-            " CREATE TABLE %s.%s "
-                + " (array_field ARRAY<INT64>,"
-                + "  struct_field STRUCT<int_field INT64 NOT NULL, str_field STRING NOT NULL> NOT NULL)"
-                + " OPTIONS( "
-                + "   description=\"a table with array and time column types\" "
-                + " ) "
-                + "AS "
-                + "   SELECT "
-                + "     [1, 2, 3],"
-                + "     (10, 'abc')",
+            " CREATE TABLE %s.%s  (array_field ARRAY<INT64>,  struct_field STRUCT<int_field INT64"
+                + " NOT NULL, str_field STRING NOT NULL> NOT NULL) OPTIONS(    description=\"a"
+                + " table with array and time column types\"  ) AS    SELECT      [1, 2, 3],    "
+                + " (10, 'abc')",
             DATASET, tableName);
 
     RunQueryJobAndExpectSuccess(QueryJobConfiguration.newBuilder(createTableStatement).build());
@@ -879,7 +877,8 @@ private void ProcessRowsAtSnapshot(
     ReadSession session = client.createReadSession(createSessionRequestBuilder.build());
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryWriteManualClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryWriteManualClientTest.java
index 9f65a74ca7..28b26d1fac 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryWriteManualClientTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/it/ITBigQueryWriteManualClientTest.java
@@ -466,10 +466,12 @@ public void testComplicateSchemaWithPendingStream()
     Iterator<FieldValueList> queryIter = queryResult.getValues().iterator();
     assertTrue(queryIter.hasNext());
     assertEquals(
-        "[FieldValue{attribute=REPEATED, value=[FieldValue{attribute=PRIMITIVE, value=aaa}, FieldValue{attribute=PRIMITIVE, value=aaa}]}]",
+        "[FieldValue{attribute=REPEATED, value=[FieldValue{attribute=PRIMITIVE, value=aaa},"
+            + " FieldValue{attribute=PRIMITIVE, value=aaa}]}]",
         queryIter.next().get(1).getRepeatedValue().toString());
     assertEquals(
-        "[FieldValue{attribute=REPEATED, value=[FieldValue{attribute=PRIMITIVE, value=bbb}, FieldValue{attribute=PRIMITIVE, value=bbb}]}]",
+        "[FieldValue{attribute=REPEATED, value=[FieldValue{attribute=PRIMITIVE, value=bbb},"
+            + " FieldValue{attribute=PRIMITIVE, value=bbb}]}]",
         queryIter.next().get(1).getRepeatedValue().toString());
     assertFalse(queryIter.hasNext());
   }
@@ -533,7 +535,8 @@ public void testStreamSchemaMisMatchError() throws IOException, InterruptedExcep
         // TODO(stephwang): update test case when toStroageException is updated
         assertThat(e.getCause().getMessage())
             .contains(
-                "io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Input schema has more fields than BigQuery schema");
+                "io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Input schema has more fields"
+                    + " than BigQuery schema");
       }
     }
   }
@@ -565,7 +568,8 @@ public void testStreamFinalizedError()
         //   //TODO(stephwang): update test case when toStroageException is updated
         assertThat(e.getCause().getMessage())
             .contains(
-                "io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Stream has been finalized and cannot be appended");
+                "io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Stream has been finalized and"
+                    + " cannot be appended");
       }
     }
   }
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorageImpl.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorageImpl.java
index d588dbc818..66c13e3eab 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorageImpl.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorageImpl.java
@@ -117,7 +117,8 @@ public void batchCreateReadSessionStreams(
       responseObserver.onError(
           new IllegalArgumentException(
               String.format(
-                  "Unrecognized response type %s for method BatchCreateReadSessionStreams, expected %s or %s",
+                  "Unrecognized response type %s for method BatchCreateReadSessionStreams, expected"
+                      + " %s or %s",
                   response == null ? "null" : response.getClass().getName(),
                   Storage.BatchCreateReadSessionStreamsResponse.class.getName(),
                   Exception.class.getName())));
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageLongRunningTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageLongRunningTest.java
index 5043c60446..78b79488a2 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageLongRunningTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageLongRunningTest.java
@@ -101,7 +101,8 @@ public void testLongRunningReadSession() throws InterruptedException, ExecutionE
             /* requestedStreams = */ 5);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table reference '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table reference '%s' CreateReadSession"
+                + " response:%n%s",
             TextFormat.shortDebugString(tableReference), session.toString()),
         5,
         session.getStreamsCount());
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageTest.java
index 79727cd1f2..c26ea82aa2 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/it/ITBigQueryStorageTest.java
@@ -137,7 +137,8 @@ public void testSimpleRead() {
             /* requestedStreams = */ 1);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table reference '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table reference '%s' CreateReadSession"
+                + " response:%n%s",
             TextFormat.shortDebugString(tableReference), session.toString()),
         1,
         session.getStreamsCount());
@@ -173,7 +174,8 @@ public void testSimpleReadAndResume() {
             /* requestedStreams = */ 1);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table reference '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table reference '%s' CreateReadSession"
+                + " response:%n%s",
             TextFormat.shortDebugString(tableReference), session.toString()),
         1,
         session.getStreamsCount());
@@ -224,7 +226,8 @@ public void testFilter() throws IOException {
     ReadSession session = client.createReadSession(request);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table reference '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table reference '%s' CreateReadSession"
+                + " response:%n%s",
             TextFormat.shortDebugString(tableReference), session.toString()),
         1,
         session.getStreamsCount());
@@ -287,7 +290,8 @@ public void testColumnSelection() throws IOException {
     ReadSession session = client.createReadSession(request);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table reference '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table reference '%s' CreateReadSession"
+                + " response:%n%s",
             TextFormat.shortDebugString(tableReference), session.toString()),
         1,
         session.getStreamsCount());
@@ -757,16 +761,10 @@ public void testStructAndArraySqlTypes() throws InterruptedException, IOExceptio
     String table_name = "test_struct_and_array_sql_types";
     String createTableStatement =
         String.format(
-            " CREATE TABLE %s.%s "
-                + " (array_field ARRAY<INT64>,"
-                + "  struct_field STRUCT<int_field INT64 NOT NULL, str_field STRING NOT NULL> NOT NULL)"
-                + " OPTIONS( "
-                + "   description=\"a table with array and time column types\" "
-                + " ) "
-                + "AS "
-                + "   SELECT "
-                + "     [1, 2, 3],"
-                + "     (10, 'abc')",
+            " CREATE TABLE %s.%s  (array_field ARRAY<INT64>,  struct_field STRUCT<int_field INT64"
+                + " NOT NULL, str_field STRING NOT NULL> NOT NULL) OPTIONS(    description=\"a"
+                + " table with array and time column types\"  ) AS    SELECT      [1, 2, 3],    "
+                + " (10, 'abc')",
             DATASET, table_name);
 
     RunQueryJobAndExpectSuccess(QueryJobConfiguration.newBuilder(createTableStatement).build());
@@ -896,7 +894,8 @@ private void ProcessRowsAtSnapshot(
     ReadSession session = client.createReadSession(createSessionRequestBuilder.build());
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table reference '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table reference '%s' CreateReadSession"
+                + " response:%n%s",
             TextFormat.shortDebugString(tableReference), session.toString()),
         1,
         session.getStreamsCount());
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWriteImpl.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWriteImpl.java
index 63588f0509..2ef086e54a 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWriteImpl.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWriteImpl.java
@@ -174,7 +174,8 @@ public void batchCommitWriteStreams(
       responseObserver.onError(
           new IllegalArgumentException(
               String.format(
-                  "Unrecognized response type %s for method BatchCommitWriteStreams, expected %s or %s",
+                  "Unrecognized response type %s for method BatchCommitWriteStreams, expected %s or"
+                      + " %s",
                   response == null ? "null" : response.getClass().getName(),
                   BatchCommitWriteStreamsResponse.class.getName(),
                   Exception.class.getName())));
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/ProtoSchemaConverterTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/ProtoSchemaConverterTest.java
index 9e025a13eb..b9c9578bca 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/ProtoSchemaConverterTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/ProtoSchemaConverterTest.java
@@ -163,7 +163,8 @@ public void convertRecursiveTopMessage() {
       Assert.fail("No exception raised");
     } catch (InvalidArgumentException e) {
       Assert.assertEquals(
-          "Recursive type is not supported:com.google.cloud.bigquery.storage.test.RecursiveTypeTopMessage",
+          "Recursive type is not"
+              + " supported:com.google.cloud.bigquery.storage.test.RecursiveTypeTopMessage",
           e.getMessage());
     }
   }
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageLongRunningTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageLongRunningTest.java
index 7f6b30f033..99ca37a2b9 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageLongRunningTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageLongRunningTest.java
@@ -102,7 +102,8 @@ public void testLongRunningReadSession() throws InterruptedException, ExecutionE
 
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         5,
         session.getStreamsCount());
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageTest.java
index 2e0ee030a1..f174d48457 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryStorageTest.java
@@ -136,7 +136,8 @@ public void testSimpleRead() {
             /* maxStreamCount = */ 1);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
@@ -171,7 +172,8 @@ public void testSimpleReadAndResume() {
             /* maxStreamCount = */ 1);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
@@ -223,7 +225,8 @@ public void testFilter() throws IOException {
     ReadSession session = client.createReadSession(request);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
@@ -285,7 +288,8 @@ public void testColumnSelection() throws IOException {
     ReadSession session = client.createReadSession(request);
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
@@ -740,16 +744,10 @@ public void testStructAndArraySqlTypes() throws InterruptedException, IOExceptio
     String tableName = "test_struct_and_array_sql_types";
     String createTableStatement =
         String.format(
-            " CREATE TABLE %s.%s "
-                + " (array_field ARRAY<INT64>,"
-                + "  struct_field STRUCT<int_field INT64 NOT NULL, str_field STRING NOT NULL> NOT NULL)"
-                + " OPTIONS( "
-                + "   description=\"a table with array and time column types\" "
-                + " ) "
-                + "AS "
-                + "   SELECT "
-                + "     [1, 2, 3],"
-                + "     (10, 'abc')",
+            " CREATE TABLE %s.%s  (array_field ARRAY<INT64>,  struct_field STRUCT<int_field INT64"
+                + " NOT NULL, str_field STRING NOT NULL> NOT NULL) OPTIONS(    description=\"a"
+                + " table with array and time column types\"  ) AS    SELECT      [1, 2, 3],    "
+                + " (10, 'abc')",
             DATASET, tableName);
 
     RunQueryJobAndExpectSuccess(QueryJobConfiguration.newBuilder(createTableStatement).build());
@@ -879,7 +877,8 @@ private void ProcessRowsAtSnapshot(
     ReadSession session = client.createReadSession(createSessionRequestBuilder.build());
     assertEquals(
         String.format(
-            "Did not receive expected number of streams for table '%s' CreateReadSession response:%n%s",
+            "Did not receive expected number of streams for table '%s' CreateReadSession"
+                + " response:%n%s",
             table, session.toString()),
         1,
         session.getStreamsCount());
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryWriteManualClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryWriteManualClientTest.java
index 3c1eeef8fd..e52b398d82 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryWriteManualClientTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/it/ITBigQueryWriteManualClientTest.java
@@ -457,10 +457,12 @@ public void testComplicateSchemaWithPendingStream()
     Iterator<FieldValueList> queryIter = queryResult.getValues().iterator();
     assertTrue(queryIter.hasNext());
     assertEquals(
-        "[FieldValue{attribute=REPEATED, value=[FieldValue{attribute=PRIMITIVE, value=aaa}, FieldValue{attribute=PRIMITIVE, value=aaa}]}]",
+        "[FieldValue{attribute=REPEATED, value=[FieldValue{attribute=PRIMITIVE, value=aaa},"
+            + " FieldValue{attribute=PRIMITIVE, value=aaa}]}]",
         queryIter.next().get(1).getRepeatedValue().toString());
     assertEquals(
-        "[FieldValue{attribute=REPEATED, value=[FieldValue{attribute=PRIMITIVE, value=bbb}, FieldValue{attribute=PRIMITIVE, value=bbb}]}]",
+        "[FieldValue{attribute=REPEATED, value=[FieldValue{attribute=PRIMITIVE, value=bbb},"
+            + " FieldValue{attribute=PRIMITIVE, value=bbb}]}]",
         queryIter.next().get(1).getRepeatedValue().toString());
     assertFalse(queryIter.hasNext());
   }
diff --git a/proto-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/TableProto.java b/proto-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/TableProto.java
index a84bff59c6..a6845a1390 100644
--- a/proto-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/TableProto.java
+++ b/proto-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/TableProto.java
@@ -44,32 +44,52 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
 
   static {
     java.lang.String[] descriptorData = {
-      "\n,google/cloud/bigquery/storage/v1/table"
-          + ".proto\022 google.cloud.bigquery.storage.v1"
-          + "\032\037google/api/field_behavior.proto\"Q\n\013Tab"
-          + "leSchema\022B\n\006fields\030\001 \003(\01322.google.cloud."
-          + "bigquery.storage.v1.TableFieldSchema\"\205\005\n"
-          + "\020TableFieldSchema\022\021\n\004name\030\001 \001(\tB\003\340A\002\022J\n\004"
-          + "type\030\002 \001(\01627.google.cloud.bigquery.stora"
-          + "ge.v1.TableFieldSchema.TypeB\003\340A\002\022J\n\004mode"
-          + "\030\003 \001(\01627.google.cloud.bigquery.storage.v"
-          + "1.TableFieldSchema.ModeB\003\340A\001\022G\n\006fields\030\004"
-          + " \003(\01322.google.cloud.bigquery.storage.v1."
-          + "TableFieldSchemaB\003\340A\001\022\030\n\013description\030\006 \001"
-          + "(\tB\003\340A\001\022\027\n\nmax_length\030\007 \001(\003B\003\340A\001\022\026\n\tprec"
-          + "ision\030\010 \001(\003B\003\340A\001\022\022\n\005scale\030\t \001(\003B\003\340A\001\"\325\001\n"
-          + "\004Type\022\024\n\020TYPE_UNSPECIFIED\020\000\022\n\n\006STRING\020\001\022"
-          + "\t\n\005INT64\020\002\022\n\n\006DOUBLE\020\003\022\n\n\006STRUCT\020\004\022\t\n\005BY"
-          + "TES\020\005\022\010\n\004BOOL\020\006\022\r\n\tTIMESTAMP\020\007\022\010\n\004DATE\020\010"
-          + "\022\010\n\004TIME\020\t\022\014\n\010DATETIME\020\n\022\r\n\tGEOGRAPHY\020\013\022"
-          + "\013\n\007NUMERIC\020\014\022\016\n\nBIGNUMERIC\020\r\022\014\n\010INTERVAL"
-          + "\020\016\022\010\n\004JSON\020\017\"F\n\004Mode\022\024\n\020MODE_UNSPECIFIED"
-          + "\020\000\022\014\n\010NULLABLE\020\001\022\014\n\010REQUIRED\020\002\022\014\n\010REPEAT"
-          + "ED\020\003B\303\001\n$com.google.cloud.bigquery.stora"
-          + "ge.v1B\nTableProtoP\001ZGgoogle.golang.org/g"
-          + "enproto/googleapis/cloud/bigquery/storag"
-          + "e/v1;storage\252\002 Google.Cloud.BigQuery.Sto"
-          + "rage.V1\312\002 Google\\Cloud\\BigQuery\\Storage\\"
+      "\n"
+          + ",google/cloud/bigquery/storage/v1/table.proto\022"
+          + " google.cloud.bigquery.storage.v1\032\037google/api/field_behavior.proto\"Q\n"
+          + "\013TableSchema\022B\n"
+          + "\006fields\030\001"
+          + " \003(\01322.google.cloud.bigquery.storage.v1.TableFieldSchema\"\205\005\n"
+          + "\020TableFieldSchema\022\021\n"
+          + "\004name\030\001 \001(\tB\003\340A\002\022J\n"
+          + "\004type\030\002"
+          + " \001(\01627.google.cloud.bigquery.storage.v1.TableFieldSchema.TypeB\003\340A\002\022J\n"
+          + "\004mode\030\003"
+          + " \001(\01627.google.cloud.bigquery.storage.v1.TableFieldSchema.ModeB\003\340A\001\022G\n"
+          + "\006fields\030\004"
+          + " \003(\01322.google.cloud.bigquery.storage.v1.TableFieldSchemaB\003\340A\001\022\030\n"
+          + "\013description\030\006 \001(\tB\003\340A\001\022\027\n\n"
+          + "max_length\030\007 \001(\003B\003\340A\001\022\026\n"
+          + "\tprecision\030\010 \001(\003B\003\340A\001\022\022\n"
+          + "\005scale\030\t \001(\003B\003\340A\001\"\325\001\n"
+          + "\004Type\022\024\n"
+          + "\020TYPE_UNSPECIFIED\020\000\022\n\n"
+          + "\006STRING\020\001\022\t\n"
+          + "\005INT64\020\002\022\n\n"
+          + "\006DOUBLE\020\003\022\n\n"
+          + "\006STRUCT\020\004\022\t\n"
+          + "\005BYTES\020\005\022\010\n"
+          + "\004BOOL\020\006\022\r\n"
+          + "\tTIMESTAMP\020\007\022\010\n"
+          + "\004DATE\020\010\022\010\n"
+          + "\004TIME\020\t\022\014\n"
+          + "\010DATETIME\020\n"
+          + "\022\r\n"
+          + "\tGEOGRAPHY\020\013\022\013\n"
+          + "\007NUMERIC\020\014\022\016\n\n"
+          + "BIGNUMERIC\020\r"
+          + "\022\014\n"
+          + "\010INTERVAL\020\016\022\010\n"
+          + "\004JSON\020\017\"F\n"
+          + "\004Mode\022\024\n"
+          + "\020MODE_UNSPECIFIED\020\000\022\014\n"
+          + "\010NULLABLE\020\001\022\014\n"
+          + "\010REQUIRED\020\002\022\014\n"
+          + "\010REPEATED\020\003B\303\001\n"
+          + "$com.google.cloud.bigquery.storage.v1B\n"
+          + "TableProtoP\001ZGgoogle.golang.org/g"
+          + "enproto/googleapis/cloud/bigquery/storage/v1;storage\252\002"
+          + " Google.Cloud.BigQuery.Storage.V1\312\002 Google\\Cloud\\BigQuery\\Storage\\"
           + "V1b\006proto3"
     };
     descriptor =
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamProto.java b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamProto.java
index c4a2531dcf..835abe7c98 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamProto.java
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamProto.java
@@ -56,63 +56,67 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
 
   static {
     java.lang.String[] descriptorData = {
-      "\n2google/cloud/bigquery/storage/v1beta2/"
-          + "stream.proto\022%google.cloud.bigquery.stor"
+      "\n"
+          + "2google/cloud/bigquery/storage/v1beta2/stream.proto\022%google.cloud.bigquery.stor"
           + "age.v1beta2\032\037google/api/field_behavior.p"
           + "roto\032\031google/api/resource.proto\0321google/"
-          + "cloud/bigquery/storage/v1beta2/arrow.pro"
-          + "to\0320google/cloud/bigquery/storage/v1beta"
+          + "cloud/bigquery/storage/v1beta2/arrow.proto\0320google/cloud/bigquery/storage/v1beta"
           + "2/avro.proto\0321google/cloud/bigquery/stor"
-          + "age/v1beta2/table.proto\032\037google/protobuf"
-          + "/timestamp.proto\"\362\007\n\013ReadSession\022\021\n\004name"
-          + "\030\001 \001(\tB\003\340A\003\0224\n\013expire_time\030\002 \001(\0132\032.googl"
-          + "e.protobuf.TimestampB\003\340A\003\022K\n\013data_format"
-          + "\030\003 \001(\01621.google.cloud.bigquery.storage.v"
-          + "1beta2.DataFormatB\003\340A\005\022M\n\013avro_schema\030\004 "
-          + "\001(\01321.google.cloud.bigquery.storage.v1be"
-          + "ta2.AvroSchemaB\003\340A\003H\000\022O\n\014arrow_schema\030\005 "
-          + "\001(\01322.google.cloud.bigquery.storage.v1be"
-          + "ta2.ArrowSchemaB\003\340A\003H\000\0224\n\005table\030\006 \001(\tB%\340"
-          + "A\005\372A\037\n\035bigquery.googleapis.com/Table\022_\n\017"
-          + "table_modifiers\030\007 \001(\0132A.google.cloud.big"
-          + "query.storage.v1beta2.ReadSession.TableM"
-          + "odifiersB\003\340A\001\022^\n\014read_options\030\010 \001(\0132C.go"
-          + "ogle.cloud.bigquery.storage.v1beta2.Read"
-          + "Session.TableReadOptionsB\003\340A\001\022G\n\007streams"
-          + "\030\n \003(\01321.google.cloud.bigquery.storage.v"
-          + "1beta2.ReadStreamB\003\340A\003\032C\n\016TableModifiers"
-          + "\0221\n\rsnapshot_time\030\001 \001(\0132\032.google.protobu"
-          + "f.Timestamp\032\260\001\n\020TableReadOptions\022\027\n\017sele"
-          + "cted_fields\030\001 \003(\t\022\027\n\017row_restriction\030\002 \001"
-          + "(\t\022j\n\033arrow_serialization_options\030\003 \001(\0132"
-          + "@.google.cloud.bigquery.storage.v1beta2."
-          + "ArrowSerializationOptionsB\003\340A\001:k\352Ah\n*big"
-          + "querystorage.googleapis.com/ReadSession\022"
-          + ":projects/{project}/locations/{location}"
-          + "/sessions/{session}B\010\n\006schema\"\234\001\n\nReadSt"
-          + "ream\022\021\n\004name\030\001 \001(\tB\003\340A\003:{\352Ax\n)bigqueryst"
-          + "orage.googleapis.com/ReadStream\022Kproject"
-          + "s/{project}/locations/{location}/session"
-          + "s/{session}/streams/{stream}\"\347\003\n\013WriteSt"
-          + "ream\022\021\n\004name\030\001 \001(\tB\003\340A\003\022J\n\004type\030\002 \001(\01627."
-          + "google.cloud.bigquery.storage.v1beta2.Wr"
-          + "iteStream.TypeB\003\340A\005\0224\n\013create_time\030\003 \001(\013"
-          + "2\032.google.protobuf.TimestampB\003\340A\003\0224\n\013com"
-          + "mit_time\030\004 \001(\0132\032.google.protobuf.Timesta"
-          + "mpB\003\340A\003\022M\n\014table_schema\030\005 \001(\01322.google.c"
-          + "loud.bigquery.storage.v1beta2.TableSchem"
-          + "aB\003\340A\003\"F\n\004Type\022\024\n\020TYPE_UNSPECIFIED\020\000\022\r\n\t"
-          + "COMMITTED\020\001\022\013\n\007PENDING\020\002\022\014\n\010BUFFERED\020\003:v"
-          + "\352As\n*bigquerystorage.googleapis.com/Writ"
-          + "eStream\022Eprojects/{project}/datasets/{da"
-          + "taset}/tables/{table}/streams/{stream}*>"
-          + "\n\nDataFormat\022\033\n\027DATA_FORMAT_UNSPECIFIED\020"
-          + "\000\022\010\n\004AVRO\020\001\022\t\n\005ARROW\020\002B\340\001\n)com.google.cl"
-          + "oud.bigquery.storage.v1beta2B\013StreamProt"
+          + "age/v1beta2/table.proto\032\037google/protobuf/timestamp.proto\"\362\007\n"
+          + "\013ReadSession\022\021\n"
+          + "\004name\030\001 \001(\tB\003\340A\003\0224\n"
+          + "\013expire_time\030\002 \001(\0132\032.google.protobuf.TimestampB\003\340A\003\022K\n"
+          + "\013data_format\030\003"
+          + " \001(\01621.google.cloud.bigquery.storage.v1beta2.DataFormatB\003\340A\005\022M\n"
+          + "\013avro_schema\030\004 "
+          + "\001(\01321.google.cloud.bigquery.storage.v1beta2.AvroSchemaB\003\340A\003H\000\022O\n"
+          + "\014arrow_schema\030\005 "
+          + "\001(\01322.google.cloud.bigquery.storage.v1beta2.ArrowSchemaB\003\340A\003H\000\0224\n"
+          + "\005table\030\006 \001(\tB%\340A\005\372A\037\n"
+          + "\035bigquery.googleapis.com/Table\022_\n"
+          + "\017table_modifiers\030\007 \001(\0132A.google.cloud.big"
+          + "query.storage.v1beta2.ReadSession.TableModifiersB\003\340A\001\022^\n"
+          + "\014read_options\030\010 \001(\0132C.go"
+          + "ogle.cloud.bigquery.storage.v1beta2.ReadSession.TableReadOptionsB\003\340A\001\022G\n"
+          + "\007streams\030\n"
+          + " \003(\01321.google.cloud.bigquery.storage.v1beta2.ReadStreamB\003\340A\003\032C\n"
+          + "\016TableModifiers\0221\n\r"
+          + "snapshot_time\030\001 \001(\0132\032.google.protobuf.Timestamp\032\260\001\n"
+          + "\020TableReadOptions\022\027\n"
+          + "\017selected_fields\030\001 \003(\t\022\027\n"
+          + "\017row_restriction\030\002 \001(\t\022j\n"
+          + "\033arrow_serialization_options\030\003 \001(\0132"
+          + "@.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptionsB\003\340A\001:k\352Ah\n"
+          + "*bigquerystorage.googleapis.com/ReadSession\022"
+          + ":projects/{project}/locations/{location}/sessions/{session}B\010\n"
+          + "\006schema\"\234\001\n\n"
+          + "ReadStream\022\021\n"
+          + "\004name\030\001 \001(\tB\003\340A\003:{\352Ax\n"
+          + ")bigquerystorage.googleapis.com/ReadStream\022Kproject"
+          + "s/{project}/locations/{location}/sessions/{session}/streams/{stream}\"\347\003\n"
+          + "\013WriteStream\022\021\n"
+          + "\004name\030\001 \001(\tB\003\340A\003\022J\n"
+          + "\004type\030\002 \001(\01627."
+          + "google.cloud.bigquery.storage.v1beta2.WriteStream.TypeB\003\340A\005\0224\n"
+          + "\013create_time\030\003 \001(\0132\032.google.protobuf.TimestampB\003\340A\003\0224\n"
+          + "\013commit_time\030\004 \001(\0132\032.google.protobuf.TimestampB\003\340A\003\022M\n"
+          + "\014table_schema\030\005 \001(\01322.google.c"
+          + "loud.bigquery.storage.v1beta2.TableSchemaB\003\340A\003\"F\n"
+          + "\004Type\022\024\n"
+          + "\020TYPE_UNSPECIFIED\020\000\022\r\n"
+          + "\tCOMMITTED\020\001\022\013\n"
+          + "\007PENDING\020\002\022\014\n"
+          + "\010BUFFERED\020\003:v\352As\n"
+          + "*bigquerystorage.googleapis.com/WriteStream\022Eprojects/{project}/datasets/{da"
+          + "taset}/tables/{table}/streams/{stream}*>\n\n"
+          + "DataFormat\022\033\n"
+          + "\027DATA_FORMAT_UNSPECIFIED\020\000\022\010\n"
+          + "\004AVRO\020\001\022\t\n"
+          + "\005ARROW\020\002B\340\001\n"
+          + ")com.google.cloud.bigquery.storage.v1beta2B\013StreamProt"
           + "oP\001ZLgoogle.golang.org/genproto/googleap"
-          + "is/cloud/bigquery/storage/v1beta2;storag"
-          + "e\352AU\n\035bigquery.googleapis.com/Table\0224pro"
-          + "jects/{project}/datasets/{dataset}/table"
+          + "is/cloud/bigquery/storage/v1beta2;storage\352AU\n"
+          + "\035bigquery.googleapis.com/Table\0224projects/{project}/datasets/{dataset}/table"
           + "s/{table}b\006proto3"
     };
     descriptor =
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/TableProto.java b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/TableProto.java
index 29abed0789..2e445aef27 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/TableProto.java
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/TableProto.java
@@ -44,29 +44,47 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
 
   static {
     java.lang.String[] descriptorData = {
-      "\n1google/cloud/bigquery/storage/v1beta2/"
-          + "table.proto\022%google.cloud.bigquery.stora"
-          + "ge.v1beta2\032\037google/api/field_behavior.pr"
-          + "oto\"V\n\013TableSchema\022G\n\006fields\030\001 \003(\01327.goo"
-          + "gle.cloud.bigquery.storage.v1beta2.Table"
-          + "FieldSchema\"\317\004\n\020TableFieldSchema\022\021\n\004name"
-          + "\030\001 \001(\tB\003\340A\002\022O\n\004type\030\002 \001(\0162<.google.cloud"
-          + ".bigquery.storage.v1beta2.TableFieldSche"
-          + "ma.TypeB\003\340A\002\022O\n\004mode\030\003 \001(\0162<.google.clou"
-          + "d.bigquery.storage.v1beta2.TableFieldSch"
-          + "ema.ModeB\003\340A\001\022L\n\006fields\030\004 \003(\01327.google.c"
-          + "loud.bigquery.storage.v1beta2.TableField"
-          + "SchemaB\003\340A\001\022\030\n\013description\030\006 \001(\tB\003\340A\001\"\325\001"
-          + "\n\004Type\022\024\n\020TYPE_UNSPECIFIED\020\000\022\n\n\006STRING\020\001"
-          + "\022\t\n\005INT64\020\002\022\n\n\006DOUBLE\020\003\022\n\n\006STRUCT\020\004\022\t\n\005B"
-          + "YTES\020\005\022\010\n\004BOOL\020\006\022\r\n\tTIMESTAMP\020\007\022\010\n\004DATE\020"
-          + "\010\022\010\n\004TIME\020\t\022\014\n\010DATETIME\020\n\022\r\n\tGEOGRAPHY\020\013"
-          + "\022\013\n\007NUMERIC\020\014\022\016\n\nBIGNUMERIC\020\r\022\014\n\010INTERVA"
-          + "L\020\016\022\010\n\004JSON\020\017\"F\n\004Mode\022\024\n\020MODE_UNSPECIFIE"
-          + "D\020\000\022\014\n\010NULLABLE\020\001\022\014\n\010REQUIRED\020\002\022\014\n\010REPEA"
-          + "TED\020\003B\207\001\n)com.google.cloud.bigquery.stor"
-          + "age.v1beta2B\nTableProtoP\001ZLgoogle.golang"
-          + ".org/genproto/googleapis/cloud/bigquery/"
+      "\n"
+          + "1google/cloud/bigquery/storage/v1beta2/table.proto\022%google.cloud.bigquery.stora"
+          + "ge.v1beta2\032\037google/api/field_behavior.proto\"V\n"
+          + "\013TableSchema\022G\n"
+          + "\006fields\030\001 \003(\01327.goo"
+          + "gle.cloud.bigquery.storage.v1beta2.TableFieldSchema\"\317\004\n"
+          + "\020TableFieldSchema\022\021\n"
+          + "\004name\030\001 \001(\tB\003\340A\002\022O\n"
+          + "\004type\030\002 \001(\0162<.google.cloud"
+          + ".bigquery.storage.v1beta2.TableFieldSchema.TypeB\003\340A\002\022O\n"
+          + "\004mode\030\003 \001(\0162<.google.clou"
+          + "d.bigquery.storage.v1beta2.TableFieldSchema.ModeB\003\340A\001\022L\n"
+          + "\006fields\030\004 \003(\01327.google.c"
+          + "loud.bigquery.storage.v1beta2.TableFieldSchemaB\003\340A\001\022\030\n"
+          + "\013description\030\006 \001(\tB\003\340A\001\"\325\001\n"
+          + "\004Type\022\024\n"
+          + "\020TYPE_UNSPECIFIED\020\000\022\n\n"
+          + "\006STRING\020\001\022\t\n"
+          + "\005INT64\020\002\022\n\n"
+          + "\006DOUBLE\020\003\022\n\n"
+          + "\006STRUCT\020\004\022\t\n"
+          + "\005BYTES\020\005\022\010\n"
+          + "\004BOOL\020\006\022\r\n"
+          + "\tTIMESTAMP\020\007\022\010\n"
+          + "\004DATE\020\010\022\010\n"
+          + "\004TIME\020\t\022\014\n"
+          + "\010DATETIME\020\n"
+          + "\022\r\n"
+          + "\tGEOGRAPHY\020\013\022\013\n"
+          + "\007NUMERIC\020\014\022\016\n\n"
+          + "BIGNUMERIC\020\r"
+          + "\022\014\n"
+          + "\010INTERVAL\020\016\022\010\n"
+          + "\004JSON\020\017\"F\n"
+          + "\004Mode\022\024\n"
+          + "\020MODE_UNSPECIFIED\020\000\022\014\n"
+          + "\010NULLABLE\020\001\022\014\n"
+          + "\010REQUIRED\020\002\022\014\n"
+          + "\010REPEATED\020\003B\207\001\n"
+          + ")com.google.cloud.bigquery.storage.v1beta2B\n"
+          + "TableProtoP\001ZLgoogle.golang.org/genproto/googleapis/cloud/bigquery/"
           + "storage/v1beta2;storageb\006proto3"
     };
     descriptor =