diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClient.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClient.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClient.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClient.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java similarity index 99% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java index baab7e9c3a..a24fe3d332 100644 --- a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadSettings.java @@ -25,7 +25,6 @@ import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.ClientSettings; import com.google.api.gax.rpc.ServerStreamingCallSettings; -import com.google.api.gax.rpc.StubSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.bigquery.storage.v1.stub.BigQueryReadStubSettings; diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClient.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClient.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClient.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClient.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteSettings.java similarity index 99% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteSettings.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteSettings.java index 01fe386251..58b5f8f2fa 100644 --- a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteSettings.java @@ -25,7 +25,6 @@ import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.ClientSettings; import com.google.api.gax.rpc.StreamingCallSettings; -import com.google.api.gax.rpc.StubSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.bigquery.storage.v1.stub.BigQueryWriteStubSettings; diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/gapic_metadata.json b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/gapic_metadata.json similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/gapic_metadata.json rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/gapic_metadata.json diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/package-info.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/package-info.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/package-info.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/package-info.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStub.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStub.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryWriteStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryWriteStub.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryWriteStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryWriteStub.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryWriteStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryWriteStubSettings.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryWriteStubSettings.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryWriteStubSettings.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadCallableFactory.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadCallableFactory.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadCallableFactory.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadCallableFactory.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadStub.java similarity index 99% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadStub.java index bb937f3ef8..311064c87b 100644 --- a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadStub.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryReadStub.java @@ -34,7 +34,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteCallableFactory.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteCallableFactory.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteCallableFactory.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteCallableFactory.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteStub.java similarity index 99% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteStub.java index 0e14eb69e2..04f22270d1 100644 --- a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteStub.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/GrpcBigQueryWriteStub.java @@ -39,7 +39,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageClient.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageClient.java similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageClient.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageClient.java diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java similarity index 99% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java index 117145284d..8bf0b80d3d 100644 --- a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageSettings.java @@ -25,7 +25,6 @@ import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.ClientSettings; import com.google.api.gax.rpc.ServerStreamingCallSettings; -import com.google.api.gax.rpc.StubSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.bigquery.storage.v1beta1.stub.BigQueryStorageStubSettings; diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/gapic_metadata.json b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/gapic_metadata.json similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/gapic_metadata.json rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/gapic_metadata.json diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/package-info.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/package-info.java similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/package-info.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/package-info.java diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStub.java similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStub.java diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStubSettings.java similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStubSettings.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/BigQueryStorageStubSettings.java diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageCallableFactory.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageCallableFactory.java similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageCallableFactory.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageCallableFactory.java diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageStub.java similarity index 99% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageStub.java index 23980b12d1..c0472c8a8e 100644 --- a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageStub.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta1/stub/GrpcBigQueryStorageStub.java @@ -31,7 +31,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClient.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClient.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClient.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClient.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java similarity index 99% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java index d6acbcfcb4..e8717d346a 100644 --- a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadSettings.java @@ -25,7 +25,6 @@ import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.ClientSettings; import com.google.api.gax.rpc.ServerStreamingCallSettings; -import com.google.api.gax.rpc.StubSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.bigquery.storage.v1beta2.stub.BigQueryReadStubSettings; diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteClient.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteClient.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteClient.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteClient.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteSettings.java similarity index 99% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteSettings.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteSettings.java index 8d619dae3a..6f45f970ad 100644 --- a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteSettings.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteSettings.java @@ -25,7 +25,6 @@ import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.ClientSettings; import com.google.api.gax.rpc.StreamingCallSettings; -import com.google.api.gax.rpc.StubSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.bigquery.storage.v1beta2.stub.BigQueryWriteStubSettings; diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/gapic_metadata.json b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/gapic_metadata.json similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/gapic_metadata.json rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/gapic_metadata.json diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/package-info.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/package-info.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/package-info.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/package-info.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStub.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStub.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryWriteStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryWriteStub.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryWriteStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryWriteStub.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryWriteStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryWriteStubSettings.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryWriteStubSettings.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryWriteStubSettings.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadCallableFactory.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadCallableFactory.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadCallableFactory.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadCallableFactory.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadStub.java similarity index 99% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadStub.java index 155c39b7ae..f173d06d73 100644 --- a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadStub.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryReadStub.java @@ -35,7 +35,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteCallableFactory.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteCallableFactory.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteCallableFactory.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteCallableFactory.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteStub.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteStub.java similarity index 99% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteStub.java rename to google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteStub.java index 17946f5741..1bb2cb0a87 100644 --- a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteStub.java +++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/GrpcBigQueryWriteStub.java @@ -40,7 +40,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1/reflect-config.json b/google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1/reflect-config.json similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1/reflect-config.json rename to google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1/reflect-config.json diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1beta1/reflect-config.json b/google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1beta1/reflect-config.json similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1beta1/reflect-config.json rename to google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1beta1/reflect-config.json diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1beta2/reflect-config.json b/google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1beta2/reflect-config.json similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1beta2/reflect-config.json rename to google-cloud-bigquerystorage/src/main/resources/META-INF/native-image/com.google.cloud.bigquery.storage.v1beta2/reflect-config.json diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClientTest.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClientTest.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BaseBigQueryReadClientTest.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClientTest.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClientTest.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClientTest.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryRead.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryRead.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryRead.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryRead.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryReadImpl.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryReadImpl.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryReadImpl.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryReadImpl.java diff --git a/owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWrite.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWrite.java similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWrite.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWrite.java diff --git a/owl-bot-staging/v1/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 similarity index 100% rename from owl-bot-staging/v1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWriteImpl.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/MockBigQueryWriteImpl.java diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageClientTest.java similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageClientTest.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/BaseBigQueryStorageClientTest.java diff --git a/owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorage.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorage.java similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorage.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorage.java diff --git a/owl-bot-staging/v1beta1/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 similarity index 100% rename from owl-bot-staging/v1beta1/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorageImpl.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta1/MockBigQueryStorageImpl.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClientTest.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClientTest.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BaseBigQueryReadClientTest.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteClientTest.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteClientTest.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/BigQueryWriteClientTest.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryRead.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryRead.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryRead.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryRead.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryReadImpl.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryReadImpl.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryReadImpl.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryReadImpl.java diff --git a/owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWrite.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWrite.java similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWrite.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWrite.java diff --git a/owl-bot-staging/v1beta2/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 similarity index 100% rename from owl-bot-staging/v1beta2/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWriteImpl.java rename to google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1beta2/MockBigQueryWriteImpl.java diff --git a/owl-bot-staging/v1/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 similarity index 60% rename from owl-bot-staging/v1/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryReadGrpc.java rename to grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryReadGrpc.java index 6aecaeeb36..1ea103f612 100644 --- a/owl-bot-staging/v1/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 @@ -1,8 +1,25 @@ +/* + * Copyright 2023 Google LLC + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package com.google.cloud.bigquery.storage.v1; import static io.grpc.MethodDescriptor.generateFullMethodName; /** + * + * *
* BigQuery Read API. * The Read API can be used to read data from BigQuery. @@ -19,144 +36,190 @@ private BigQueryReadGrpc() {} public static final String SERVICE_NAME = "google.cloud.bigquery.storage.v1.BigQueryRead"; // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptorgetCreateReadSessionMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest, + com.google.cloud.bigquery.storage.v1.ReadSession> + getCreateReadSessionMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "CreateReadSession", requestType = com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest.class, responseType = com.google.cloud.bigquery.storage.v1.ReadSession.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getCreateReadSessionMethod() { - io.grpc.MethodDescriptor getCreateReadSessionMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest, + com.google.cloud.bigquery.storage.v1.ReadSession> + getCreateReadSessionMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest, + com.google.cloud.bigquery.storage.v1.ReadSession> + getCreateReadSessionMethod; if ((getCreateReadSessionMethod = BigQueryReadGrpc.getCreateReadSessionMethod) == null) { synchronized (BigQueryReadGrpc.class) { if ((getCreateReadSessionMethod = BigQueryReadGrpc.getCreateReadSessionMethod) == null) { - BigQueryReadGrpc.getCreateReadSessionMethod = getCreateReadSessionMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateReadSession")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.ReadSession.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryReadMethodDescriptorSupplier("CreateReadSession")) - .build(); + BigQueryReadGrpc.getCreateReadSessionMethod = + getCreateReadSessionMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateReadSession")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.ReadSession + .getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryReadMethodDescriptorSupplier("CreateReadSession")) + .build(); } } } return getCreateReadSessionMethod; } - private static volatile io.grpc.MethodDescriptor getReadRowsMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.ReadRowsRequest, + com.google.cloud.bigquery.storage.v1.ReadRowsResponse> + getReadRowsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ReadRows", requestType = com.google.cloud.bigquery.storage.v1.ReadRowsRequest.class, responseType = com.google.cloud.bigquery.storage.v1.ReadRowsResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) - public static io.grpc.MethodDescriptor getReadRowsMethod() { - io.grpc.MethodDescriptor getReadRowsMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.ReadRowsRequest, + com.google.cloud.bigquery.storage.v1.ReadRowsResponse> + getReadRowsMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.ReadRowsRequest, + com.google.cloud.bigquery.storage.v1.ReadRowsResponse> + getReadRowsMethod; if ((getReadRowsMethod = BigQueryReadGrpc.getReadRowsMethod) == null) { synchronized (BigQueryReadGrpc.class) { if ((getReadRowsMethod = BigQueryReadGrpc.getReadRowsMethod) == null) { - BigQueryReadGrpc.getReadRowsMethod = getReadRowsMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ReadRows")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.ReadRowsRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.ReadRowsResponse.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryReadMethodDescriptorSupplier("ReadRows")) - .build(); + BigQueryReadGrpc.getReadRowsMethod = + getReadRowsMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ReadRows")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.ReadRowsRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.ReadRowsResponse + .getDefaultInstance())) + .setSchemaDescriptor(new BigQueryReadMethodDescriptorSupplier("ReadRows")) + .build(); } } } return getReadRowsMethod; } - private static volatile io.grpc.MethodDescriptor getSplitReadStreamMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest, + com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse> + getSplitReadStreamMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SplitReadStream", requestType = com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest.class, responseType = com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getSplitReadStreamMethod() { - io.grpc.MethodDescriptor getSplitReadStreamMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest, + com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse> + getSplitReadStreamMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest, + com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse> + getSplitReadStreamMethod; if ((getSplitReadStreamMethod = BigQueryReadGrpc.getSplitReadStreamMethod) == null) { synchronized (BigQueryReadGrpc.class) { if ((getSplitReadStreamMethod = BigQueryReadGrpc.getSplitReadStreamMethod) == null) { - BigQueryReadGrpc.getSplitReadStreamMethod = getSplitReadStreamMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SplitReadStream")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryReadMethodDescriptorSupplier("SplitReadStream")) - .build(); + BigQueryReadGrpc.getSplitReadStreamMethod = + getSplitReadStreamMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SplitReadStream")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse + .getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryReadMethodDescriptorSupplier("SplitReadStream")) + .build(); } } } return getSplitReadStreamMethod; } - /** - * Creates a new async stub that supports all call types for the service - */ + /** Creates a new async stub that supports all call types for the service */ public static BigQueryReadStub newStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public BigQueryReadStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new BigQueryReadStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public BigQueryReadStub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new BigQueryReadStub(channel, callOptions); + } + }; return BigQueryReadStub.newStub(factory, channel); } /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ - public static BigQueryReadBlockingStub newBlockingStub( - io.grpc.Channel channel) { + public static BigQueryReadBlockingStub newBlockingStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public BigQueryReadBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new BigQueryReadBlockingStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public BigQueryReadBlockingStub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new BigQueryReadBlockingStub(channel, callOptions); + } + }; return BigQueryReadBlockingStub.newStub(factory, channel); } - /** - * Creates a new ListenableFuture-style stub that supports unary calls on the service - */ - public static BigQueryReadFutureStub newFutureStub( - io.grpc.Channel channel) { + /** Creates a new ListenableFuture-style stub that supports unary calls on the service */ + public static BigQueryReadFutureStub newFutureStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public BigQueryReadFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new BigQueryReadFutureStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public BigQueryReadFutureStub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new BigQueryReadFutureStub(channel, callOptions); + } + }; return BigQueryReadFutureStub.newStub(factory, channel); } /** + * + * * * BigQuery Read API. * The Read API can be used to read data from BigQuery. @@ -165,6 +228,8 @@ public BigQueryReadFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptio public interface AsyncService { /** + * + * ** Creates a new read session. A read session divides the contents of a * BigQuery table into one or more streams, which can then be used to read @@ -184,12 +249,17 @@ public interface AsyncService { * not require manual clean-up by the caller. **/ - default void createReadSession(com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request, - io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateReadSessionMethod(), responseObserver); + default void createReadSession( + com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request, + io.grpc.stub.StreamObserver + responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getCreateReadSessionMethod(), responseObserver); } /** + * + * * * Reads rows from the stream in the format prescribed by the ReadSession. * Each response contains one or more table rows, up to a maximum of 100 MiB @@ -199,12 +269,16 @@ default void createReadSession(com.google.cloud.bigquery.storage.v1.CreateReadSe * state of the stream. **/ - default void readRows(com.google.cloud.bigquery.storage.v1.ReadRowsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + default void readRows( + com.google.cloud.bigquery.storage.v1.ReadRowsRequest request, + io.grpc.stub.StreamObserver + responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getReadRowsMethod(), responseObserver); } /** + * + * * * Splits a given `ReadStream` into two `ReadStream` objects. These * `ReadStream` objects are referred to as the primary and the residual @@ -219,29 +293,35 @@ default void readRows(com.google.cloud.bigquery.storage.v1.ReadRowsRequest reque * completion. **/ - default void splitReadStream(com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSplitReadStreamMethod(), responseObserver); + 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 static abstract class BigQueryReadImplBase + public abstract static class BigQueryReadImplBase implements io.grpc.BindableService, AsyncService { - @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { + @java.lang.Override + public final io.grpc.ServerServiceDefinition bindService() { return BigQueryReadGrpc.bindService(this); } } /** * A stub to allow clients to do asynchronous rpc calls to service BigQueryRead. + * ** BigQuery Read API. * The Read API can be used to read data from BigQuery. @@ -249,18 +329,18 @@ public static abstract class BigQueryReadImplBase */ public static final class BigQueryReadStub extends io.grpc.stub.AbstractAsyncStub{ - private BigQueryReadStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + private BigQueryReadStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @java.lang.Override - protected BigQueryReadStub build( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + protected BigQueryReadStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new BigQueryReadStub(channel, callOptions); } /** + * + * * * Creates a new read session. A read session divides the contents of a * BigQuery table into one or more streams, which can then be used to read @@ -280,13 +360,19 @@ protected BigQueryReadStub build( * not require manual clean-up by the caller. **/ - public void createReadSession(com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void createReadSession( + com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request, + io.grpc.stub.StreamObserver + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getCreateReadSessionMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getCreateReadSessionMethod(), getCallOptions()), + request, + responseObserver); } /** + * + * * * Reads rows from the stream in the format prescribed by the ReadSession. * Each response contains one or more table rows, up to a maximum of 100 MiB @@ -296,13 +382,17 @@ public void createReadSession(com.google.cloud.bigquery.storage.v1.CreateReadSes * state of the stream. **/ - public void readRows(com.google.cloud.bigquery.storage.v1.ReadRowsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void readRows( + com.google.cloud.bigquery.storage.v1.ReadRowsRequest request, + io.grpc.stub.StreamObserver + responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getReadRowsMethod(), getCallOptions()), request, responseObserver); } /** + * + * * * Splits a given `ReadStream` into two `ReadStream` objects. These * `ReadStream` objects are referred to as the primary and the residual @@ -317,15 +407,20 @@ public void readRows(com.google.cloud.bigquery.storage.v1.ReadRowsRequest reques * completion. **/ - public void splitReadStream(com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void splitReadStream( + com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request, + io.grpc.stub.StreamObserver + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getSplitReadStreamMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getSplitReadStreamMethod(), getCallOptions()), + request, + responseObserver); } } /** * A stub to allow clients to do synchronous rpc calls to service BigQueryRead. + * * * BigQuery Read API. * The Read API can be used to read data from BigQuery. @@ -333,8 +428,7 @@ public void splitReadStream(com.google.cloud.bigquery.storage.v1.SplitReadStream */ public static final class BigQueryReadBlockingStub extends io.grpc.stub.AbstractBlockingStub{ - private BigQueryReadBlockingStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + private BigQueryReadBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @@ -345,6 +439,8 @@ protected BigQueryReadBlockingStub build( } /** + * + * * * Creates a new read session. A read session divides the contents of a * BigQuery table into one or more streams, which can then be used to read @@ -364,12 +460,15 @@ protected BigQueryReadBlockingStub build( * not require manual clean-up by the caller. **/ - public com.google.cloud.bigquery.storage.v1.ReadSession createReadSession(com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request) { + public com.google.cloud.bigquery.storage.v1.ReadSession createReadSession( + com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getCreateReadSessionMethod(), getCallOptions(), request); } /** + * + * ** Reads rows from the stream in the format prescribed by the ReadSession. * Each response contains one or more table rows, up to a maximum of 100 MiB @@ -386,6 +485,8 @@ public java.util.Iterator} /** + * + * * * Splits a given `ReadStream` into two `ReadStream` objects. These * `ReadStream` objects are referred to as the primary and the residual @@ -400,7 +501,8 @@ public java.util.Iterator*/ - public com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse splitReadStream(com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) { + public com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse splitReadStream( + com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getSplitReadStreamMethod(), getCallOptions(), request); } @@ -408,6 +510,7 @@ public com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse splitReadStr /** * A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryRead. + * ** completion. * * BigQuery Read API. * The Read API can be used to read data from BigQuery. @@ -415,8 +518,7 @@ public com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse splitReadStr */ public static final class BigQueryReadFutureStub extends io.grpc.stub.AbstractFutureStub{ - private BigQueryReadFutureStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + private BigQueryReadFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @@ -427,6 +529,8 @@ protected BigQueryReadFutureStub build( } /** + * + * * * Creates a new read session. A read session divides the contents of a * BigQuery table into one or more streams, which can then be used to read @@ -446,13 +550,16 @@ protected BigQueryReadFutureStub build( * not require manual clean-up by the caller. **/ - public com.google.common.util.concurrent.ListenableFuturecreateReadSession( - com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1.ReadSession> + createReadSession(com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getCreateReadSessionMethod(), getCallOptions()), request); } /** + * + * * * Splits a given `ReadStream` into two `ReadStream` objects. These * `ReadStream` objects are referred to as the primary and the residual @@ -467,8 +574,9 @@ public com.google.common.util.concurrent.ListenableFuture*/ - public com.google.common.util.concurrent.ListenableFuture splitReadStream( - com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse> + splitReadStream(com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSplitReadStreamMethod(), getCallOptions()), request); } @@ -478,11 +586,11 @@ public com.google.common.util.concurrent.ListenableFuture implements - io.grpc.stub.ServerCalls.UnaryMethod , - io.grpc.stub.ServerCalls.ServerStreamingMethod , - io.grpc.stub.ServerCalls.ClientStreamingMethod , - io.grpc.stub.ServerCalls.BidiStreamingMethod { + private static final class MethodHandlers + implements io.grpc.stub.ServerCalls.UnaryMethod , + io.grpc.stub.ServerCalls.ServerStreamingMethod , + io.grpc.stub.ServerCalls.ClientStreamingMethod , + io.grpc.stub.ServerCalls.BidiStreamingMethod { private final AsyncService serviceImpl; private final int methodId; @@ -496,16 +604,23 @@ private static final class MethodHandlers implements public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { case METHODID_CREATE_READ_SESSION: - serviceImpl.createReadSession((com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.createReadSession( + (com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest) request, + (io.grpc.stub.StreamObserver ) + responseObserver); break; case METHODID_READ_ROWS: - serviceImpl.readRows((com.google.cloud.bigquery.storage.v1.ReadRowsRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.readRows( + (com.google.cloud.bigquery.storage.v1.ReadRowsRequest) request, + (io.grpc.stub.StreamObserver ) + responseObserver); break; case METHODID_SPLIT_READ_STREAM: - serviceImpl.splitReadStream((com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.splitReadStream( + (com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest) request, + (io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>) + responseObserver); break; default: throw new AssertionError(); @@ -526,31 +641,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))) + 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))) + 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))) + 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 static abstract class BigQueryReadBaseDescriptorSupplier - implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { + private abstract static class BigQueryReadBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoFileDescriptorSupplier, + io.grpc.protobuf.ProtoServiceDescriptorSupplier { BigQueryReadBaseDescriptorSupplier() {} @java.lang.Override @@ -592,12 +708,14 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() { synchronized (BigQueryReadGrpc.class) { result = serviceDescriptor; if (result == null) { - serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) - .setSchemaDescriptor(new BigQueryReadFileDescriptorSupplier()) - .addMethod(getCreateReadSessionMethod()) - .addMethod(getReadRowsMethod()) - .addMethod(getSplitReadStreamMethod()) - .build(); + serviceDescriptor = + result = + io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) + .setSchemaDescriptor(new BigQueryReadFileDescriptorSupplier()) + .addMethod(getCreateReadSessionMethod()) + .addMethod(getReadRowsMethod()) + .addMethod(getSplitReadStreamMethod()) + .build(); } } } diff --git a/owl-bot-staging/v1/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 similarity index 50% rename from owl-bot-staging/v1/grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteGrpc.java rename to grpc-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteGrpc.java index 1344d37861..1553527690 100644 --- a/owl-bot-staging/v1/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 @@ -1,8 +1,25 @@ +/* + * Copyright 2023 Google LLC + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package com.google.cloud.bigquery.storage.v1; import static io.grpc.MethodDescriptor.generateFullMethodName; /** + * + * * * BigQuery Write API. * The Write API can be used to write data to BigQuery. @@ -21,237 +38,335 @@ private BigQueryWriteGrpc() {} public static final String SERVICE_NAME = "google.cloud.bigquery.storage.v1.BigQueryWrite"; // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptorgetCreateWriteStreamMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest, + com.google.cloud.bigquery.storage.v1.WriteStream> + getCreateWriteStreamMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "CreateWriteStream", requestType = com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest.class, responseType = com.google.cloud.bigquery.storage.v1.WriteStream.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getCreateWriteStreamMethod() { - io.grpc.MethodDescriptor getCreateWriteStreamMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest, + com.google.cloud.bigquery.storage.v1.WriteStream> + getCreateWriteStreamMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest, + com.google.cloud.bigquery.storage.v1.WriteStream> + getCreateWriteStreamMethod; if ((getCreateWriteStreamMethod = BigQueryWriteGrpc.getCreateWriteStreamMethod) == null) { synchronized (BigQueryWriteGrpc.class) { if ((getCreateWriteStreamMethod = BigQueryWriteGrpc.getCreateWriteStreamMethod) == null) { - BigQueryWriteGrpc.getCreateWriteStreamMethod = getCreateWriteStreamMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateWriteStream")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.WriteStream.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryWriteMethodDescriptorSupplier("CreateWriteStream")) - .build(); + BigQueryWriteGrpc.getCreateWriteStreamMethod = + getCreateWriteStreamMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateWriteStream")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.WriteStream + .getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryWriteMethodDescriptorSupplier("CreateWriteStream")) + .build(); } } } return getCreateWriteStreamMethod; } - private static volatile io.grpc.MethodDescriptor getAppendRowsMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.AppendRowsRequest, + com.google.cloud.bigquery.storage.v1.AppendRowsResponse> + getAppendRowsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "AppendRows", requestType = com.google.cloud.bigquery.storage.v1.AppendRowsRequest.class, responseType = com.google.cloud.bigquery.storage.v1.AppendRowsResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) - public static io.grpc.MethodDescriptor getAppendRowsMethod() { - io.grpc.MethodDescriptor getAppendRowsMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.AppendRowsRequest, + com.google.cloud.bigquery.storage.v1.AppendRowsResponse> + getAppendRowsMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.AppendRowsRequest, + com.google.cloud.bigquery.storage.v1.AppendRowsResponse> + getAppendRowsMethod; if ((getAppendRowsMethod = BigQueryWriteGrpc.getAppendRowsMethod) == null) { synchronized (BigQueryWriteGrpc.class) { if ((getAppendRowsMethod = BigQueryWriteGrpc.getAppendRowsMethod) == null) { - BigQueryWriteGrpc.getAppendRowsMethod = getAppendRowsMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "AppendRows")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.AppendRowsRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.AppendRowsResponse.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryWriteMethodDescriptorSupplier("AppendRows")) - .build(); + BigQueryWriteGrpc.getAppendRowsMethod = + getAppendRowsMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "AppendRows")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.AppendRowsRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.AppendRowsResponse + .getDefaultInstance())) + .setSchemaDescriptor(new BigQueryWriteMethodDescriptorSupplier("AppendRows")) + .build(); } } } return getAppendRowsMethod; } - private static volatile io.grpc.MethodDescriptor getGetWriteStreamMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest, + com.google.cloud.bigquery.storage.v1.WriteStream> + getGetWriteStreamMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetWriteStream", requestType = com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest.class, responseType = com.google.cloud.bigquery.storage.v1.WriteStream.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getGetWriteStreamMethod() { - io.grpc.MethodDescriptor getGetWriteStreamMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest, + com.google.cloud.bigquery.storage.v1.WriteStream> + getGetWriteStreamMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest, + com.google.cloud.bigquery.storage.v1.WriteStream> + getGetWriteStreamMethod; if ((getGetWriteStreamMethod = BigQueryWriteGrpc.getGetWriteStreamMethod) == null) { synchronized (BigQueryWriteGrpc.class) { if ((getGetWriteStreamMethod = BigQueryWriteGrpc.getGetWriteStreamMethod) == null) { - BigQueryWriteGrpc.getGetWriteStreamMethod = getGetWriteStreamMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetWriteStream")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.WriteStream.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryWriteMethodDescriptorSupplier("GetWriteStream")) - .build(); + BigQueryWriteGrpc.getGetWriteStreamMethod = + getGetWriteStreamMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetWriteStream")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.WriteStream + .getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryWriteMethodDescriptorSupplier("GetWriteStream")) + .build(); } } } return getGetWriteStreamMethod; } - private static volatile io.grpc.MethodDescriptor getFinalizeWriteStreamMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest, + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse> + getFinalizeWriteStreamMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "FinalizeWriteStream", requestType = com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest.class, responseType = com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getFinalizeWriteStreamMethod() { - io.grpc.MethodDescriptor getFinalizeWriteStreamMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest, + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse> + getFinalizeWriteStreamMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest, + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse> + getFinalizeWriteStreamMethod; if ((getFinalizeWriteStreamMethod = BigQueryWriteGrpc.getFinalizeWriteStreamMethod) == null) { synchronized (BigQueryWriteGrpc.class) { - if ((getFinalizeWriteStreamMethod = BigQueryWriteGrpc.getFinalizeWriteStreamMethod) == null) { - BigQueryWriteGrpc.getFinalizeWriteStreamMethod = getFinalizeWriteStreamMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FinalizeWriteStream")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryWriteMethodDescriptorSupplier("FinalizeWriteStream")) - .build(); + if ((getFinalizeWriteStreamMethod = BigQueryWriteGrpc.getFinalizeWriteStreamMethod) + == null) { + BigQueryWriteGrpc.getFinalizeWriteStreamMethod = + getFinalizeWriteStreamMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName( + generateFullMethodName(SERVICE_NAME, "FinalizeWriteStream")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse + .getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryWriteMethodDescriptorSupplier("FinalizeWriteStream")) + .build(); } } } return getFinalizeWriteStreamMethod; } - private static volatile io.grpc.MethodDescriptor getBatchCommitWriteStreamsMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest, + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse> + getBatchCommitWriteStreamsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "BatchCommitWriteStreams", requestType = com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest.class, responseType = com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getBatchCommitWriteStreamsMethod() { - io.grpc.MethodDescriptor getBatchCommitWriteStreamsMethod; - if ((getBatchCommitWriteStreamsMethod = BigQueryWriteGrpc.getBatchCommitWriteStreamsMethod) == null) { + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest, + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse> + getBatchCommitWriteStreamsMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest, + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse> + getBatchCommitWriteStreamsMethod; + if ((getBatchCommitWriteStreamsMethod = BigQueryWriteGrpc.getBatchCommitWriteStreamsMethod) + == null) { synchronized (BigQueryWriteGrpc.class) { - if ((getBatchCommitWriteStreamsMethod = BigQueryWriteGrpc.getBatchCommitWriteStreamsMethod) == null) { - BigQueryWriteGrpc.getBatchCommitWriteStreamsMethod = getBatchCommitWriteStreamsMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "BatchCommitWriteStreams")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryWriteMethodDescriptorSupplier("BatchCommitWriteStreams")) - .build(); + if ((getBatchCommitWriteStreamsMethod = BigQueryWriteGrpc.getBatchCommitWriteStreamsMethod) + == null) { + BigQueryWriteGrpc.getBatchCommitWriteStreamsMethod = + getBatchCommitWriteStreamsMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName( + generateFullMethodName(SERVICE_NAME, "BatchCommitWriteStreams")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse + .getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryWriteMethodDescriptorSupplier("BatchCommitWriteStreams")) + .build(); } } } return getBatchCommitWriteStreamsMethod; } - private static volatile io.grpc.MethodDescriptor getFlushRowsMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.FlushRowsRequest, + com.google.cloud.bigquery.storage.v1.FlushRowsResponse> + getFlushRowsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "FlushRows", requestType = com.google.cloud.bigquery.storage.v1.FlushRowsRequest.class, responseType = com.google.cloud.bigquery.storage.v1.FlushRowsResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getFlushRowsMethod() { - io.grpc.MethodDescriptor getFlushRowsMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.FlushRowsRequest, + com.google.cloud.bigquery.storage.v1.FlushRowsResponse> + getFlushRowsMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1.FlushRowsRequest, + com.google.cloud.bigquery.storage.v1.FlushRowsResponse> + getFlushRowsMethod; if ((getFlushRowsMethod = BigQueryWriteGrpc.getFlushRowsMethod) == null) { synchronized (BigQueryWriteGrpc.class) { if ((getFlushRowsMethod = BigQueryWriteGrpc.getFlushRowsMethod) == null) { - BigQueryWriteGrpc.getFlushRowsMethod = getFlushRowsMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FlushRows")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.FlushRowsRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1.FlushRowsResponse.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryWriteMethodDescriptorSupplier("FlushRows")) - .build(); + BigQueryWriteGrpc.getFlushRowsMethod = + getFlushRowsMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FlushRows")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.FlushRowsRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1.FlushRowsResponse + .getDefaultInstance())) + .setSchemaDescriptor(new BigQueryWriteMethodDescriptorSupplier("FlushRows")) + .build(); } } } return getFlushRowsMethod; } - /** - * Creates a new async stub that supports all call types for the service - */ + /** Creates a new async stub that supports all call types for the service */ public static BigQueryWriteStub newStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public BigQueryWriteStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new BigQueryWriteStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public BigQueryWriteStub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new BigQueryWriteStub(channel, callOptions); + } + }; return BigQueryWriteStub.newStub(factory, channel); } /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ - public static BigQueryWriteBlockingStub newBlockingStub( - io.grpc.Channel channel) { + public static BigQueryWriteBlockingStub newBlockingStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public BigQueryWriteBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new BigQueryWriteBlockingStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public BigQueryWriteBlockingStub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new BigQueryWriteBlockingStub(channel, callOptions); + } + }; return BigQueryWriteBlockingStub.newStub(factory, channel); } - /** - * Creates a new ListenableFuture-style stub that supports unary calls on the service - */ - public static BigQueryWriteFutureStub newFutureStub( - io.grpc.Channel channel) { + /** Creates a new ListenableFuture-style stub that supports unary calls on the service */ + public static BigQueryWriteFutureStub newFutureStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public BigQueryWriteFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new BigQueryWriteFutureStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public BigQueryWriteFutureStub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new BigQueryWriteFutureStub(channel, callOptions); + } + }; return BigQueryWriteFutureStub.newStub(factory, channel); } /** + * + * * * BigQuery Write API. * The Write API can be used to write data to BigQuery. @@ -262,6 +377,8 @@ public BigQueryWriteFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOpti public interface AsyncService { /** + * + * ** Creates a write stream to the given table. * Additionally, every table has a special stream named '_default' @@ -271,12 +388,17 @@ public interface AsyncService { * soon as an acknowledgement is received. **/ - default void createWriteStream(com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateWriteStreamMethod(), responseObserver); + default void createWriteStream( + com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request, + io.grpc.stub.StreamObserver + responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getCreateWriteStreamMethod(), responseObserver); } /** + * + * * * Appends data to the given stream. * If `offset` is specified, the `offset` is checked against the end of @@ -304,33 +426,49 @@ default void createWriteStream(com.google.cloud.bigquery.storage.v1.CreateWriteS * committed via the `BatchCommitWriteStreams` rpc. **/ - default io.grpc.stub.StreamObserverappendRows( - io.grpc.stub.StreamObserver responseObserver) { - return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getAppendRowsMethod(), responseObserver); + default io.grpc.stub.StreamObserver + appendRows( + io.grpc.stub.StreamObserver + responseObserver) { + return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall( + getAppendRowsMethod(), responseObserver); } /** + * + * * * Gets information about a write stream. **/ - default void getWriteStream(com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetWriteStreamMethod(), responseObserver); + default void getWriteStream( + com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request, + io.grpc.stub.StreamObserver + responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getGetWriteStreamMethod(), responseObserver); } /** + * + * * * Finalize a write stream so that no new data can be appended to the * stream. Finalize is not supported on the '_default' stream. **/ - default void finalizeWriteStream(com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getFinalizeWriteStreamMethod(), responseObserver); + default void finalizeWriteStream( + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse> + responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getFinalizeWriteStreamMethod(), responseObserver); } /** + * + * * * Atomically commits a group of `PENDING` streams that belong to the same * `parent` table. @@ -339,12 +477,18 @@ default void finalizeWriteStream(com.google.cloud.bigquery.storage.v1.FinalizeWr * for read operations. **/ - default void batchCommitWriteStreams(com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getBatchCommitWriteStreamsMethod(), responseObserver); + default void batchCommitWriteStreams( + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse> + responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getBatchCommitWriteStreamsMethod(), responseObserver); } /** + * + * * * Flushes rows to a BUFFERED stream. * If users are appending rows to BUFFERED stream, flush operation is @@ -354,14 +498,17 @@ default void batchCommitWriteStreams(com.google.cloud.bigquery.storage.v1.BatchC * Flush is not supported on the _default stream, since it is not BUFFERED. **/ - default void flushRows(com.google.cloud.bigquery.storage.v1.FlushRowsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + 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. @@ -369,16 +516,18 @@ default void flushRows(com.google.cloud.bigquery.storage.v1.FlushRowsRequest req * https://cloud.google.com/bigquery/docs/write-api **/ - public static abstract class BigQueryWriteImplBase + public abstract static class BigQueryWriteImplBase implements io.grpc.BindableService, AsyncService { - @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { + @java.lang.Override + public final io.grpc.ServerServiceDefinition bindService() { return BigQueryWriteGrpc.bindService(this); } } /** * A stub to allow clients to do asynchronous rpc calls to service BigQueryWrite. + * ** BigQuery Write API. * The Write API can be used to write data to BigQuery. @@ -388,18 +537,18 @@ public static abstract class BigQueryWriteImplBase */ public static final class BigQueryWriteStub extends io.grpc.stub.AbstractAsyncStub{ - private BigQueryWriteStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + private BigQueryWriteStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @java.lang.Override - protected BigQueryWriteStub build( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + protected BigQueryWriteStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new BigQueryWriteStub(channel, callOptions); } /** + * + * * * Creates a write stream to the given table. * Additionally, every table has a special stream named '_default' @@ -409,13 +558,19 @@ protected BigQueryWriteStub build( * soon as an acknowledgement is received. **/ - public void createWriteStream(com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void createWriteStream( + com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request, + io.grpc.stub.StreamObserver + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getCreateWriteStreamMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getCreateWriteStreamMethod(), getCallOptions()), + request, + responseObserver); } /** + * + * * * Appends data to the given stream. * If `offset` is specified, the `offset` is checked against the end of @@ -443,36 +598,53 @@ public void createWriteStream(com.google.cloud.bigquery.storage.v1.CreateWriteSt * committed via the `BatchCommitWriteStreams` rpc. **/ - public io.grpc.stub.StreamObserverappendRows( - io.grpc.stub.StreamObserver responseObserver) { + public io.grpc.stub.StreamObserver + appendRows( + io.grpc.stub.StreamObserver + responseObserver) { return io.grpc.stub.ClientCalls.asyncBidiStreamingCall( getChannel().newCall(getAppendRowsMethod(), getCallOptions()), responseObserver); } /** + * + * * * Gets information about a write stream. **/ - public void getWriteStream(com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void getWriteStream( + com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request, + io.grpc.stub.StreamObserver + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getGetWriteStreamMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getGetWriteStreamMethod(), getCallOptions()), + request, + responseObserver); } /** + * + * * * Finalize a write stream so that no new data can be appended to the * stream. Finalize is not supported on the '_default' stream. **/ - public void finalizeWriteStream(com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void finalizeWriteStream( + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse> + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getFinalizeWriteStreamMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getFinalizeWriteStreamMethod(), getCallOptions()), + request, + responseObserver); } /** + * + * * * Atomically commits a group of `PENDING` streams that belong to the same * `parent` table. @@ -481,13 +653,20 @@ public void finalizeWriteStream(com.google.cloud.bigquery.storage.v1.FinalizeWri * for read operations. **/ - public void batchCommitWriteStreams(com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void batchCommitWriteStreams( + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse> + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getBatchCommitWriteStreamsMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getBatchCommitWriteStreamsMethod(), getCallOptions()), + request, + responseObserver); } /** + * + * * * Flushes rows to a BUFFERED stream. * If users are appending rows to BUFFERED stream, flush operation is @@ -497,8 +676,10 @@ public void batchCommitWriteStreams(com.google.cloud.bigquery.storage.v1.BatchCo * Flush is not supported on the _default stream, since it is not BUFFERED. **/ - public void flushRows(com.google.cloud.bigquery.storage.v1.FlushRowsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void flushRows( + com.google.cloud.bigquery.storage.v1.FlushRowsRequest request, + io.grpc.stub.StreamObserver + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( getChannel().newCall(getFlushRowsMethod(), getCallOptions()), request, responseObserver); } @@ -506,6 +687,7 @@ public void flushRows(com.google.cloud.bigquery.storage.v1.FlushRowsRequest requ /** * A stub to allow clients to do synchronous rpc calls to service BigQueryWrite. + * * * BigQuery Write API. * The Write API can be used to write data to BigQuery. @@ -515,8 +697,7 @@ public void flushRows(com.google.cloud.bigquery.storage.v1.FlushRowsRequest requ */ public static final class BigQueryWriteBlockingStub extends io.grpc.stub.AbstractBlockingStub{ - private BigQueryWriteBlockingStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + private BigQueryWriteBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @@ -527,6 +708,8 @@ protected BigQueryWriteBlockingStub build( } /** + * + * * * Creates a write stream to the given table. * Additionally, every table has a special stream named '_default' @@ -536,33 +719,42 @@ protected BigQueryWriteBlockingStub build( * soon as an acknowledgement is received. **/ - public com.google.cloud.bigquery.storage.v1.WriteStream createWriteStream(com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request) { + public com.google.cloud.bigquery.storage.v1.WriteStream createWriteStream( + com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getCreateWriteStreamMethod(), getCallOptions(), request); } /** + * + * ** Gets information about a write stream. **/ - public com.google.cloud.bigquery.storage.v1.WriteStream getWriteStream(com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request) { + public com.google.cloud.bigquery.storage.v1.WriteStream getWriteStream( + com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getGetWriteStreamMethod(), getCallOptions(), request); } /** + * + * ** Finalize a write stream so that no new data can be appended to the * stream. Finalize is not supported on the '_default' stream. **/ - public com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse finalizeWriteStream(com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request) { + public com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse finalizeWriteStream( + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getFinalizeWriteStreamMethod(), getCallOptions(), request); } /** + * + * ** Atomically commits a group of `PENDING` streams that belong to the same * `parent` table. @@ -571,12 +763,16 @@ public com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse finalize * for read operations. **/ - public com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse batchCommitWriteStreams(com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request) { + public com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse + batchCommitWriteStreams( + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getBatchCommitWriteStreamsMethod(), getCallOptions(), request); } /** + * + * ** Flushes rows to a BUFFERED stream. * If users are appending rows to BUFFERED stream, flush operation is @@ -586,7 +782,8 @@ public com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse batc * Flush is not supported on the _default stream, since it is not BUFFERED. **/ - public com.google.cloud.bigquery.storage.v1.FlushRowsResponse flushRows(com.google.cloud.bigquery.storage.v1.FlushRowsRequest request) { + public com.google.cloud.bigquery.storage.v1.FlushRowsResponse flushRows( + com.google.cloud.bigquery.storage.v1.FlushRowsRequest request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getFlushRowsMethod(), getCallOptions(), request); } @@ -594,6 +791,7 @@ public com.google.cloud.bigquery.storage.v1.FlushRowsResponse flushRows(com.goog /** * A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryWrite. + * ** BigQuery Write API. * The Write API can be used to write data to BigQuery. @@ -603,8 +801,7 @@ public com.google.cloud.bigquery.storage.v1.FlushRowsResponse flushRows(com.goog */ public static final class BigQueryWriteFutureStub extends io.grpc.stub.AbstractFutureStub{ - private BigQueryWriteFutureStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + private BigQueryWriteFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @@ -615,6 +812,8 @@ protected BigQueryWriteFutureStub build( } /** + * + * * * Creates a write stream to the given table. * Additionally, every table has a special stream named '_default' @@ -624,36 +823,46 @@ protected BigQueryWriteFutureStub build( * soon as an acknowledgement is received. **/ - public com.google.common.util.concurrent.ListenableFuturecreateWriteStream( - com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1.WriteStream> + createWriteStream(com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getCreateWriteStreamMethod(), getCallOptions()), request); } /** + * + * * * Gets information about a write stream. **/ - public com.google.common.util.concurrent.ListenableFuturegetWriteStream( - com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1.WriteStream> + getWriteStream(com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getGetWriteStreamMethod(), getCallOptions()), request); } /** + * + * * * Finalize a write stream so that no new data can be appended to the * stream. Finalize is not supported on the '_default' stream. **/ - public com.google.common.util.concurrent.ListenableFuturefinalizeWriteStream( - com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse> + finalizeWriteStream( + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getFinalizeWriteStreamMethod(), getCallOptions()), request); } /** + * + * * * Atomically commits a group of `PENDING` streams that belong to the same * `parent` table. @@ -662,13 +871,17 @@ public com.google.common.util.concurrent.ListenableFuture*/ - public com.google.common.util.concurrent.ListenableFuture batchCommitWriteStreams( - com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse> + batchCommitWriteStreams( + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getBatchCommitWriteStreamsMethod(), getCallOptions()), request); } /** + * + * * * Flushes rows to a BUFFERED stream. * If users are appending rows to BUFFERED stream, flush operation is @@ -678,8 +891,9 @@ public com.google.common.util.concurrent.ListenableFuture*/ - public com.google.common.util.concurrent.ListenableFuture flushRows( - com.google.cloud.bigquery.storage.v1.FlushRowsRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1.FlushRowsResponse> + flushRows(com.google.cloud.bigquery.storage.v1.FlushRowsRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getFlushRowsMethod(), getCallOptions()), request); } @@ -692,11 +906,11 @@ public com.google.common.util.concurrent.ListenableFuture implements - io.grpc.stub.ServerCalls.UnaryMethod , - io.grpc.stub.ServerCalls.ServerStreamingMethod , - io.grpc.stub.ServerCalls.ClientStreamingMethod , - io.grpc.stub.ServerCalls.BidiStreamingMethod { + private static final class MethodHandlers + implements io.grpc.stub.ServerCalls.UnaryMethod , + io.grpc.stub.ServerCalls.ServerStreamingMethod , + io.grpc.stub.ServerCalls.ClientStreamingMethod , + io.grpc.stub.ServerCalls.BidiStreamingMethod { private final AsyncService serviceImpl; private final int methodId; @@ -710,24 +924,36 @@ private static final class MethodHandlers implements public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { case METHODID_CREATE_WRITE_STREAM: - serviceImpl.createWriteStream((com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.createWriteStream( + (com.google.cloud.bigquery.storage.v1.CreateWriteStreamRequest) request, + (io.grpc.stub.StreamObserver ) + responseObserver); break; case METHODID_GET_WRITE_STREAM: - serviceImpl.getWriteStream((com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.getWriteStream( + (com.google.cloud.bigquery.storage.v1.GetWriteStreamRequest) request, + (io.grpc.stub.StreamObserver ) + responseObserver); break; case METHODID_FINALIZE_WRITE_STREAM: - serviceImpl.finalizeWriteStream((com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.finalizeWriteStream( + (com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamRequest) request, + (io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1.FinalizeWriteStreamResponse>) + responseObserver); break; case METHODID_BATCH_COMMIT_WRITE_STREAMS: - serviceImpl.batchCommitWriteStreams((com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.batchCommitWriteStreams( + (com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsRequest) request, + (io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1.BatchCommitWriteStreamsResponse>) + responseObserver); break; case METHODID_FLUSH_ROWS: - serviceImpl.flushRows((com.google.cloud.bigquery.storage.v1.FlushRowsRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.flushRows( + (com.google.cloud.bigquery.storage.v1.FlushRowsRequest) request, + (io.grpc.stub.StreamObserver ) + responseObserver); break; default: throw new AssertionError(); @@ -740,8 +966,11 @@ public io.grpc.stub.StreamObserver invoke( io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { case METHODID_APPEND_ROWS: - return (io.grpc.stub.StreamObserver ) serviceImpl.appendRows( - (io.grpc.stub.StreamObserver ) responseObserver); + return (io.grpc.stub.StreamObserver ) + serviceImpl.appendRows( + (io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1.AppendRowsResponse>) + responseObserver); default: throw new AssertionError(); } @@ -751,52 +980,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))) + 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))) + 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))) + 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))) + 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))) + 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))) + 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 static abstract class BigQueryWriteBaseDescriptorSupplier - implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { + private abstract static class BigQueryWriteBaseDescriptorSupplier + implements io.grpc.protobuf.ProtoFileDescriptorSupplier, + io.grpc.protobuf.ProtoServiceDescriptorSupplier { BigQueryWriteBaseDescriptorSupplier() {} @java.lang.Override @@ -838,15 +1068,17 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() { synchronized (BigQueryWriteGrpc.class) { result = serviceDescriptor; if (result == null) { - serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) - .setSchemaDescriptor(new BigQueryWriteFileDescriptorSupplier()) - .addMethod(getCreateWriteStreamMethod()) - .addMethod(getAppendRowsMethod()) - .addMethod(getGetWriteStreamMethod()) - .addMethod(getFinalizeWriteStreamMethod()) - .addMethod(getBatchCommitWriteStreamsMethod()) - .addMethod(getFlushRowsMethod()) - .build(); + serviceDescriptor = + result = + io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) + .setSchemaDescriptor(new BigQueryWriteFileDescriptorSupplier()) + .addMethod(getCreateWriteStreamMethod()) + .addMethod(getAppendRowsMethod()) + .addMethod(getGetWriteStreamMethod()) + .addMethod(getFinalizeWriteStreamMethod()) + .addMethod(getBatchCommitWriteStreamsMethod()) + .addMethod(getFlushRowsMethod()) + .build(); } } } diff --git a/owl-bot-staging/v1beta1/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 similarity index 53% rename from owl-bot-staging/v1beta1/grpc-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BigQueryStorageGrpc.java rename to grpc-google-cloud-bigquerystorage-v1beta1/src/main/java/com/google/cloud/bigquery/storage/v1beta1/BigQueryStorageGrpc.java index a7b35fd6a5..6a31e3f930 100644 --- a/owl-bot-staging/v1beta1/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 @@ -1,8 +1,25 @@ +/* + * Copyright 2023 Google LLC + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package com.google.cloud.bigquery.storage.v1beta1; import static io.grpc.MethodDescriptor.generateFullMethodName; /** + * + * * * BigQuery storage API. * The BigQuery storage API can be used to read data stored in BigQuery. @@ -23,206 +40,297 @@ private BigQueryStorageGrpc() {} public static final String SERVICE_NAME = "google.cloud.bigquery.storage.v1beta1.BigQueryStorage"; // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptorgetCreateReadSessionMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession> + getCreateReadSessionMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "CreateReadSession", - requestType = com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest.class, + requestType = + com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest.class, responseType = com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getCreateReadSessionMethod() { - io.grpc.MethodDescriptor getCreateReadSessionMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession> + getCreateReadSessionMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession> + getCreateReadSessionMethod; if ((getCreateReadSessionMethod = BigQueryStorageGrpc.getCreateReadSessionMethod) == null) { synchronized (BigQueryStorageGrpc.class) { if ((getCreateReadSessionMethod = BigQueryStorageGrpc.getCreateReadSessionMethod) == null) { - BigQueryStorageGrpc.getCreateReadSessionMethod = getCreateReadSessionMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateReadSession")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryStorageMethodDescriptorSupplier("CreateReadSession")) - .build(); + BigQueryStorageGrpc.getCreateReadSessionMethod = + getCreateReadSessionMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateReadSession")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1beta1.Storage + .CreateReadSessionRequest.getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession + .getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryStorageMethodDescriptorSupplier("CreateReadSession")) + .build(); } } } return getCreateReadSessionMethod; } - private static volatile io.grpc.MethodDescriptor getReadRowsMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> + getReadRowsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ReadRows", requestType = com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest.class, responseType = com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) - public static io.grpc.MethodDescriptor getReadRowsMethod() { - io.grpc.MethodDescriptor getReadRowsMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> + getReadRowsMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> + getReadRowsMethod; if ((getReadRowsMethod = BigQueryStorageGrpc.getReadRowsMethod) == null) { synchronized (BigQueryStorageGrpc.class) { if ((getReadRowsMethod = BigQueryStorageGrpc.getReadRowsMethod) == null) { - BigQueryStorageGrpc.getReadRowsMethod = getReadRowsMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ReadRows")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryStorageMethodDescriptorSupplier("ReadRows")) - .build(); + BigQueryStorageGrpc.getReadRowsMethod = + getReadRowsMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ReadRows")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest + .getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse + .getDefaultInstance())) + .setSchemaDescriptor(new BigQueryStorageMethodDescriptorSupplier("ReadRows")) + .build(); } } } return getReadRowsMethod; } - private static volatile io.grpc.MethodDescriptor getBatchCreateReadSessionStreamsMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse> + getBatchCreateReadSessionStreamsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "BatchCreateReadSessionStreams", - requestType = com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest.class, - responseType = com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse.class, + requestType = + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest + .class, + responseType = + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse + .class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getBatchCreateReadSessionStreamsMethod() { - io.grpc.MethodDescriptor getBatchCreateReadSessionStreamsMethod; - if ((getBatchCreateReadSessionStreamsMethod = BigQueryStorageGrpc.getBatchCreateReadSessionStreamsMethod) == null) { + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse> + getBatchCreateReadSessionStreamsMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse> + getBatchCreateReadSessionStreamsMethod; + if ((getBatchCreateReadSessionStreamsMethod = + BigQueryStorageGrpc.getBatchCreateReadSessionStreamsMethod) + == null) { synchronized (BigQueryStorageGrpc.class) { - if ((getBatchCreateReadSessionStreamsMethod = BigQueryStorageGrpc.getBatchCreateReadSessionStreamsMethod) == null) { - BigQueryStorageGrpc.getBatchCreateReadSessionStreamsMethod = getBatchCreateReadSessionStreamsMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "BatchCreateReadSessionStreams")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryStorageMethodDescriptorSupplier("BatchCreateReadSessionStreams")) - .build(); + if ((getBatchCreateReadSessionStreamsMethod = + BigQueryStorageGrpc.getBatchCreateReadSessionStreamsMethod) + == null) { + BigQueryStorageGrpc.getBatchCreateReadSessionStreamsMethod = + getBatchCreateReadSessionStreamsMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName( + generateFullMethodName(SERVICE_NAME, "BatchCreateReadSessionStreams")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1beta1.Storage + .BatchCreateReadSessionStreamsRequest.getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1beta1.Storage + .BatchCreateReadSessionStreamsResponse.getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryStorageMethodDescriptorSupplier( + "BatchCreateReadSessionStreams")) + .build(); } } } return getBatchCreateReadSessionStreamsMethod; } - private static volatile io.grpc.MethodDescriptor getFinalizeStreamMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest, + com.google.protobuf.Empty> + getFinalizeStreamMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "FinalizeStream", requestType = com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest.class, responseType = com.google.protobuf.Empty.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getFinalizeStreamMethod() { - io.grpc.MethodDescriptor getFinalizeStreamMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest, + com.google.protobuf.Empty> + getFinalizeStreamMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest, + com.google.protobuf.Empty> + getFinalizeStreamMethod; if ((getFinalizeStreamMethod = BigQueryStorageGrpc.getFinalizeStreamMethod) == null) { synchronized (BigQueryStorageGrpc.class) { if ((getFinalizeStreamMethod = BigQueryStorageGrpc.getFinalizeStreamMethod) == null) { - BigQueryStorageGrpc.getFinalizeStreamMethod = getFinalizeStreamMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FinalizeStream")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.protobuf.Empty.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryStorageMethodDescriptorSupplier("FinalizeStream")) - .build(); + BigQueryStorageGrpc.getFinalizeStreamMethod = + getFinalizeStreamMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "FinalizeStream")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1beta1.Storage + .FinalizeStreamRequest.getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.protobuf.Empty.getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryStorageMethodDescriptorSupplier("FinalizeStream")) + .build(); } } } return getFinalizeStreamMethod; } - private static volatile io.grpc.MethodDescriptor getSplitReadStreamMethod; + private static volatile io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse> + getSplitReadStreamMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "SplitReadStream", requestType = com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest.class, - responseType = com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse.class, + responseType = + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor getSplitReadStreamMethod() { - io.grpc.MethodDescriptor getSplitReadStreamMethod; + public static io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse> + getSplitReadStreamMethod() { + io.grpc.MethodDescriptor< + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest, + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse> + getSplitReadStreamMethod; if ((getSplitReadStreamMethod = BigQueryStorageGrpc.getSplitReadStreamMethod) == null) { synchronized (BigQueryStorageGrpc.class) { if ((getSplitReadStreamMethod = BigQueryStorageGrpc.getSplitReadStreamMethod) == null) { - BigQueryStorageGrpc.getSplitReadStreamMethod = getSplitReadStreamMethod = - io.grpc.MethodDescriptor. newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SplitReadStream")) - .setSampledToLocalTracing(true) - .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest.getDefaultInstance())) - .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( - com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse.getDefaultInstance())) - .setSchemaDescriptor(new BigQueryStorageMethodDescriptorSupplier("SplitReadStream")) - .build(); + BigQueryStorageGrpc.getSplitReadStreamMethod = + getSplitReadStreamMethod = + io.grpc.MethodDescriptor + . + newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "SplitReadStream")) + .setSampledToLocalTracing(true) + .setRequestMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1beta1.Storage + .SplitReadStreamRequest.getDefaultInstance())) + .setResponseMarshaller( + io.grpc.protobuf.ProtoUtils.marshaller( + com.google.cloud.bigquery.storage.v1beta1.Storage + .SplitReadStreamResponse.getDefaultInstance())) + .setSchemaDescriptor( + new BigQueryStorageMethodDescriptorSupplier("SplitReadStream")) + .build(); } } } return getSplitReadStreamMethod; } - /** - * Creates a new async stub that supports all call types for the service - */ + /** Creates a new async stub that supports all call types for the service */ public static BigQueryStorageStub newStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public BigQueryStorageStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new BigQueryStorageStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public BigQueryStorageStub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new BigQueryStorageStub(channel, callOptions); + } + }; return BigQueryStorageStub.newStub(factory, channel); } /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ - public static BigQueryStorageBlockingStub newBlockingStub( - io.grpc.Channel channel) { + public static BigQueryStorageBlockingStub newBlockingStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public BigQueryStorageBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new BigQueryStorageBlockingStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public BigQueryStorageBlockingStub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new BigQueryStorageBlockingStub(channel, callOptions); + } + }; return BigQueryStorageBlockingStub.newStub(factory, channel); } - /** - * Creates a new ListenableFuture-style stub that supports unary calls on the service - */ - public static BigQueryStorageFutureStub newFutureStub( - io.grpc.Channel channel) { + /** Creates a new ListenableFuture-style stub that supports unary calls on the service */ + public static BigQueryStorageFutureStub newFutureStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public BigQueryStorageFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new BigQueryStorageFutureStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public BigQueryStorageFutureStub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new BigQueryStorageFutureStub(channel, callOptions); + } + }; return BigQueryStorageFutureStub.newStub(factory, channel); } /** + * + * * * BigQuery storage API. * The BigQuery storage API can be used to read data stored in BigQuery. @@ -235,6 +343,8 @@ public BigQueryStorageFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOp public interface AsyncService { /** + * + * ** Creates a new read session. A read session divides the contents of a * BigQuery table into one or more streams, which can then be used to read @@ -248,12 +358,17 @@ public interface AsyncService { * not require manual clean-up by the caller. **/ - default void createReadSession(com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request, - io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateReadSessionMethod(), responseObserver); + default void createReadSession( + com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request, + io.grpc.stub.StreamObserver + responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getCreateReadSessionMethod(), responseObserver); } /** + * + * * * Reads rows from the table in the format prescribed by the read session. * Each response contains one or more table rows, up to a maximum of 10 MiB @@ -265,24 +380,37 @@ default void createReadSession(com.google.cloud.bigquery.storage.v1beta1.Storage * session, and may change as other streams continue to read data. **/ - default void readRows(com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + default void readRows( + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> + responseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getReadRowsMethod(), responseObserver); } /** + * + * * * Creates additional streams for a ReadSession. This API can be used to * dynamically adjust the parallelism of a batch processing task upwards by * adding additional workers. **/ - default void batchCreateReadSessionStreams(com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getBatchCreateReadSessionStreamsMethod(), responseObserver); + default void batchCreateReadSessionStreams( + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest + request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1beta1.Storage + .BatchCreateReadSessionStreamsResponse> + responseObserver) { + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getBatchCreateReadSessionStreamsMethod(), responseObserver); } /** + * + * * * Causes a single stream in a ReadSession to gracefully stop. This * API can be used to dynamically adjust the parallelism of a batch processing @@ -298,12 +426,16 @@ default void batchCreateReadSessionStreams(com.google.cloud.bigquery.storage.v1b * Stream. **/ - default void finalizeStream(com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request, + default void finalizeStream( + com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request, io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getFinalizeStreamMethod(), responseObserver); + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( + getFinalizeStreamMethod(), responseObserver); } /** + * + * * * Splits a given read stream into two Streams. These streams are referred to * as the primary and the residual of the split. The original stream can still @@ -318,14 +450,19 @@ default void finalizeStream(com.google.cloud.bigquery.storage.v1beta1.Storage.Fi * This method is guaranteed to be idempotent. **/ - default void splitReadStream(com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getSplitReadStreamMethod(), responseObserver); + default void splitReadStream( + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse> + responseObserver) { + 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. @@ -335,16 +472,18 @@ default void splitReadStream(com.google.cloud.bigquery.storage.v1beta1.Storage.S * going forward. **/ - public static abstract class BigQueryStorageImplBase + public abstract static class BigQueryStorageImplBase implements io.grpc.BindableService, AsyncService { - @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { + @java.lang.Override + public final io.grpc.ServerServiceDefinition bindService() { return BigQueryStorageGrpc.bindService(this); } } /** * A stub to allow clients to do asynchronous rpc calls to service BigQueryStorage. + * ** BigQuery storage API. * The BigQuery storage API can be used to read data stored in BigQuery. @@ -356,18 +495,18 @@ public static abstract class BigQueryStorageImplBase */ public static final class BigQueryStorageStub extends io.grpc.stub.AbstractAsyncStub{ - private BigQueryStorageStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + private BigQueryStorageStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @java.lang.Override - protected BigQueryStorageStub build( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + protected BigQueryStorageStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { return new BigQueryStorageStub(channel, callOptions); } /** + * + * * * Creates a new read session. A read session divides the contents of a * BigQuery table into one or more streams, which can then be used to read @@ -381,13 +520,19 @@ protected BigQueryStorageStub build( * not require manual clean-up by the caller. **/ - public void createReadSession(com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void createReadSession( + com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request, + io.grpc.stub.StreamObserver + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getCreateReadSessionMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getCreateReadSessionMethod(), getCallOptions()), + request, + responseObserver); } /** + * + * * * Reads rows from the table in the format prescribed by the read session. * Each response contains one or more table rows, up to a maximum of 10 MiB @@ -399,26 +544,40 @@ public void createReadSession(com.google.cloud.bigquery.storage.v1beta1.Storage. * session, and may change as other streams continue to read data. **/ - public void readRows(com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void readRows( + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> + responseObserver) { io.grpc.stub.ClientCalls.asyncServerStreamingCall( getChannel().newCall(getReadRowsMethod(), getCallOptions()), request, responseObserver); } /** + * + * * * Creates additional streams for a ReadSession. This API can be used to * dynamically adjust the parallelism of a batch processing task upwards by * adding additional workers. **/ - public void batchCreateReadSessionStreams(com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void batchCreateReadSessionStreams( + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest + request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1beta1.Storage + .BatchCreateReadSessionStreamsResponse> + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getBatchCreateReadSessionStreamsMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getBatchCreateReadSessionStreamsMethod(), getCallOptions()), + request, + responseObserver); } /** + * + * * * Causes a single stream in a ReadSession to gracefully stop. This * API can be used to dynamically adjust the parallelism of a batch processing @@ -434,13 +593,18 @@ public void batchCreateReadSessionStreams(com.google.cloud.bigquery.storage.v1be * Stream. **/ - public void finalizeStream(com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request, + public void finalizeStream( + com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request, io.grpc.stub.StreamObserverresponseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getFinalizeStreamMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getFinalizeStreamMethod(), getCallOptions()), + request, + responseObserver); } /** + * + * * * Splits a given read stream into two Streams. These streams are referred to * as the primary and the residual of the split. The original stream can still @@ -455,15 +619,21 @@ public void finalizeStream(com.google.cloud.bigquery.storage.v1beta1.Storage.Fin * This method is guaranteed to be idempotent. **/ - public void splitReadStream(com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request, - io.grpc.stub.StreamObserverresponseObserver) { + public void splitReadStream( + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request, + io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse> + responseObserver) { io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getSplitReadStreamMethod(), getCallOptions()), request, responseObserver); + getChannel().newCall(getSplitReadStreamMethod(), getCallOptions()), + request, + responseObserver); } } /** * A stub to allow clients to do synchronous rpc calls to service BigQueryStorage. + * * * BigQuery storage API. * The BigQuery storage API can be used to read data stored in BigQuery. @@ -475,8 +645,7 @@ public void splitReadStream(com.google.cloud.bigquery.storage.v1beta1.Storage.Sp */ public static final class BigQueryStorageBlockingStub extends io.grpc.stub.AbstractBlockingStub{ - private BigQueryStorageBlockingStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + private BigQueryStorageBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @@ -487,6 +656,8 @@ protected BigQueryStorageBlockingStub build( } /** + * + * * * Creates a new read session. A read session divides the contents of a * BigQuery table into one or more streams, which can then be used to read @@ -500,12 +671,15 @@ protected BigQueryStorageBlockingStub build( * not require manual clean-up by the caller. **/ - public com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession createReadSession(com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request) { + 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( getChannel(), getCreateReadSessionMethod(), getCallOptions(), request); } /** + * + * ** Reads rows from the table in the format prescribed by the read session. * Each response contains one or more table rows, up to a maximum of 10 MiB @@ -517,25 +691,32 @@ public com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession createReadS * session, and may change as other streams continue to read data. **/ - public java.util.IteratorreadRows( - com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest request) { + public java.util.Iterator + readRows(com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest request) { return io.grpc.stub.ClientCalls.blockingServerStreamingCall( getChannel(), getReadRowsMethod(), getCallOptions(), request); } /** + * + * * * Creates additional streams for a ReadSession. This API can be used to * dynamically adjust the parallelism of a batch processing task upwards by * adding additional workers. **/ - public com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse batchCreateReadSessionStreams(com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest request) { + 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( getChannel(), getBatchCreateReadSessionStreamsMethod(), getCallOptions(), request); } /** + * + * ** Causes a single stream in a ReadSession to gracefully stop. This * API can be used to dynamically adjust the parallelism of a batch processing @@ -551,12 +732,15 @@ public com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionS * Stream. **/ - public com.google.protobuf.Empty finalizeStream(com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request) { + public com.google.protobuf.Empty finalizeStream( + com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request) { return io.grpc.stub.ClientCalls.blockingUnaryCall( getChannel(), getFinalizeStreamMethod(), getCallOptions(), request); } /** + * + * ** Splits a given read stream into two Streams. These streams are referred to * as the primary and the residual of the split. The original stream can still @@ -571,7 +755,9 @@ public com.google.protobuf.Empty finalizeStream(com.google.cloud.bigquery.storag * This method is guaranteed to be idempotent. **/ - public com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse splitReadStream(com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request) { + 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( getChannel(), getSplitReadStreamMethod(), getCallOptions(), request); } @@ -579,6 +765,7 @@ public com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse /** * A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryStorage. + * ** BigQuery storage API. * The BigQuery storage API can be used to read data stored in BigQuery. @@ -590,8 +777,7 @@ public com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse */ public static final class BigQueryStorageFutureStub extends io.grpc.stub.AbstractFutureStub{ - private BigQueryStorageFutureStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + private BigQueryStorageFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { super(channel, callOptions); } @@ -602,6 +788,8 @@ protected BigQueryStorageFutureStub build( } /** + * + * * * Creates a new read session. A read session divides the contents of a * BigQuery table into one or more streams, which can then be used to read @@ -615,26 +803,36 @@ protected BigQueryStorageFutureStub build( * not require manual clean-up by the caller. **/ - public com.google.common.util.concurrent.ListenableFuturecreateReadSession( - com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession> + createReadSession( + com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getCreateReadSessionMethod(), getCallOptions()), request); } /** + * + * * * Creates additional streams for a ReadSession. This API can be used to * dynamically adjust the parallelism of a batch processing task upwards by * adding additional workers. **/ - public com.google.common.util.concurrent.ListenableFuturebatchCreateReadSessionStreams( - com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse> + batchCreateReadSessionStreams( + com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest + request) { return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getBatchCreateReadSessionStreamsMethod(), getCallOptions()), request); + getChannel().newCall(getBatchCreateReadSessionStreamsMethod(), getCallOptions()), + request); } /** + * + * * * Causes a single stream in a ReadSession to gracefully stop. This * API can be used to dynamically adjust the parallelism of a batch processing @@ -650,13 +848,16 @@ public com.google.common.util.concurrent.ListenableFuture*/ - public com.google.common.util.concurrent.ListenableFuture finalizeStream( - com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request) { + public com.google.common.util.concurrent.ListenableFuture + finalizeStream( + com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getFinalizeStreamMethod(), getCallOptions()), request); } /** + * + * * * Splits a given read stream into two Streams. These streams are referred to * as the primary and the residual of the split. The original stream can still @@ -671,8 +872,10 @@ public com.google.common.util.concurrent.ListenableFuture*/ - public com.google.common.util.concurrent.ListenableFuture splitReadStream( - com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request) { + public com.google.common.util.concurrent.ListenableFuture< + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse> + splitReadStream( + com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest request) { return io.grpc.stub.ClientCalls.futureUnaryCall( getChannel().newCall(getSplitReadStreamMethod(), getCallOptions()), request); } @@ -684,11 +887,11 @@ public com.google.common.util.concurrent.ListenableFuture implements - io.grpc.stub.ServerCalls.UnaryMethod , - io.grpc.stub.ServerCalls.ServerStreamingMethod , - io.grpc.stub.ServerCalls.ClientStreamingMethod , - io.grpc.stub.ServerCalls.BidiStreamingMethod { + private static final class MethodHandlers + implements io.grpc.stub.ServerCalls.UnaryMethod , + io.grpc.stub.ServerCalls.ServerStreamingMethod , + io.grpc.stub.ServerCalls.ClientStreamingMethod , + io.grpc.stub.ServerCalls.BidiStreamingMethod { private final AsyncService serviceImpl; private final int methodId; @@ -702,24 +905,40 @@ private static final class MethodHandlers implements public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) { switch (methodId) { case METHODID_CREATE_READ_SESSION: - serviceImpl.createReadSession((com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.createReadSession( + (com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest) request, + (io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession>) + responseObserver); break; case METHODID_READ_ROWS: - serviceImpl.readRows((com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.readRows( + (com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest) request, + (io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>) + responseObserver); break; case METHODID_BATCH_CREATE_READ_SESSION_STREAMS: - serviceImpl.batchCreateReadSessionStreams((com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest) request, - (io.grpc.stub.StreamObserver ) responseObserver); + serviceImpl.batchCreateReadSessionStreams( + (com.google.cloud.bigquery.storage.v1beta1.Storage + .BatchCreateReadSessionStreamsRequest) + request, + (io.grpc.stub.StreamObserver< + com.google.cloud.bigquery.storage.v1beta1.Storage + .BatchCreateReadSessionStreamsResponse>) + responseObserver); break; case METHODID_FINALIZE_STREAM: - serviceImpl.finalizeStream((com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest) request, + serviceImpl.finalizeStream( + (com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest) request, (io.grpc.stub.StreamObserver ) responseObserver); break; case METHODID_SPLIT_READ_STREAM: - serviceImpl.splitReadStream((com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest) request, - (io.grpc.stub.StreamObserver