diff --git a/CHANGELOG.md b/CHANGELOG.md index 520e6cf773..5e2e777717 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,20 @@ # Changelog +## [2.34.2](https://github.com/googleapis/java-bigquerystorage/compare/v2.34.1...v2.34.2) (2023-03-30) + + +### Bug Fixes + +* Correct AppendSerializtionError typo ([#2037](https://github.com/googleapis/java-bigquerystorage/issues/2037)) ([e67e913](https://github.com/googleapis/java-bigquerystorage/commit/e67e913f34fda4f4cc523c0248e5344232c0b736)) + + +### Dependencies + +* Update dependency com.google.cloud:google-cloud-bigquery to v2.24.0 ([#2054](https://github.com/googleapis/java-bigquerystorage/issues/2054)) ([e3156c7](https://github.com/googleapis/java-bigquerystorage/commit/e3156c7b525f7df2f3fe756f096e7fb1352fae8e)) +* Update dependency com.google.cloud:google-cloud-bigquery to v2.24.1 ([#2056](https://github.com/googleapis/java-bigquerystorage/issues/2056)) ([a989ac6](https://github.com/googleapis/java-bigquerystorage/commit/a989ac63d813cc98dcc13200a950fe3edad10bdf)) +* Update dependency com.google.cloud:google-cloud-bigquery to v2.24.3 ([#2058](https://github.com/googleapis/java-bigquerystorage/issues/2058)) ([9346667](https://github.com/googleapis/java-bigquerystorage/commit/934666737a92ec3220c6a186cc1af0f1adabb00c)) +* Update dependency com.google.cloud:google-cloud-shared-dependencies to v3.6.0 ([#2063](https://github.com/googleapis/java-bigquerystorage/issues/2063)) ([965de7b](https://github.com/googleapis/java-bigquerystorage/commit/965de7bf78884cca30e6e6d672b74d734bda840d)) + ## [2.34.1](https://github.com/googleapis/java-bigquerystorage/compare/v2.34.0...v2.34.1) (2023-03-21) diff --git a/README.md b/README.md index a95f4c5bd3..145a863499 100644 --- a/README.md +++ b/README.md @@ -19,7 +19,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file: com.google.cloud libraries-bom - 26.10.0 + 26.11.0 pom import @@ -41,7 +41,7 @@ If you are using Maven without BOM, add this to your dependencies: com.google.cloud google-cloud-bigquerystorage - 2.34.0 + 2.34.1 ``` @@ -49,20 +49,20 @@ If you are using Maven without BOM, add this to your dependencies: If you are using Gradle 5.x or later, add this to your dependencies: ```Groovy -implementation platform('com.google.cloud:libraries-bom:26.10.0') +implementation platform('com.google.cloud:libraries-bom:26.11.0') implementation 'com.google.cloud:google-cloud-bigquerystorage' ``` If you are using Gradle without BOM, add this to your dependencies: ```Groovy -implementation 'com.google.cloud:google-cloud-bigquerystorage:2.34.0' +implementation 'com.google.cloud:google-cloud-bigquerystorage:2.34.1' ``` If you are using SBT, add this to your dependencies: ```Scala -libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.34.0" +libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.34.1" ``` @@ -219,7 +219,7 @@ Java is a registered trademark of Oracle and/or its affiliates. [kokoro-badge-link-5]: http://storage.googleapis.com/cloud-devrel-public/java/badges/java-bigquerystorage/java11.html [stability-image]: https://img.shields.io/badge/stability-stable-green [maven-version-image]: https://img.shields.io/maven-central/v/com.google.cloud/google-cloud-bigquerystorage.svg -[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-bigquerystorage/2.34.0 +[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-bigquerystorage/2.34.1 [authentication]: https://github.com/googleapis/google-cloud-java#authentication [auth-scopes]: https://developers.google.com/identity/protocols/oauth2/scopes [predefined-iam-roles]: https://cloud.google.com/iam/docs/understanding-roles#predefined_roles diff --git a/google-cloud-bigquerystorage-bom/pom.xml b/google-cloud-bigquerystorage-bom/pom.xml index 2ae50f3072..fa57f671e6 100644 --- a/google-cloud-bigquerystorage-bom/pom.xml +++ b/google-cloud-bigquerystorage-bom/pom.xml @@ -3,7 +3,7 @@ 4.0.0 com.google.cloud google-cloud-bigquerystorage-bom - 2.34.1 + 2.34.2 pom com.google.cloud @@ -52,37 +52,37 @@ com.google.cloud google-cloud-bigquerystorage - 2.34.1 + 2.34.2 com.google.api.grpc grpc-google-cloud-bigquerystorage-v1beta1 - 0.158.1 + 0.158.2 com.google.api.grpc grpc-google-cloud-bigquerystorage-v1beta2 - 0.158.1 + 0.158.2 com.google.api.grpc grpc-google-cloud-bigquerystorage-v1 - 2.34.1 + 2.34.2 com.google.api.grpc proto-google-cloud-bigquerystorage-v1beta1 - 0.158.1 + 0.158.2 com.google.api.grpc proto-google-cloud-bigquerystorage-v1beta2 - 0.158.1 + 0.158.2 com.google.api.grpc proto-google-cloud-bigquerystorage-v1 - 2.34.1 + 2.34.2 diff --git a/google-cloud-bigquerystorage/pom.xml b/google-cloud-bigquerystorage/pom.xml index a7548d3c8f..94d1178eac 100644 --- a/google-cloud-bigquerystorage/pom.xml +++ b/google-cloud-bigquerystorage/pom.xml @@ -3,7 +3,7 @@ 4.0.0 com.google.cloud google-cloud-bigquerystorage - 2.34.1 + 2.34.2 jar BigQuery Storage https://github.com/googleapis/java-bigquerystorage @@ -11,7 +11,7 @@ com.google.cloud google-cloud-bigquerystorage-parent - 2.34.1 + 2.34.2 google-cloud-bigquerystorage diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java index 3d713fd914..1aeb911943 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/ConnectionWorker.java @@ -21,7 +21,7 @@ import com.google.api.gax.rpc.FixedHeaderProvider; import com.google.auto.value.AutoValue; import com.google.cloud.bigquery.storage.v1.AppendRowsRequest.ProtoData; -import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializtionError; +import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializationError; import com.google.cloud.bigquery.storage.v1.StreamConnection.DoneCallback; import com.google.cloud.bigquery.storage.v1.StreamConnection.RequestCallback; import com.google.common.annotations.VisibleForTesting; @@ -901,8 +901,8 @@ private void requestCallback(AppendRowsResponse response) { rowIndexToErrorMessage.put( Math.toIntExact(rowError.getIndex()), rowError.getMessage()); } - AppendSerializtionError exception = - new AppendSerializtionError( + AppendSerializationError exception = + new AppendSerializationError( response.getError().getCode(), response.getError().getMessage(), streamName, diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/Exceptions.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/Exceptions.java index 4bc0d97e0f..8e13121414 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/Exceptions.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/Exceptions.java @@ -216,10 +216,8 @@ public static StorageException toStorageException(Throwable exception) { } /** - * This exception is thrown from {@link JsonStreamWriter#append()} when the client side Json to - * Proto serializtion fails. It can also be thrown by the server in case rows contains invalid - * data. The exception contains a Map of indexes of faulty rows and the corresponding error - * message. + * This class has a typo in the name. It will be removed soon. Please use {@link + * AppendSerializationError} */ public static class AppendSerializtionError extends StatusRuntimeException { private final Map rowIndexToErrorMessage; @@ -244,6 +242,23 @@ public String getStreamName() { } } + /** + * This exception is thrown from {@link JsonStreamWriter#append()} when the client side Json to + * Proto serializtion fails. It can also be thrown by the server in case rows contains invalid + * data. The exception contains a Map of indexes of faulty rows and the corresponding error + * message. + */ + public static class AppendSerializationError extends AppendSerializtionError { + + public AppendSerializationError( + int codeValue, + String description, + String streamName, + Map rowIndexToErrorMessage) { + super(codeValue, description, streamName, rowIndexToErrorMessage); + } + } + /** This exception is used internally to handle field level parsing errors. */ public static class FieldParseError extends IllegalArgumentException { private final String fieldName; diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriter.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriter.java index edf40c1e64..415830d6ec 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriter.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriter.java @@ -20,7 +20,7 @@ import com.google.api.gax.core.CredentialsProvider; import com.google.api.gax.core.ExecutorProvider; import com.google.api.gax.rpc.TransportChannelProvider; -import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializtionError; +import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializationError; import com.google.common.base.Preconditions; import com.google.protobuf.Descriptors; import com.google.protobuf.Descriptors.Descriptor; @@ -194,7 +194,8 @@ public ApiFuture append(JSONArray jsonArr, long offset) // Any error in convertJsonToProtoMessage will throw an // IllegalArgumentException/IllegalStateException/NullPointerException. // IllegalArgumentException will be collected into a Map of row indexes to error messages. - // After the conversion is finished an AppendSerializtionError exception that contains all the + // After the conversion is finished an AppendSerializationError exception that contains all + // the // conversion errors will be thrown. long currentRequestSize = 0; Map rowIndexToErrorMessage = new HashMap<>(); @@ -224,7 +225,7 @@ public ApiFuture append(JSONArray jsonArr, long offset) } if (!rowIndexToErrorMessage.isEmpty()) { - throw new AppendSerializtionError( + throw new AppendSerializationError( Code.INVALID_ARGUMENT.getNumber(), "Append serialization failed for writer: " + streamName, streamName, diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriterTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriterTest.java index a748678839..50532b1e0a 100644 --- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriterTest.java +++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/JsonStreamWriterTest.java @@ -36,7 +36,7 @@ import com.google.cloud.bigquery.storage.test.Test.RepetitionType; import com.google.cloud.bigquery.storage.test.Test.UpdatedFooType; import com.google.cloud.bigquery.storage.v1.ConnectionWorkerPool.Settings; -import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializtionError; +import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializationError; import com.google.cloud.bigquery.storage.v1.TableFieldSchema.Mode; import com.google.protobuf.ByteString; import com.google.protobuf.Descriptors.DescriptorValidationException; @@ -1096,7 +1096,7 @@ public void testWithoutIgnoreUnknownFieldsUpdateFail() throws Exception { try { ApiFuture appendFuture = writer.append(jsonArr); Assert.fail("expected ExecutionException"); - } catch (AppendSerializtionError ex) { + } catch (AppendSerializationError ex) { assertEquals( "JSONObject has fields unknown to BigQuery: root.test_unknown.", ex.getRowIndexToErrorMessage().get(1)); @@ -1188,7 +1188,7 @@ public void testFlowControlSettingNoLimitBehavior() throws Exception { } @Test - public void testMultipleAppendSerializtionErrors() + public void testMultipleAppendSerializationErrors() throws DescriptorValidationException, IOException, InterruptedException { FooType expectedProto = FooType.newBuilder().setFoo("allen").build(); JSONObject foo = new JSONObject(); @@ -1213,10 +1213,10 @@ public void testMultipleAppendSerializtionErrors() getTestJsonStreamWriterBuilder(TEST_STREAM, TABLE_SCHEMA).build()) { try { ApiFuture appendFuture = writer.append(jsonArr); - Assert.fail("expected AppendSerializtionError"); - } catch (AppendSerializtionError appendSerializtionError) { + Assert.fail("expected AppendSerializationError"); + } catch (AppendSerializationError appendSerializationError) { Map rowIndexToErrorMessage = - appendSerializtionError.getRowIndexToErrorMessage(); + appendSerializationError.getRowIndexToErrorMessage(); assertEquals(2, rowIndexToErrorMessage.size()); assertEquals( "JSONObject has fields unknown to BigQuery: root.not_foo.", @@ -1253,10 +1253,10 @@ public void testBadStringToNumericRowError() getTestJsonStreamWriterBuilder(TEST_STREAM, TABLE_SCHEMA).build()) { try { ApiFuture appendFuture = writer.append(jsonArr); - Assert.fail("expected AppendSerializtionError"); - } catch (AppendSerializtionError appendSerializtionError) { + Assert.fail("expected AppendSerializationError"); + } catch (AppendSerializationError appendSerializationError) { Map rowIndexToErrorMessage = - appendSerializtionError.getRowIndexToErrorMessage(); + appendSerializationError.getRowIndexToErrorMessage(); assertEquals(1, rowIndexToErrorMessage.size()); assertTrue( rowIndexToErrorMessage 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 6972813e20..c80bb960ac 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 @@ -28,7 +28,7 @@ import com.google.cloud.bigquery.Schema; import com.google.cloud.bigquery.storage.test.Test.*; import com.google.cloud.bigquery.storage.v1.*; -import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializtionError; +import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializationError; import com.google.cloud.bigquery.storage.v1.Exceptions.OffsetAlreadyExists; import com.google.cloud.bigquery.storage.v1.Exceptions.OffsetOutOfRange; import com.google.cloud.bigquery.storage.v1.Exceptions.SchemaMismatchedException; @@ -372,8 +372,8 @@ public void testRowErrors() } catch (Throwable t) { assertTrue(t instanceof ExecutionException); t = t.getCause(); - assertTrue(t instanceof AppendSerializtionError); - AppendSerializtionError e = (AppendSerializtionError) t; + assertTrue(t instanceof AppendSerializationError); + AppendSerializationError e = (AppendSerializationError) t; LOG.info("Found row errors on stream: " + e.getStreamName()); assertEquals( "Field foo: STRING(10) has maximum length 10 but got a value with length 12 on field foo.", diff --git a/grpc-google-cloud-bigquerystorage-v1/pom.xml b/grpc-google-cloud-bigquerystorage-v1/pom.xml index 979f88b214..a0681d7dbd 100644 --- a/grpc-google-cloud-bigquerystorage-v1/pom.xml +++ b/grpc-google-cloud-bigquerystorage-v1/pom.xml @@ -4,13 +4,13 @@ 4.0.0 com.google.api.grpc grpc-google-cloud-bigquerystorage-v1 - 2.34.1 + 2.34.2 grpc-google-cloud-bigquerystorage-v1 GRPC library for grpc-google-cloud-bigquerystorage-v1 com.google.cloud google-cloud-bigquerystorage-parent - 2.34.1 + 2.34.2 diff --git a/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryReadGrpc.java b/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryReadGrpc.java index 06dff1c5d2..2a208f90e6 100644 --- a/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryReadGrpc.java +++ b/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryReadGrpc.java @@ -225,7 +225,7 @@ public BigQueryReadFutureStub newStub( * The Read API can be used to read data from BigQuery. * */ - public abstract static class BigQueryReadImplBase implements io.grpc.BindableService { + public interface AsyncService { /** * @@ -249,7 +249,7 @@ public abstract static class BigQueryReadImplBase implements io.grpc.BindableSer * not require manual clean-up by the caller. * */ - public void createReadSession( + default void createReadSession( com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request, io.grpc.stub.StreamObserver responseObserver) { @@ -269,7 +269,7 @@ public void createReadSession( * state of the stream. * */ - public void readRows( + default void readRows( com.google.cloud.bigquery.storage.v1.ReadRowsRequest request, io.grpc.stub.StreamObserver responseObserver) { @@ -293,44 +293,34 @@ public void readRows( * completion. * */ - public void splitReadStream( + default void splitReadStream( com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( getSplitReadStreamMethod(), responseObserver); } + } + + /** + * Base class for the server implementation of the service BigQueryRead. + * + * 
+   * BigQuery Read API.
+   * The Read API can be used to read data from BigQuery.
+   *
+ */ + public abstract static class BigQueryReadImplBase + implements io.grpc.BindableService, AsyncService { @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { - return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) - .addMethod( - getCreateReadSessionMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest, - com.google.cloud.bigquery.storage.v1.ReadSession>( - this, METHODID_CREATE_READ_SESSION))) - .addMethod( - getReadRowsMethod(), - io.grpc.stub.ServerCalls.asyncServerStreamingCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1.ReadRowsRequest, - com.google.cloud.bigquery.storage.v1.ReadRowsResponse>( - this, METHODID_READ_ROWS))) - .addMethod( - getSplitReadStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest, - com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>( - this, METHODID_SPLIT_READ_STREAM))) - .build(); + return BigQueryReadGrpc.bindService(this); } } /** - * + * A stub to allow clients to do asynchronous rpc calls to service BigQueryRead. * * 
    * BigQuery Read API.
@@ -429,7 +419,7 @@ public void splitReadStream(
   }
 
   /**
-   *
+   * A stub to allow clients to do synchronous rpc calls to service BigQueryRead.
    *
    * 
    * BigQuery Read API.
@@ -519,7 +509,7 @@ public com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse splitReadStr
   }
 
   /**
-   *
+   * A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryRead.
    *
    * 
    * BigQuery Read API.
@@ -601,10 +591,10 @@ private static final class MethodHandlers
           io.grpc.stub.ServerCalls.ServerStreamingMethod,
           io.grpc.stub.ServerCalls.ClientStreamingMethod,
           io.grpc.stub.ServerCalls.BidiStreamingMethod {
-    private final BigQueryReadImplBase serviceImpl;
+    private final AsyncService serviceImpl;
     private final int methodId;
 
-    MethodHandlers(BigQueryReadImplBase serviceImpl, int methodId) {
+    MethodHandlers(AsyncService serviceImpl, int methodId) {
       this.serviceImpl = serviceImpl;
       this.methodId = methodId;
     }
@@ -648,6 +638,32 @@ public io.grpc.stub.StreamObserver invoke(
     }
   }
 
+  public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
+    return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+        .addMethod(
+            getCreateReadSessionMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest,
+                    com.google.cloud.bigquery.storage.v1.ReadSession>(
+                    service, METHODID_CREATE_READ_SESSION)))
+        .addMethod(
+            getReadRowsMethod(),
+            io.grpc.stub.ServerCalls.asyncServerStreamingCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1.ReadRowsRequest,
+                    com.google.cloud.bigquery.storage.v1.ReadRowsResponse>(
+                    service, METHODID_READ_ROWS)))
+        .addMethod(
+            getSplitReadStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest,
+                    com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>(
+                    service, METHODID_SPLIT_READ_STREAM)))
+        .build();
+  }
+
   private abstract static class BigQueryReadBaseDescriptorSupplier
       implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
           io.grpc.protobuf.ProtoServiceDescriptorSupplier {
diff --git a/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteGrpc.java b/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteGrpc.java
index e6d4a78c92..7d2259bc0b 100644
--- a/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteGrpc.java
+++ b/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteGrpc.java
@@ -374,7 +374,7 @@ public BigQueryWriteFutureStub newStub(
    * https://cloud.google.com/bigquery/docs/write-api
    * 

    */
