diff --git a/.github/workflows/hermetic_library_generation.yaml b/.github/workflows/hermetic_library_generation.yaml index 1f218b2874..a293f6b92f 100644 --- a/.github/workflows/hermetic_library_generation.yaml +++ b/.github/workflows/hermetic_library_generation.yaml @@ -37,7 +37,7 @@ jobs: with: fetch-depth: 0 token: ${{ secrets.CLOUD_JAVA_BOT_TOKEN }} - - uses: googleapis/sdk-platform-java/.github/scripts@v2.62.3 + - uses: googleapis/sdk-platform-java/.github/scripts@v2.64.0 if: env.SHOULD_RUN == 'true' with: base_ref: ${{ github.base_ref }} diff --git a/README.md b/README.md index 108867e826..3ebfe57523 100644 --- a/README.md +++ b/README.md @@ -56,7 +56,7 @@ If you are using Maven without the 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.69.0') +implementation platform('com.google.cloud:libraries-bom:26.71.0') implementation 'com.google.cloud:google-cloud-bigquerystorage' ``` diff --git a/generation_config.yaml b/generation_config.yaml index b8de2442ed..8ef12af900 100644 --- a/generation_config.yaml +++ b/generation_config.yaml @@ -1,6 +1,6 @@ -gapic_generator_version: 2.62.3 -googleapis_commitish: 6e79e73204aed17b11e724beebb9cf11f36ea57d -libraries_bom_version: 26.69.0 +gapic_generator_version: 2.64.0 +googleapis_commitish: baf777503d79555219eed1acebe01838ca448bb5 +libraries_bom_version: 26.71.0 libraries: - api_shortname: bigquerystorage name_pretty: BigQuery Storage diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java index b98565690e..2da1b0f617 100644 --- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/StreamWriter.java @@ -316,8 +316,8 @@ public String call() throws Exception { String fetchedLocation = writeStream.getLocation(); log.info( String.format( - "Fetched location %s for stream name %s, extracted project and dataset" - + " name: %s\"", + "Fetched location %s for stream name %s, extracted project and" + + " dataset name: %s\"", fetchedLocation, streamName, datasetAndProjectName)); return fetchedLocation; } 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 0809d14b6f..68d7f72507 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 @@ -25,9 +25,6 @@ * The Read API can be used to read data from BigQuery. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/bigquery/storage/v1/storage.proto") @io.grpc.stub.annotations.GrpcGenerated public final class BigQueryReadGrpc { @@ -475,8 +472,9 @@ protected BigQueryReadBlockingV2Stub build( * */ public com.google.cloud.bigquery.storage.v1.ReadSession createReadSession( - com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateReadSessionMethod(), getCallOptions(), request); } @@ -517,8 +515,9 @@ public com.google.cloud.bigquery.storage.v1.ReadSession createReadSession( * */ public com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse splitReadStream( - com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getSplitReadStreamMethod(), getCallOptions(), request); } } 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 4dff99d0fd..fcbc2af218 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 @@ -27,9 +27,6 @@ * https://cloud.google.com/bigquery/docs/write-api * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/bigquery/storage/v1/storage.proto") @io.grpc.stub.annotations.GrpcGenerated public final class BigQueryWriteGrpc { @@ -734,8 +731,9 @@ protected BigQueryWriteBlockingV2Stub build( * */ public com.google.cloud.bigquery.storage.v1.WriteStream createWriteStream( - com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateWriteStreamMethod(), getCallOptions(), request); } @@ -786,8 +784,9 @@ public com.google.cloud.bigquery.storage.v1.WriteStream createWriteStream( * */ public com.google.cloud.bigquery.storage.v1.WriteStream getWriteStream( - com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetWriteStreamMethod(), getCallOptions(), request); } @@ -800,8 +799,9 @@ public com.google.cloud.bigquery.storage.v1.WriteStream getWriteStream( * */ public com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse finalizeWriteStream( - com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getFinalizeWriteStreamMethod(), getCallOptions(), request); } @@ -818,8 +818,9 @@ public com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse finalize */ public com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse batchCommitWriteStreams( - com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getBatchCommitWriteStreamsMethod(), getCallOptions(), request); } @@ -836,8 +837,9 @@ public com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse finalize * */ public com.google.cloud.bigquery.storage.v1.FlushRowsResponse flushRows( - com.google.cloud.bigquery.storage.v1.FlushRowsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1.FlushRowsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getFlushRowsMethod(), getCallOptions(), request); } } diff --git a/grpc-google-cloud-bigquerystorage-v1alpha/src/main/java/com/google/cloud/bigquery/storage/v1alpha/MetastorePartitionServiceGrpc.java b/grpc-google-cloud-bigquerystorage-v1alpha/src/main/java/com/google/cloud/bigquery/storage/v1alpha/MetastorePartitionServiceGrpc.java index 076feb78f3..f62d49acb1 100644 --- a/grpc-google-cloud-bigquerystorage-v1alpha/src/main/java/com/google/cloud/bigquery/storage/v1alpha/MetastorePartitionServiceGrpc.java +++ b/grpc-google-cloud-bigquerystorage-v1alpha/src/main/java/com/google/cloud/bigquery/storage/v1alpha/MetastorePartitionServiceGrpc.java @@ -26,9 +26,6 @@ * metastore. The service supports only batch operations for write. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/bigquery/storage/v1alpha/metastore_partition.proto") @io.grpc.stub.annotations.GrpcGenerated public final class MetastorePartitionServiceGrpc { @@ -631,9 +628,9 @@ protected MetastorePartitionServiceBlockingV2Stub build( */ public com.google.cloud.bigquery.storage.v1alpha.BatchCreateMetastorePartitionsResponse batchCreateMetastorePartitions( - com.google.cloud.bigquery.storage.v1alpha.BatchCreateMetastorePartitionsRequest - request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1alpha.BatchCreateMetastorePartitionsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getBatchCreateMetastorePartitionsMethod(), getCallOptions(), request); } @@ -645,8 +642,9 @@ protected MetastorePartitionServiceBlockingV2Stub build( * */ public com.google.protobuf.Empty batchDeleteMetastorePartitions( - com.google.cloud.bigquery.storage.v1alpha.BatchDeleteMetastorePartitionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1alpha.BatchDeleteMetastorePartitionsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getBatchDeleteMetastorePartitionsMethod(), getCallOptions(), request); } @@ -659,9 +657,9 @@ public com.google.protobuf.Empty batchDeleteMetastorePartitions( */ public com.google.cloud.bigquery.storage.v1alpha.BatchUpdateMetastorePartitionsResponse batchUpdateMetastorePartitions( - com.google.cloud.bigquery.storage.v1alpha.BatchUpdateMetastorePartitionsRequest - request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1alpha.BatchUpdateMetastorePartitionsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getBatchUpdateMetastorePartitionsMethod(), getCallOptions(), request); } @@ -674,8 +672,9 @@ public com.google.protobuf.Empty batchDeleteMetastorePartitions( */ public com.google.cloud.bigquery.storage.v1alpha.ListMetastorePartitionsResponse listMetastorePartitions( - com.google.cloud.bigquery.storage.v1alpha.ListMetastorePartitionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1alpha.ListMetastorePartitionsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListMetastorePartitionsMethod(), getCallOptions(), request); } diff --git a/grpc-google-cloud-bigquerystorage-v1beta/src/main/java/com/google/cloud/bigquery/storage/v1beta/MetastorePartitionServiceGrpc.java b/grpc-google-cloud-bigquerystorage-v1beta/src/main/java/com/google/cloud/bigquery/storage/v1beta/MetastorePartitionServiceGrpc.java index ca9ef2cf66..7049c1efcb 100644 --- a/grpc-google-cloud-bigquerystorage-v1beta/src/main/java/com/google/cloud/bigquery/storage/v1beta/MetastorePartitionServiceGrpc.java +++ b/grpc-google-cloud-bigquerystorage-v1beta/src/main/java/com/google/cloud/bigquery/storage/v1beta/MetastorePartitionServiceGrpc.java @@ -26,9 +26,6 @@ * metastore. The service supports only batch operations for write. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/bigquery/storage/v1beta/metastore_partition.proto") @io.grpc.stub.annotations.GrpcGenerated public final class MetastorePartitionServiceGrpc { @@ -629,9 +626,9 @@ protected MetastorePartitionServiceBlockingV2Stub build( */ public com.google.cloud.bigquery.storage.v1beta.BatchCreateMetastorePartitionsResponse batchCreateMetastorePartitions( - com.google.cloud.bigquery.storage.v1beta.BatchCreateMetastorePartitionsRequest - request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta.BatchCreateMetastorePartitionsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getBatchCreateMetastorePartitionsMethod(), getCallOptions(), request); } @@ -643,8 +640,9 @@ protected MetastorePartitionServiceBlockingV2Stub build( * */ public com.google.protobuf.Empty batchDeleteMetastorePartitions( - com.google.cloud.bigquery.storage.v1beta.BatchDeleteMetastorePartitionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta.BatchDeleteMetastorePartitionsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getBatchDeleteMetastorePartitionsMethod(), getCallOptions(), request); } @@ -657,9 +655,9 @@ public com.google.protobuf.Empty batchDeleteMetastorePartitions( */ public com.google.cloud.bigquery.storage.v1beta.BatchUpdateMetastorePartitionsResponse batchUpdateMetastorePartitions( - com.google.cloud.bigquery.storage.v1beta.BatchUpdateMetastorePartitionsRequest - request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta.BatchUpdateMetastorePartitionsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getBatchUpdateMetastorePartitionsMethod(), getCallOptions(), request); } @@ -672,8 +670,9 @@ public com.google.protobuf.Empty batchDeleteMetastorePartitions( */ public com.google.cloud.bigquery.storage.v1beta.ListMetastorePartitionsResponse listMetastorePartitions( - com.google.cloud.bigquery.storage.v1beta.ListMetastorePartitionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta.ListMetastorePartitionsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListMetastorePartitionsMethod(), getCallOptions(), request); } 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 614bba77de..eefb14ee8f 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 @@ -29,9 +29,6 @@ * going forward. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/bigquery/storage/v1beta1/storage.proto") @io.grpc.stub.annotations.GrpcGenerated public final class BigQueryStorageGrpc { @@ -687,8 +684,9 @@ protected BigQueryStorageBlockingV2Stub build( * */ public com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession createReadSession( - com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateReadSessionMethod(), getCallOptions(), request); } @@ -726,8 +724,9 @@ public com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession createReadS public com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse batchCreateReadSessionStreams( com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest - request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getBatchCreateReadSessionStreamsMethod(), getCallOptions(), request); } @@ -750,8 +749,9 @@ public com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession createReadS * */ public com.google.protobuf.Empty finalizeStream( - com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getFinalizeStreamMethod(), getCallOptions(), request); } @@ -774,8 +774,9 @@ public com.google.protobuf.Empty finalizeStream( */ public com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse splitReadStream( - com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getSplitReadStreamMethod(), getCallOptions(), request); } } 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 9daa649d09..f448f93de6 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 @@ -27,9 +27,6 @@ * API at the same time. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/bigquery/storage/v1beta2/storage.proto") @io.grpc.stub.annotations.GrpcGenerated public final class BigQueryReadGrpc { @@ -487,8 +484,9 @@ protected BigQueryReadBlockingV2Stub build( * */ public com.google.cloud.bigquery.storage.v1beta2.ReadSession createReadSession( - com.google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateReadSessionMethod(), getCallOptions(), request); } @@ -530,8 +528,9 @@ public com.google.cloud.bigquery.storage.v1beta2.ReadSession createReadSession( * */ public com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse splitReadStream( - com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getSplitReadStreamMethod(), getCallOptions(), request); } } 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 f2f53bd608..32d8ef9881 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 @@ -28,9 +28,6 @@ * should be used instead of the v1beta2 API for BigQueryWrite operations. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/bigquery/storage/v1beta2/storage.proto") @io.grpc.stub.annotations.GrpcGenerated @java.lang.Deprecated public final class BigQueryWriteGrpc { @@ -744,8 +741,9 @@ protected BigQueryWriteBlockingV2Stub build( */ @java.lang.Deprecated public com.google.cloud.bigquery.storage.v1beta2.WriteStream createWriteStream( - com.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateWriteStreamMethod(), getCallOptions(), request); } @@ -790,8 +788,9 @@ public com.google.cloud.bigquery.storage.v1beta2.WriteStream createWriteStream( */ @java.lang.Deprecated public com.google.cloud.bigquery.storage.v1beta2.WriteStream getWriteStream( - com.google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetWriteStreamMethod(), getCallOptions(), request); } @@ -806,8 +805,9 @@ public com.google.cloud.bigquery.storage.v1beta2.WriteStream getWriteStream( @java.lang.Deprecated public com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse finalizeWriteStream( - com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getFinalizeWriteStreamMethod(), getCallOptions(), request); } @@ -825,8 +825,9 @@ public com.google.cloud.bigquery.storage.v1beta2.WriteStream getWriteStream( @java.lang.Deprecated public com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse batchCommitWriteStreams( - com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getBatchCommitWriteStreamsMethod(), getCallOptions(), request); } @@ -844,8 +845,9 @@ public com.google.cloud.bigquery.storage.v1beta2.WriteStream getWriteStream( */ @java.lang.Deprecated public com.google.cloud.bigquery.storage.v1beta2.FlushRowsResponse flushRows( - com.google.cloud.bigquery.storage.v1beta2.FlushRowsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.cloud.bigquery.storage.v1beta2.FlushRowsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getFlushRowsMethod(), getCallOptions(), request); } }