diff --git a/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
index ed0e08871f..7dfff71a93 100644
--- a/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
@@ -53,8 +53,12 @@
*
* BaseBigQueryReadSettings.Builder baseBigQueryReadSettingsBuilder =
* BaseBigQueryReadSettings.newBuilder();
- * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
- * .setTotalTimeout(Duration.ofSeconds(30));
+ * baseBigQueryReadSettingsBuilder
+ * .createReadSessionSettings()
+ * .setRetrySettings(
+ * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
* BaseBigQueryReadSettings baseBigQueryReadSettings = baseBigQueryReadSettingsBuilder.build();
*
*
diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java
index 3040cae377..aea64050a2 100644
--- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java
+++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java
@@ -68,8 +68,12 @@
*
* BigQueryReadStubSettings.Builder baseBigQueryReadSettingsBuilder =
* BigQueryReadStubSettings.newBuilder();
- * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
- * .setTotalTimeout(Duration.ofSeconds(30));
+ * baseBigQueryReadSettingsBuilder
+ * .createReadSessionSettings()
+ * .setRetrySettings(
+ * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
* BigQueryReadStubSettings baseBigQueryReadSettings = baseBigQueryReadSettingsBuilder.build();
*
*
diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteSettings.java
index a4153630eb..d7e3ff0522 100644
--- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteSettings.java
+++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteSettings.java
@@ -62,8 +62,12 @@
*
* BigQueryWriteSettings.Builder bigQueryWriteSettingsBuilder =
* BigQueryWriteSettings.newBuilder();
- * bigQueryWriteSettingsBuilder.createWriteStreamSettings().getRetrySettings().toBuilder()
- * .setTotalTimeout(Duration.ofSeconds(30));
+ * bigQueryWriteSettingsBuilder
+ * .createWriteStreamSettings()
+ * .setRetrySettings(
+ * bigQueryWriteSettingsBuilder.createWriteStreamSettings().getRetrySettings().toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
* BigQueryWriteSettings bigQueryWriteSettings = bigQueryWriteSettingsBuilder.build();
*
*
diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/stub/BigQueryWriteStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/stub/BigQueryWriteStubSettings.java
index 82c6335731..7dba9c85fa 100644
--- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/stub/BigQueryWriteStubSettings.java
+++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/stub/BigQueryWriteStubSettings.java
@@ -71,8 +71,12 @@
*
* BigQueryWriteStubSettings.Builder bigQueryWriteSettingsBuilder =
* BigQueryWriteStubSettings.newBuilder();
- * bigQueryWriteSettingsBuilder.createWriteStreamSettings().getRetrySettings().toBuilder()
- * .setTotalTimeout(Duration.ofSeconds(30));
+ * bigQueryWriteSettingsBuilder
+ * .createWriteStreamSettings()
+ * .setRetrySettings(
+ * bigQueryWriteSettingsBuilder.createWriteStreamSettings().getRetrySettings().toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
* BigQueryWriteStubSettings bigQueryWriteSettings = bigQueryWriteSettingsBuilder.build();
*
*
diff --git a/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
index 882092d9a0..a1bb6b456e 100644
--- a/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
@@ -63,8 +63,12 @@
*
* BaseBigQueryStorageSettings.Builder baseBigQueryStorageSettingsBuilder =
* BaseBigQueryStorageSettings.newBuilder();
- * baseBigQueryStorageSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
- * .setTotalTimeout(Duration.ofSeconds(30));
+ * baseBigQueryStorageSettingsBuilder
+ * .createReadSessionSettings()
+ * .setRetrySettings(
+ * baseBigQueryStorageSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
* BaseBigQueryStorageSettings baseBigQueryStorageSettings = baseBigQueryStorageSettingsBuilder.build();
*
*
diff --git a/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
index 0b19a7c0cf..3ce39e32fe 100644
--- a/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
@@ -72,8 +72,12 @@
*
* BigQueryStorageStubSettings.Builder baseBigQueryStorageSettingsBuilder =
* BigQueryStorageStubSettings.newBuilder();
- * baseBigQueryStorageSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
- * .setTotalTimeout(Duration.ofSeconds(30));
+ * baseBigQueryStorageSettingsBuilder
+ * .createReadSessionSettings()
+ * .setRetrySettings(
+ * baseBigQueryStorageSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
* BigQueryStorageStubSettings baseBigQueryStorageSettings = baseBigQueryStorageSettingsBuilder.build();
*
*
diff --git a/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
index 8276d74000..6570a55fc8 100644
--- a/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
@@ -53,8 +53,12 @@
*
* BaseBigQueryReadSettings.Builder baseBigQueryReadSettingsBuilder =
* BaseBigQueryReadSettings.newBuilder();
- * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
- * .setTotalTimeout(Duration.ofSeconds(30));
+ * baseBigQueryReadSettingsBuilder
+ * .createReadSessionSettings()
+ * .setRetrySettings(
+ * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
* BaseBigQueryReadSettings baseBigQueryReadSettings = baseBigQueryReadSettingsBuilder.build();
*
*
diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStubSettings.java
index 77c5f0e133..4d51ccb6d7 100644
--- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStubSettings.java
+++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1beta2/stub/BigQueryReadStubSettings.java
@@ -68,8 +68,12 @@
*
* BigQueryReadStubSettings.Builder baseBigQueryReadSettingsBuilder =
* BigQueryReadStubSettings.newBuilder();
- * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
- * .setTotalTimeout(Duration.ofSeconds(30));
+ * baseBigQueryReadSettingsBuilder
+ * .createReadSessionSettings()
+ * .setRetrySettings(
+ * baseBigQueryReadSettingsBuilder.createReadSessionSettings().getRetrySettings().toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
* BigQueryReadStubSettings baseBigQueryReadSettings = baseBigQueryReadSettingsBuilder.build();
*
*
diff --git a/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
index 71160a8ae1..9d26c04ab2 100644
--- a/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
@@ -163,4 +163,41 @@ public void readRowsExceptionTest() throws Exception {
Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
}
}
+
+ @Test
+ @SuppressWarnings("all")
+ public void splitReadStreamTest() {
+ SplitReadStreamResponse expectedResponse = SplitReadStreamResponse.newBuilder().build();
+ mockBigQueryRead.addResponse(expectedResponse);
+
+ SplitReadStreamRequest request = SplitReadStreamRequest.newBuilder().build();
+
+ SplitReadStreamResponse actualResponse = client.splitReadStream(request);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigQueryRead.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ SplitReadStreamRequest actualRequest = (SplitReadStreamRequest) actualRequests.get(0);
+
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void splitReadStreamExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockBigQueryRead.addException(exception);
+
+ try {
+ SplitReadStreamRequest request = SplitReadStreamRequest.newBuilder().build();
+
+ client.splitReadStream(request);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
}
diff --git a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClientTest.java b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClientTest.java
index 1709d4642a..661d422e74 100644
--- a/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClientTest.java
+++ b/google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClientTest.java
@@ -16,16 +16,26 @@
package com.google.cloud.bigquery.storage.v1alpha2;
import com.google.api.gax.core.NoCredentialsProvider;
+import com.google.api.gax.grpc.GaxGrpcProperties;
import com.google.api.gax.grpc.testing.LocalChannelProvider;
import com.google.api.gax.grpc.testing.MockGrpcService;
import com.google.api.gax.grpc.testing.MockServiceHelper;
import com.google.api.gax.grpc.testing.MockStreamObserver;
+import com.google.api.gax.rpc.ApiClientHeaderProvider;
import com.google.api.gax.rpc.ApiStreamObserver;
import com.google.api.gax.rpc.BidiStreamingCallable;
import com.google.api.gax.rpc.InvalidArgumentException;
import com.google.api.gax.rpc.StatusCode;
import com.google.cloud.bigquery.storage.v1alpha2.Storage.AppendRowsRequest;
import com.google.cloud.bigquery.storage.v1alpha2.Storage.AppendRowsResponse;
+import com.google.cloud.bigquery.storage.v1alpha2.Storage.BatchCommitWriteStreamsRequest;
+import com.google.cloud.bigquery.storage.v1alpha2.Storage.BatchCommitWriteStreamsResponse;
+import com.google.cloud.bigquery.storage.v1alpha2.Storage.CreateWriteStreamRequest;
+import com.google.cloud.bigquery.storage.v1alpha2.Storage.FinalizeWriteStreamRequest;
+import com.google.cloud.bigquery.storage.v1alpha2.Storage.FinalizeWriteStreamResponse;
+import com.google.cloud.bigquery.storage.v1alpha2.Storage.GetWriteStreamRequest;
+import com.google.cloud.bigquery.storage.v1alpha2.Stream.WriteStream;
+import com.google.protobuf.AbstractMessage;
import io.grpc.Status;
import io.grpc.StatusRuntimeException;
import java.io.IOException;
@@ -78,6 +88,46 @@ public void tearDown() throws Exception {
client.close();
}
+ @Test
+ @SuppressWarnings("all")
+ public void createWriteStreamTest() {
+ String name = "name3373707";
+ String externalId = "externalId-1153075697";
+ WriteStream expectedResponse =
+ WriteStream.newBuilder().setName(name).setExternalId(externalId).build();
+ mockBigQueryWrite.addResponse(expectedResponse);
+
+ CreateWriteStreamRequest request = CreateWriteStreamRequest.newBuilder().build();
+
+ WriteStream actualResponse = client.createWriteStream(request);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigQueryWrite.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ CreateWriteStreamRequest actualRequest = (CreateWriteStreamRequest) actualRequests.get(0);
+
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void createWriteStreamExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockBigQueryWrite.addException(exception);
+
+ try {
+ CreateWriteStreamRequest request = CreateWriteStreamRequest.newBuilder().build();
+
+ client.createWriteStream(request);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
+
@Test
@SuppressWarnings("all")
public void appendRowsTest() throws Exception {
@@ -126,4 +176,122 @@ public void appendRowsExceptionTest() throws Exception {
Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
}
}
+
+ @Test
+ @SuppressWarnings("all")
+ public void getWriteStreamTest() {
+ String name = "name3373707";
+ String externalId = "externalId-1153075697";
+ WriteStream expectedResponse =
+ WriteStream.newBuilder().setName(name).setExternalId(externalId).build();
+ mockBigQueryWrite.addResponse(expectedResponse);
+
+ GetWriteStreamRequest request = GetWriteStreamRequest.newBuilder().build();
+
+ WriteStream actualResponse = client.getWriteStream(request);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigQueryWrite.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ GetWriteStreamRequest actualRequest = (GetWriteStreamRequest) actualRequests.get(0);
+
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void getWriteStreamExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockBigQueryWrite.addException(exception);
+
+ try {
+ GetWriteStreamRequest request = GetWriteStreamRequest.newBuilder().build();
+
+ client.getWriteStream(request);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void finalizeWriteStreamTest() {
+ long rowCount = 1340416618L;
+ FinalizeWriteStreamResponse expectedResponse =
+ FinalizeWriteStreamResponse.newBuilder().setRowCount(rowCount).build();
+ mockBigQueryWrite.addResponse(expectedResponse);
+
+ FinalizeWriteStreamRequest request = FinalizeWriteStreamRequest.newBuilder().build();
+
+ FinalizeWriteStreamResponse actualResponse = client.finalizeWriteStream(request);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigQueryWrite.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ FinalizeWriteStreamRequest actualRequest = (FinalizeWriteStreamRequest) actualRequests.get(0);
+
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void finalizeWriteStreamExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockBigQueryWrite.addException(exception);
+
+ try {
+ FinalizeWriteStreamRequest request = FinalizeWriteStreamRequest.newBuilder().build();
+
+ client.finalizeWriteStream(request);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void batchCommitWriteStreamsTest() {
+ BatchCommitWriteStreamsResponse expectedResponse =
+ BatchCommitWriteStreamsResponse.newBuilder().build();
+ mockBigQueryWrite.addResponse(expectedResponse);
+
+ BatchCommitWriteStreamsRequest request = BatchCommitWriteStreamsRequest.newBuilder().build();
+
+ BatchCommitWriteStreamsResponse actualResponse = client.batchCommitWriteStreams(request);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigQueryWrite.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ BatchCommitWriteStreamsRequest actualRequest =
+ (BatchCommitWriteStreamsRequest) actualRequests.get(0);
+
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void batchCommitWriteStreamsExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockBigQueryWrite.addException(exception);
+
+ try {
+ BatchCommitWriteStreamsRequest request = BatchCommitWriteStreamsRequest.newBuilder().build();
+
+ client.batchCommitWriteStreams(request);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
}
diff --git a/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
index cd7261d48b..1b9363462f 100644
--- a/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
@@ -163,4 +163,41 @@ public void readRowsExceptionTest() throws Exception {
Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
}
}
+
+ @Test
+ @SuppressWarnings("all")
+ public void splitReadStreamTest() {
+ SplitReadStreamResponse expectedResponse = SplitReadStreamResponse.newBuilder().build();
+ mockBigQueryRead.addResponse(expectedResponse);
+
+ SplitReadStreamRequest request = SplitReadStreamRequest.newBuilder().build();
+
+ SplitReadStreamResponse actualResponse = client.splitReadStream(request);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockBigQueryRead.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ SplitReadStreamRequest actualRequest = (SplitReadStreamRequest) actualRequests.get(0);
+
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void splitReadStreamExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockBigQueryRead.addException(exception);
+
+ try {
+ SplitReadStreamRequest request = SplitReadStreamRequest.newBuilder().build();
+
+ client.splitReadStream(request);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
}
diff --git a/synth.metadata b/synth.metadata
index d68616923f..51bf6d5e26 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -1,43 +1,44 @@
{
- "updateTime": "2020-02-06T19:14:00.130766Z",
+ "updateTime": "2020-02-08T09:41:28.852134Z",
"sources": [
{
"generator": {
"name": "artman",
- "version": "0.44.4",
- "dockerImage": "googleapis/artman@sha256:19e945954fc960a4bdfee6cb34695898ab21a8cf0bac063ee39b91f00a1faec8"
+ "version": "0.45.0",
+ "dockerImage": "googleapis/artman@sha256:6aec9c34db0e4be221cdaf6faba27bdc07cfea846808b3d3b964dfce3a9a0f9b"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "4cdfe8278cb6f308106580d70648001c9146e759",
- "internalRef": "293614782"
+ "sha": "e7d8a694f4559201e6913f6610069cb08b39274e",
+ "internalRef": "293903652"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "4cdfe8278cb6f308106580d70648001c9146e759",
- "internalRef": "293614782"
+ "sha": "e7d8a694f4559201e6913f6610069cb08b39274e",
+ "internalRef": "293903652"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "4cdfe8278cb6f308106580d70648001c9146e759",
- "internalRef": "293614782"
+ "sha": "e7d8a694f4559201e6913f6610069cb08b39274e",
+ "internalRef": "293903652"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "4cdfe8278cb6f308106580d70648001c9146e759",
- "internalRef": "293614782"
+ "sha": "e7d8a694f4559201e6913f6610069cb08b39274e",
+ "internalRef": "293903652",
+ "log": "e7d8a694f4559201e6913f6610069cb08b39274e\nDepend on the latest gapic-generator and resource names plugin.\n\nThis fixes the very old an very annoying bug: https://github.com/googleapis/gapic-generator/pull/3087\n\nPiperOrigin-RevId: 293903652\n\n806b2854a966d55374ee26bb0cef4e30eda17b58\nfix: correct capitalization of Ruby namespaces in SecurityCenter V1p1beta1\n\nPiperOrigin-RevId: 293903613\n\n1b83c92462b14d67a7644e2980f723112472e03a\nPublish annotations and grpc service config for Logging API.\n\nPiperOrigin-RevId: 293893514\n\ne46f761cd6ec15a9e3d5ed4ff321a4bcba8e8585\nGenerate the Bazel build file for recommendengine public api\n\nPiperOrigin-RevId: 293710856\n\n68477017c4173c98addac0373950c6aa9d7b375f\nMake `language_code` optional for UpdateIntentRequest and BatchUpdateIntentsRequest.\n\nThe comments and proto annotations describe this parameter as optional.\n\nPiperOrigin-RevId: 293703548\n\n16f823f578bca4e845a19b88bb9bc5870ea71ab2\nAdd BUILD.bazel files for managedidentities API\n\nPiperOrigin-RevId: 293698246\n\n2f53fd8178c9a9de4ad10fae8dd17a7ba36133f2\nAdd v1p1beta1 config file\n\nPiperOrigin-RevId: 293696729\n\n052b274138fce2be80f97b6dcb83ab343c7c8812\nAdd source field for user event and add field behavior annotations\n\nPiperOrigin-RevId: 293693115\n\n1e89732b2d69151b1b3418fff3d4cc0434f0dded\ndatacatalog: v1beta1 add three new RPCs to gapic v1beta1 config\n\nPiperOrigin-RevId: 293692823\n\n9c8bd09bbdc7c4160a44f1fbab279b73cd7a2337\nchange the name of AccessApproval service to AccessApprovalAdmin\n\nPiperOrigin-RevId: 293690934\n\n2e23b8fbc45f5d9e200572ca662fe1271bcd6760\nAdd ListEntryGroups method, add http bindings to support entry group tagging, and update some comments.\n\nPiperOrigin-RevId: 293666452\n\n0275e38a4ca03a13d3f47a9613aac8c8b0d3f1f2\nAdd proto_package field to managedidentities API. It is needed for APIs that still depend on artman generation.\n\nPiperOrigin-RevId: 293643323\n\n"
}
},
{