-  public abstract static class BigQueryWriteImplBase implements io.grpc.BindableService {
+  public interface AsyncService {
 
     /**
      *
@@ -388,7 +388,7 @@ public abstract static class BigQueryWriteImplBase implements io.grpc.BindableSe
      * soon as an acknowledgement is received.
      * 

      */
-    public void createWriteStream(
+    default void createWriteStream(
         com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request,
         io.grpc.stub.StreamObserver
             responseObserver) {
@@ -426,7 +426,7 @@ public void createWriteStream(
      * committed via the `BatchCommitWriteStreams` rpc.
      *
*/ - public io.grpc.stub.StreamObserver + default io.grpc.stub.StreamObserver appendRows( io.grpc.stub.StreamObserver responseObserver) { @@ -441,7 +441,7 @@ public void createWriteStream( * Gets information about a write stream. * */ - public void getWriteStream( + default void getWriteStream( com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request, io.grpc.stub.StreamObserver responseObserver) { @@ -457,7 +457,7 @@ public void getWriteStream( * stream. Finalize is not supported on the '_default' stream. * */ - public void finalizeWriteStream( + default void finalizeWriteStream( com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request, io.grpc.stub.StreamObserver< com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse> @@ -477,7 +477,7 @@ public void finalizeWriteStream( * for read operations. * */ - public void batchCommitWriteStreams( + default void batchCommitWriteStreams( com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request, io.grpc.stub.StreamObserver< com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse> @@ -498,64 +498,35 @@ public void batchCommitWriteStreams( * Flush is not supported on the _default stream, since it is not BUFFERED. * */ - public void flushRows( + default void flushRows( com.google.cloud.bigquery.storage.v1.FlushRowsRequest request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getFlushRowsMethod(), responseObserver); } + } + + /** + * Base class for the server implementation of the service BigQueryWrite. + * + * 
+   * BigQuery Write API.
+   * The Write API can be used to write data to BigQuery.
+   * For supplementary information about the Write API, see:
+   * https://cloud.google.com/bigquery/docs/write-api
+   *
+ */ + public abstract static class BigQueryWriteImplBase + implements io.grpc.BindableService, AsyncService { @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { - return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) - .addMethod( - getCreateWriteStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest, - com.google.cloud.bigquery.storage.v1.WriteStream>( - this, METHODID_CREATE_WRITE_STREAM))) - .addMethod( - getAppendRowsMethod(), - io.grpc.stub.ServerCalls.asyncBidiStreamingCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1.AppendRowsRequest, - com.google.cloud.bigquery.storage.v1.AppendRowsResponse>( - this, METHODID_APPEND_ROWS))) - .addMethod( - getGetWriteStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest, - com.google.cloud.bigquery.storage.v1.WriteStream>( - this, METHODID_GET_WRITE_STREAM))) - .addMethod( - getFinalizeWriteStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest, - com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse>( - this, METHODID_FINALIZE_WRITE_STREAM))) - .addMethod( - getBatchCommitWriteStreamsMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest, - com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse>( - this, METHODID_BATCH_COMMIT_WRITE_STREAMS))) - .addMethod( - getFlushRowsMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1.FlushRowsRequest, - com.google.cloud.bigquery.storage.v1.FlushRowsResponse>( - this, METHODID_FLUSH_ROWS))) - .build(); + return BigQueryWriteGrpc.bindService(this); } } /** - * + * A stub to allow clients to do asynchronous rpc calls to service BigQueryWrite. * * 
    * BigQuery Write API.
@@ -715,7 +686,7 @@ public void flushRows(
   }
 
   /**
-   *
+   * A stub to allow clients to do synchronous rpc calls to service BigQueryWrite.
    *
    * 
    * BigQuery Write API.
@@ -819,7 +790,7 @@ public com.google.cloud.bigquery.storage.v1.FlushRowsResponse flushRows(
   }
 
   /**
-   *
+   * A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryWrite.
    *
    * 
    * BigQuery Write API.
@@ -940,10 +911,10 @@ private static final class MethodHandlers
           io.grpc.stub.ServerCalls.ServerStreamingMethod,
           io.grpc.stub.ServerCalls.ClientStreamingMethod,
           io.grpc.stub.ServerCalls.BidiStreamingMethod {
-    private final BigQueryWriteImplBase serviceImpl;
+    private final AsyncService serviceImpl;
     private final int methodId;
 
-    MethodHandlers(BigQueryWriteImplBase serviceImpl, int methodId) {
+    MethodHandlers(AsyncService serviceImpl, int methodId) {
       this.serviceImpl = serviceImpl;
       this.methodId = methodId;
     }
@@ -1006,6 +977,53 @@ public io.grpc.stub.StreamObserver invoke(
     }
   }
 
+  public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
+    return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+        .addMethod(
+            getCreateWriteStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest,
+                    com.google.cloud.bigquery.storage.v1.WriteStream>(
+                    service, METHODID_CREATE_WRITE_STREAM)))
+        .addMethod(
+            getAppendRowsMethod(),
+            io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1.AppendRowsRequest,
+                    com.google.cloud.bigquery.storage.v1.AppendRowsResponse>(
+                    service, METHODID_APPEND_ROWS)))
+        .addMethod(
+            getGetWriteStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest,
+                    com.google.cloud.bigquery.storage.v1.WriteStream>(
+                    service, METHODID_GET_WRITE_STREAM)))
+        .addMethod(
+            getFinalizeWriteStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest,
+                    com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse>(
+                    service, METHODID_FINALIZE_WRITE_STREAM)))
+        .addMethod(
+            getBatchCommitWriteStreamsMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest,
+                    com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse>(
+                    service, METHODID_BATCH_COMMIT_WRITE_STREAMS)))
+        .addMethod(
+            getFlushRowsMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1.FlushRowsRequest,
+                    com.google.cloud.bigquery.storage.v1.FlushRowsResponse>(
+                    service, METHODID_FLUSH_ROWS)))
+        .build();
+  }
+
   private abstract static class BigQueryWriteBaseDescriptorSupplier
       implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
           io.grpc.protobuf.ProtoServiceDescriptorSupplier {
diff --git a/grpc-google-cloud-bigquerystorage-v1beta1/pom.xml b/grpc-google-cloud-bigquerystorage-v1beta1/pom.xml
index 09bbdbb1f0..913217f564 100644
--- a/grpc-google-cloud-bigquerystorage-v1beta1/pom.xml
+++ b/grpc-google-cloud-bigquerystorage-v1beta1/pom.xml
@@ -4,13 +4,13 @@
   4.0.0
   com.google.api.grpc
   grpc-google-cloud-bigquerystorage-v1beta1
-  0.158.1
+  0.158.2
   grpc-google-cloud-bigquerystorage-v1beta1
   GRPC library for grpc-google-cloud-bigquerystorage-v1beta1
   
     com.google.cloud
     google-cloud-bigquerystorage-parent
-    2.34.1
+    2.34.2
   
   
     
diff --git a/grpc-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BigQueryStorageGrpc.java b/grpc-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BigQueryStorageGrpc.java
index cf52d1ae7f..af8c4cef7b 100644
--- a/grpc-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BigQueryStorageGrpc.java
+++ b/grpc-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BigQueryStorageGrpc.java
@@ -332,7 +332,7 @@ public BigQueryStorageFutureStub newStub(
    * The BigQuery storage API can be used to read data stored in BigQuery.
    * 

    */
-  public abstract static class BigQueryStorageImplBase implements io.grpc.BindableService {
+  public interface AsyncService {
 
     /**
      *
@@ -350,7 +350,7 @@ public abstract static class BigQueryStorageImplBase implements io.grpc.Bindable
      * not require manual clean-up by the caller.
      * 

      */
-    public void createReadSession(
+    default void createReadSession(
         com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request,
         io.grpc.stub.StreamObserver
             responseObserver) {
@@ -372,7 +372,7 @@ public void createReadSession(
      * session, and may change as other streams continue to read data.
      *
*/ - public void readRows( + default void readRows( com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest request, io.grpc.stub.StreamObserver< com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> @@ -389,7 +389,7 @@ public void readRows( * adding additional workers. * */ - public void batchCreateReadSessionStreams( + default void batchCreateReadSessionStreams( com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest request, io.grpc.stub.StreamObserver< @@ -418,7 +418,7 @@ public void batchCreateReadSessionStreams( * Stream. * */ - public void finalizeStream( + default void finalizeStream( com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( @@ -442,7 +442,7 @@ public void finalizeStream( * This method is guaranteed to be idempotent. * */ - public void splitReadStream( + default void splitReadStream( com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request, io.grpc.stub.StreamObserver< com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse> @@ -450,52 +450,27 @@ public void splitReadStream( io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( getSplitReadStreamMethod(), responseObserver); } + } + + /** + * Base class for the server implementation of the service BigQueryStorage. + * + * 
+   * BigQuery storage API.
+   * The BigQuery storage API can be used to read data stored in BigQuery.
+   *
+ */ + public abstract static class BigQueryStorageImplBase + implements io.grpc.BindableService, AsyncService { @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { - return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) - .addMethod( - getCreateReadSessionMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest, - com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession>( - this, METHODID_CREATE_READ_SESSION))) - .addMethod( - getReadRowsMethod(), - io.grpc.stub.ServerCalls.asyncServerStreamingCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest, - com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>( - this, METHODID_READ_ROWS))) - .addMethod( - getBatchCreateReadSessionStreamsMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta1.Storage - .BatchCreateReadSessionStreamsRequest, - com.google.cloud.bigquery.storage.v1beta1.Storage - .BatchCreateReadSessionStreamsResponse>( - this, METHODID_BATCH_CREATE_READ_SESSION_STREAMS))) - .addMethod( - getFinalizeStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest, - com.google.protobuf.Empty>(this, METHODID_FINALIZE_STREAM))) - .addMethod( - getSplitReadStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest, - com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse>( - this, METHODID_SPLIT_READ_STREAM))) - .build(); + return BigQueryStorageGrpc.bindService(this); } } /** - * + * A stub to allow clients to do asynchronous rpc calls to service BigQueryStorage. * * 
    * BigQuery storage API.
@@ -641,7 +616,7 @@ public void splitReadStream(
   }
 
   /**
-   *
+   * A stub to allow clients to do synchronous rpc calls to service BigQueryStorage.
    *
    * 
    * BigQuery storage API.
@@ -769,7 +744,7 @@ public com.google.protobuf.Empty finalizeStream(
   }
 
   /**
-   *
+   * A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryStorage.
    *
    * 
    * BigQuery storage API.
@@ -893,10 +868,10 @@ private static final class MethodHandlers
           io.grpc.stub.ServerCalls.ServerStreamingMethod,
           io.grpc.stub.ServerCalls.ClientStreamingMethod,
           io.grpc.stub.ServerCalls.BidiStreamingMethod {
-    private final BigQueryStorageImplBase serviceImpl;
+    private final AsyncService serviceImpl;
     private final int methodId;
 
-    MethodHandlers(BigQueryStorageImplBase serviceImpl, int methodId) {
+    MethodHandlers(AsyncService serviceImpl, int methodId) {
       this.serviceImpl = serviceImpl;
       this.methodId = methodId;
     }
@@ -957,6 +932,47 @@ public io.grpc.stub.StreamObserver invoke(
     }
   }
 
+  public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
+    return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+        .addMethod(
+            getCreateReadSessionMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest,
+                    com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession>(
+                    service, METHODID_CREATE_READ_SESSION)))
+        .addMethod(
+            getReadRowsMethod(),
+            io.grpc.stub.ServerCalls.asyncServerStreamingCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,
+                    com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>(
+                    service, METHODID_READ_ROWS)))
+        .addMethod(
+            getBatchCreateReadSessionStreamsMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta1.Storage
+                        .BatchCreateReadSessionStreamsRequest,
+                    com.google.cloud.bigquery.storage.v1beta1.Storage
+                        .BatchCreateReadSessionStreamsResponse>(
+                    service, METHODID_BATCH_CREATE_READ_SESSION_STREAMS)))
+        .addMethod(
+            getFinalizeStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest,
+                    com.google.protobuf.Empty>(service, METHODID_FINALIZE_STREAM)))
+        .addMethod(
+            getSplitReadStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest,
+                    com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse>(
+                    service, METHODID_SPLIT_READ_STREAM)))
+        .build();
+  }
+
   private abstract static class BigQueryStorageBaseDescriptorSupplier
       implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
           io.grpc.protobuf.ProtoServiceDescriptorSupplier {
diff --git a/grpc-google-cloud-bigquerystorage-v1beta2/pom.xml b/grpc-google-cloud-bigquerystorage-v1beta2/pom.xml
index 9f14eed3d6..0d395ca526 100644
--- a/grpc-google-cloud-bigquerystorage-v1beta2/pom.xml
+++ b/grpc-google-cloud-bigquerystorage-v1beta2/pom.xml
@@ -4,13 +4,13 @@
   4.0.0
   com.google.api.grpc
   grpc-google-cloud-bigquerystorage-v1beta2
-  0.158.1
+  0.158.2
   grpc-google-cloud-bigquerystorage-v1beta2
   GRPC library for grpc-google-cloud-bigquerystorage-v1beta2
   
     com.google.cloud
     google-cloud-bigquerystorage-parent
-    2.34.1
+    2.34.2
   
   
     
diff --git a/grpc-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryReadGrpc.java b/grpc-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryReadGrpc.java
index 70f9be1cef..1678dd1f49 100644
--- a/grpc-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryReadGrpc.java
+++ b/grpc-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryReadGrpc.java
@@ -229,7 +229,7 @@ public BigQueryReadFutureStub newStub(
    * API at the same time.
    * 

    */
-  public abstract static class BigQueryReadImplBase implements io.grpc.BindableService {
+  public interface AsyncService {
 
     /**
      *
@@ -253,7 +253,7 @@ public abstract static class BigQueryReadImplBase implements io.grpc.BindableSer
      * not require manual clean-up by the caller.
      * 

      */
-    public void createReadSession(
+    default void createReadSession(
         com.google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest request,
         io.grpc.stub.StreamObserver
             responseObserver) {
@@ -273,7 +273,7 @@ public void createReadSession(
      * state of the stream.
      *
*/ - public void readRows( + default void readRows( com.google.cloud.bigquery.storage.v1beta2.ReadRowsRequest request, io.grpc.stub.StreamObserver responseObserver) { @@ -297,7 +297,7 @@ public void readRows( * completion. * */ - public void splitReadStream( + default void splitReadStream( com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest request, io.grpc.stub.StreamObserver< com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse> @@ -305,37 +305,29 @@ public void splitReadStream( io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( getSplitReadStreamMethod(), responseObserver); } + } + + /** + * Base class for the server implementation of the service BigQueryRead. + * + * 
+   * BigQuery Read API.
+   * The Read API can be used to read data from BigQuery.
+   * New code should use the v1 Read API going forward, if they don't use Write
+   * API at the same time.
+   *
+ */ + public abstract static class BigQueryReadImplBase + implements io.grpc.BindableService, AsyncService { @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { - return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) - .addMethod( - getCreateReadSessionMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest, - com.google.cloud.bigquery.storage.v1beta2.ReadSession>( - this, METHODID_CREATE_READ_SESSION))) - .addMethod( - getReadRowsMethod(), - io.grpc.stub.ServerCalls.asyncServerStreamingCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta2.ReadRowsRequest, - com.google.cloud.bigquery.storage.v1beta2.ReadRowsResponse>( - this, METHODID_READ_ROWS))) - .addMethod( - getSplitReadStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest, - com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse>( - this, METHODID_SPLIT_READ_STREAM))) - .build(); + return BigQueryReadGrpc.bindService(this); } } /** - * + * A stub to allow clients to do asynchronous rpc calls to service BigQueryRead. * * 
    * BigQuery Read API.
@@ -437,7 +429,7 @@ public void splitReadStream(
   }
 
   /**
-   *
+   * A stub to allow clients to do synchronous rpc calls to service BigQueryRead.
    *
    * 
    * BigQuery Read API.
@@ -529,7 +521,7 @@ public com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse splitRe
   }
 
   /**
-   *
+   * A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryRead.
    *
    * 
    * BigQuery Read API.
@@ -614,10 +606,10 @@ private static final class MethodHandlers
           io.grpc.stub.ServerCalls.ServerStreamingMethod,
           io.grpc.stub.ServerCalls.ClientStreamingMethod,
           io.grpc.stub.ServerCalls.BidiStreamingMethod {
-    private final BigQueryReadImplBase serviceImpl;
+    private final AsyncService serviceImpl;
     private final int methodId;
 
-    MethodHandlers(BigQueryReadImplBase serviceImpl, int methodId) {
+    MethodHandlers(AsyncService serviceImpl, int methodId) {
       this.serviceImpl = serviceImpl;
       this.methodId = methodId;
     }
@@ -662,6 +654,32 @@ public io.grpc.stub.StreamObserver invoke(
     }
   }
 
+  public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
+    return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+        .addMethod(
+            getCreateReadSessionMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest,
+                    com.google.cloud.bigquery.storage.v1beta2.ReadSession>(
+                    service, METHODID_CREATE_READ_SESSION)))
+        .addMethod(
+            getReadRowsMethod(),
+            io.grpc.stub.ServerCalls.asyncServerStreamingCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta2.ReadRowsRequest,
+                    com.google.cloud.bigquery.storage.v1beta2.ReadRowsResponse>(
+                    service, METHODID_READ_ROWS)))
+        .addMethod(
+            getSplitReadStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest,
+                    com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse>(
+                    service, METHODID_SPLIT_READ_STREAM)))
+        .build();
+  }
+
   private abstract static class BigQueryReadBaseDescriptorSupplier
       implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
           io.grpc.protobuf.ProtoServiceDescriptorSupplier {
diff --git a/grpc-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteGrpc.java b/grpc-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteGrpc.java
index 8cd9ee60c9..571d59b328 100644
--- a/grpc-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteGrpc.java
+++ b/grpc-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteGrpc.java
@@ -371,7 +371,7 @@ public BigQueryWriteFutureStub newStub(
    * The Write API can be used to write data to BigQuery.
    * 

    */
-  public abstract static class BigQueryWriteImplBase implements io.grpc.BindableService {
+  public interface AsyncService {
 
     /**
      *
@@ -385,7 +385,7 @@ public abstract static class BigQueryWriteImplBase implements io.grpc.BindableSe
      * soon as an acknowledgement is received.
      * 

      */
-    public void createWriteStream(
+    default void createWriteStream(
         com.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest request,
         io.grpc.stub.StreamObserver
             responseObserver) {
@@ -415,7 +415,7 @@ public void createWriteStream(
      * operations after the stream is committed.
      *
*/ - public io.grpc.stub.StreamObserver + default io.grpc.stub.StreamObserver appendRows( io.grpc.stub.StreamObserver< com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse> @@ -431,7 +431,7 @@ public void createWriteStream( * Gets a write stream. * */ - public void getWriteStream( + default void getWriteStream( com.google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest request, io.grpc.stub.StreamObserver responseObserver) { @@ -447,7 +447,7 @@ public void getWriteStream( * stream. Finalize is not supported on the '_default' stream. * */ - public void finalizeWriteStream( + default void finalizeWriteStream( com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest request, io.grpc.stub.StreamObserver< com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse> @@ -467,7 +467,7 @@ public void finalizeWriteStream( * for read operations. * */ - public void batchCommitWriteStreams( + default void batchCommitWriteStreams( com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest request, io.grpc.stub.StreamObserver< com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse> @@ -488,64 +488,33 @@ public void batchCommitWriteStreams( * Flush is not supported on the _default stream, since it is not BUFFERED. * */ - public void flushRows( + default void flushRows( com.google.cloud.bigquery.storage.v1beta2.FlushRowsRequest request, io.grpc.stub.StreamObserver responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getFlushRowsMethod(), responseObserver); } + } + + /** + * Base class for the server implementation of the service BigQueryWrite. + * + * 
+   * BigQuery Write API.
+   * The Write API can be used to write data to BigQuery.
+   *
+ */ + public abstract static class BigQueryWriteImplBase + implements io.grpc.BindableService, AsyncService { @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { - return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) - .addMethod( - getCreateWriteStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest, - com.google.cloud.bigquery.storage.v1beta2.WriteStream>( - this, METHODID_CREATE_WRITE_STREAM))) - .addMethod( - getAppendRowsMethod(), - io.grpc.stub.ServerCalls.asyncBidiStreamingCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta2.AppendRowsRequest, - com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse>( - this, METHODID_APPEND_ROWS))) - .addMethod( - getGetWriteStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest, - com.google.cloud.bigquery.storage.v1beta2.WriteStream>( - this, METHODID_GET_WRITE_STREAM))) - .addMethod( - getFinalizeWriteStreamMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest, - com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse>( - this, METHODID_FINALIZE_WRITE_STREAM))) - .addMethod( - getBatchCommitWriteStreamsMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest, - com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse>( - this, METHODID_BATCH_COMMIT_WRITE_STREAMS))) - .addMethod( - getFlushRowsMethod(), - io.grpc.stub.ServerCalls.asyncUnaryCall( - new MethodHandlers< - com.google.cloud.bigquery.storage.v1beta2.FlushRowsRequest, - com.google.cloud.bigquery.storage.v1beta2.FlushRowsResponse>( - this, METHODID_FLUSH_ROWS))) - .build(); + return BigQueryWriteGrpc.bindService(this); } } /** - * + * A stub to allow clients to do asynchronous rpc calls to service BigQueryWrite. * * 
    * BigQuery Write API.
@@ -696,7 +665,7 @@ public void flushRows(
   }
 
   /**
-   *
+   * A stub to allow clients to do synchronous rpc calls to service BigQueryWrite.
    *
    * 
    * BigQuery Write API.
@@ -799,7 +768,7 @@ public com.google.cloud.bigquery.storage.v1beta2.FlushRowsResponse flushRows(
   }
 
   /**
-   *
+   * A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryWrite.
    *
    * 
    * BigQuery Write API.
@@ -919,10 +888,10 @@ private static final class MethodHandlers
           io.grpc.stub.ServerCalls.ServerStreamingMethod,
           io.grpc.stub.ServerCalls.ClientStreamingMethod,
           io.grpc.stub.ServerCalls.BidiStreamingMethod {
-    private final BigQueryWriteImplBase serviceImpl;
+    private final AsyncService serviceImpl;
     private final int methodId;
 
-    MethodHandlers(BigQueryWriteImplBase serviceImpl, int methodId) {
+    MethodHandlers(AsyncService serviceImpl, int methodId) {
       this.serviceImpl = serviceImpl;
       this.methodId = methodId;
     }
@@ -986,6 +955,53 @@ public io.grpc.stub.StreamObserver invoke(
     }
   }
 
+  public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
+    return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+        .addMethod(
+            getCreateWriteStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest,
+                    com.google.cloud.bigquery.storage.v1beta2.WriteStream>(
+                    service, METHODID_CREATE_WRITE_STREAM)))
+        .addMethod(
+            getAppendRowsMethod(),
+            io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta2.AppendRowsRequest,
+                    com.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse>(
+                    service, METHODID_APPEND_ROWS)))
+        .addMethod(
+            getGetWriteStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest,
+                    com.google.cloud.bigquery.storage.v1beta2.WriteStream>(
+                    service, METHODID_GET_WRITE_STREAM)))
+        .addMethod(
+            getFinalizeWriteStreamMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest,
+                    com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse>(
+                    service, METHODID_FINALIZE_WRITE_STREAM)))
+        .addMethod(
+            getBatchCommitWriteStreamsMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest,
+                    com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse>(
+                    service, METHODID_BATCH_COMMIT_WRITE_STREAMS)))
+        .addMethod(
+            getFlushRowsMethod(),
+            io.grpc.stub.ServerCalls.asyncUnaryCall(
+                new MethodHandlers<
+                    com.google.cloud.bigquery.storage.v1beta2.FlushRowsRequest,
+                    com.google.cloud.bigquery.storage.v1beta2.FlushRowsResponse>(
+                    service, METHODID_FLUSH_ROWS)))
+        .build();
+  }
+
   private abstract static class BigQueryWriteBaseDescriptorSupplier
       implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
           io.grpc.protobuf.ProtoServiceDescriptorSupplier {
diff --git a/pom.xml b/pom.xml
index 557069d431..7a39cb2b63 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
   com.google.cloud
   google-cloud-bigquerystorage-parent
   pom
-  2.34.1
+  2.34.2
   BigQuery Storage Parent
   https://github.com/googleapis/java-bigquerystorage
   
@@ -31,7 +31,7 @@
   
     Google LLC
   
-  
+  
     scm:git:git@github.com:googleapis/java-bigquerystorage.git
     scm:git:git@github.com:googleapis/java-bigquerystorage.git
     https://github.com/googleapis/java-bigquerystorage
@@ -76,44 +76,44 @@
       
         com.google.cloud
         google-cloud-shared-dependencies
-        3.5.0
+        3.6.0
         pom
         import
       
       
         com.google.api.grpc
         proto-google-cloud-bigquerystorage-v1beta1
-        0.158.1
+        0.158.2
       
       
         com.google.api.grpc
         proto-google-cloud-bigquerystorage-v1beta2
-        0.158.1
+        0.158.2
       
       
         com.google.api.grpc
         proto-google-cloud-bigquerystorage-v1
-        2.34.1
+        2.34.2
       
       
         com.google.api.grpc
         grpc-google-cloud-bigquerystorage-v1beta1
-        0.158.1
+        0.158.2
       
       
         com.google.api.grpc
         grpc-google-cloud-bigquerystorage-v1beta2
-        0.158.1
+        0.158.2
       
       
         com.google.api.grpc
         grpc-google-cloud-bigquerystorage-v1
-        2.34.1
+        2.34.2
       
       
         com.google.cloud
         google-cloud-bigquerystorage
-        2.34.1
+        2.34.2
       
       
         org.json
@@ -132,7 +132,7 @@
       
         com.google.cloud
         google-cloud-bigquery
-        2.23.2
+        2.24.3
         test
         
           
diff --git a/proto-google-cloud-bigquerystorage-v1/pom.xml b/proto-google-cloud-bigquerystorage-v1/pom.xml
index 447c1b1b2e..746ad3a08d 100644
--- a/proto-google-cloud-bigquerystorage-v1/pom.xml
+++ b/proto-google-cloud-bigquerystorage-v1/pom.xml
@@ -4,13 +4,13 @@
   4.0.0
   com.google.api.grpc
   proto-google-cloud-bigquerystorage-v1
-  2.34.1
+  2.34.2
   proto-google-cloud-bigquerystorage-v1
   PROTO library for proto-google-cloud-bigquerystorage-v1
   
     com.google.cloud
     google-cloud-bigquerystorage-parent
-    2.34.1
+    2.34.2
   
   
     
diff --git a/proto-google-cloud-bigquerystorage-v1beta1/pom.xml b/proto-google-cloud-bigquerystorage-v1beta1/pom.xml
index 7106bcf31a..91db33cd81 100644
--- a/proto-google-cloud-bigquerystorage-v1beta1/pom.xml
+++ b/proto-google-cloud-bigquerystorage-v1beta1/pom.xml
@@ -4,13 +4,13 @@
   4.0.0
   com.google.api.grpc
   proto-google-cloud-bigquerystorage-v1beta1
-  0.158.1
+  0.158.2
   proto-google-cloud-bigquerystorage-v1beta1
   PROTO library for proto-google-cloud-bigquerystorage-v1beta1
   
     com.google.cloud
     google-cloud-bigquerystorage-parent
-    2.34.1
+    2.34.2
   
   
     
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/pom.xml b/proto-google-cloud-bigquerystorage-v1beta2/pom.xml
index a02bdf0711..eb9de4ef7a 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/pom.xml
+++ b/proto-google-cloud-bigquerystorage-v1beta2/pom.xml
@@ -4,13 +4,13 @@
   4.0.0
   com.google.api.grpc
   proto-google-cloud-bigquerystorage-v1beta2
-  0.158.1
+  0.158.2
   proto-google-cloud-bigquerystorage-v1beta2
   PROTO library for proto-google-cloud-bigquerystorage-v1beta2
   
     com.google.cloud
     google-cloud-bigquerystorage-parent
-    2.34.1
+    2.34.2
   
   
     
diff --git a/samples/install-without-bom/pom.xml b/samples/install-without-bom/pom.xml
index 587f4e4d9a..ecfcdc5934 100644
--- a/samples/install-without-bom/pom.xml
+++ b/samples/install-without-bom/pom.xml
@@ -30,14 +30,14 @@
     
       com.google.cloud
       google-cloud-bigquerystorage
-      2.34.0
+      2.34.1
     
     
 
     
       com.google.cloud
       google-cloud-bigquery
-      2.23.2
+      2.24.3
     
     
       org.apache.avro
diff --git a/samples/pom.xml b/samples/pom.xml
index ae24bfd59f..06f79f499c 100644
--- a/samples/pom.xml
+++ b/samples/pom.xml
@@ -38,7 +38,7 @@
       
         org.apache.maven.plugins
         maven-deploy-plugin
-        3.1.0
+        3.1.1
         
           true
         
diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml
index ae834929f8..e69f721897 100644
--- a/samples/snapshot/pom.xml
+++ b/samples/snapshot/pom.xml
@@ -29,14 +29,14 @@
     
       com.google.cloud
       google-cloud-bigquerystorage
-      2.34.1
+      2.34.2
     
     
 
     
       com.google.cloud
       google-cloud-bigquery
-      2.23.2
+      2.24.3
     
     
       org.apache.avro
diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml
index 7c6b185f74..6009b89583 100644
--- a/samples/snippets/pom.xml
+++ b/samples/snippets/pom.xml
@@ -31,7 +31,7 @@
       
         com.google.cloud
         libraries-bom
-        26.10.0
+        26.11.0
         pom
         import
       
@@ -48,7 +48,7 @@
     
       com.google.cloud
       google-cloud-bigquery
-      2.23.2
+      2.24.3
     
     
       org.apache.avro
diff --git a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
index f5f357238a..8bd384c325 100644
--- a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
+++ b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
@@ -28,7 +28,7 @@
 import com.google.cloud.bigquery.storage.v1.AppendRowsResponse;
 import com.google.cloud.bigquery.storage.v1.BigQueryWriteClient;
 import com.google.cloud.bigquery.storage.v1.Exceptions;
-import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializtionError;
+import com.google.cloud.bigquery.storage.v1.Exceptions.AppendSerializationError;
 import com.google.cloud.bigquery.storage.v1.Exceptions.StorageException;
 import com.google.cloud.bigquery.storage.v1.JsonStreamWriter;
 import com.google.cloud.bigquery.storage.v1.TableName;
@@ -218,8 +218,8 @@ public void onFailure(Throwable throwable) {
           }
         }
 
-        if (throwable instanceof AppendSerializtionError) {
-          AppendSerializtionError ase = (AppendSerializtionError) throwable;
+        if (throwable instanceof AppendSerializationError) {
+          AppendSerializationError ase = (AppendSerializationError) throwable;
           Map rowIndexToErrorMessage = ase.getRowIndexToErrorMessage();
           if (rowIndexToErrorMessage.size() > 0) {
             // Omit the faulty rows
diff --git a/tutorials/JsonWriterDefaultStream/pom.xml b/tutorials/JsonWriterDefaultStream/pom.xml
index ec6944985c..7e1aca52c1 100644
--- a/tutorials/JsonWriterDefaultStream/pom.xml
+++ b/tutorials/JsonWriterDefaultStream/pom.xml
@@ -19,12 +19,12 @@
     
       com.google.cloud
       google-cloud-bigquerystorage
-      2.34.0
+      2.34.1
     
     
       com.google.cloud
       google-cloud-bigquery
-      2.23.2
+      2.24.3
     
     
       org.apache.avro
diff --git a/tutorials/pom.xml b/tutorials/pom.xml
index f636d2d46e..ae46c35685 100644
--- a/tutorials/pom.xml
+++ b/tutorials/pom.xml
@@ -36,7 +36,7 @@
       
         org.apache.maven.plugins
         maven-deploy-plugin
-        3.1.0
+        3.1.1
         
           true
         
diff --git a/versions.txt b/versions.txt
index 1be806c4a1..3bb1693b4f 100644
--- a/versions.txt
+++ b/versions.txt
@@ -1,10 +1,10 @@
 # Format:
 # module:released-version:current-version
 
-google-cloud-bigquerystorage:2.34.1:2.34.1
-grpc-google-cloud-bigquerystorage-v1beta1:0.158.1:0.158.1
-grpc-google-cloud-bigquerystorage-v1beta2:0.158.1:0.158.1
-grpc-google-cloud-bigquerystorage-v1:2.34.1:2.34.1
-proto-google-cloud-bigquerystorage-v1beta1:0.158.1:0.158.1
-proto-google-cloud-bigquerystorage-v1beta2:0.158.1:0.158.1
-proto-google-cloud-bigquerystorage-v1:2.34.1:2.34.1
+google-cloud-bigquerystorage:2.34.2:2.34.2
+grpc-google-cloud-bigquerystorage-v1beta1:0.158.2:0.158.2
+grpc-google-cloud-bigquerystorage-v1beta2:0.158.2:0.158.2
+grpc-google-cloud-bigquerystorage-v1:2.34.2:2.34.2
+proto-google-cloud-bigquerystorage-v1beta1:0.158.2:0.158.2
+proto-google-cloud-bigquerystorage-v1beta2:0.158.2:0.158.2
+proto-google-cloud-bigquerystorage-v1:2.34.2:2.34.2