feat: add missing_value_interpretations to AppendRowsRequest (#1885)

* feat: add missing_value_interpretations to AppendRowsRequest PiperOrigin-RevId: 488693558 Source-Link: googleapis/googleapis@43bf96f Source-Link: googleapis/googleapis-gen@1532dc6 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMTUzMmRjNmZkNWI1MmE1MzYxMzMwNGU3NWFhYzFiNWRhNDA3YjZiMyJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
googleapis · Nov 16, 2022 · 0def62f · 0def62f
1 parent 9be165d
commit 0def62f
Show file tree

Hide file tree

Showing 6 changed files with 1,429 additions and 113 deletions.
diff --git a/...gquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClient.java b/...gquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClient.java
@@ -342,6 +342,8 @@ public final UnaryCallable<CreateWriteStreamRequest, WriteStream> createWriteStr
    *               WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
    *           .setOffset(Int64Value.newBuilder().build())
    *           .setTraceId("traceId-1067401920")
+   *           .putAllMissingValueInterpretations(
+   *               new HashMap<String, AppendRowsRequest.MissingValueInterpretation>())
    *           .build();
    *   bidiStream.send(request);
    *   for (AppendRowsResponse response : bidiStream) {

diff --git a/...rystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClientTest.java b/...rystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClientTest.java
@@ -34,6 +34,7 @@
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.HashMap;
 import java.util.List;
 import java.util.UUID;
 import java.util.concurrent.ExecutionException;
@@ -188,6 +189,8 @@ public void appendRowsTest() throws Exception {
                 WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
             .setOffset(Int64Value.newBuilder().build())
             .setTraceId("traceId-1067401920")
+            .putAllMissingValueInterpretations(
+                new HashMap<String, AppendRowsRequest.MissingValueInterpretation>())
             .build();
 
     MockStreamObserver<AppendRowsResponse> responseObserver = new MockStreamObserver<>();
@@ -215,6 +218,8 @@ public void appendRowsExceptionTest() throws Exception {
                 WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
             .setOffset(Int64Value.newBuilder().build())
             .setTraceId("traceId-1067401920")
+            .putAllMissingValueInterpretations(
+                new HashMap<String, AppendRowsRequest.MissingValueInterpretation>())
             .build();
 
     MockStreamObserver<AppendRowsResponse> responseObserver = new MockStreamObserver<>();