Skip to content

Commit 0def62f

Browse files
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: https://github.com/googleapis/googleapis-gen/commit/1532dc6fd5b52a53613304e75aac1b5da407b6b3 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>
1 parent 9be165d commit 0def62f

File tree

6 files changed

+1429
-113
lines changed

6 files changed

+1429
-113
lines changed

google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClient.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -342,6 +342,8 @@ public final UnaryCallable<CreateWriteStreamRequest, WriteStream> createWriteStr
342342
* WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
343343
* .setOffset(Int64Value.newBuilder().build())
344344
* .setTraceId("traceId-1067401920")
345+
* .putAllMissingValueInterpretations(
346+
* new HashMap<String, AppendRowsRequest.MissingValueInterpretation>())
345347
* .build();
346348
* bidiStream.send(request);
347349
* for (AppendRowsResponse response : bidiStream) {

google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1/BigQueryWriteClientTest.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@
3434
import java.io.IOException;
3535
import java.util.ArrayList;
3636
import java.util.Arrays;
37+
import java.util.HashMap;
3738
import java.util.List;
3839
import java.util.UUID;
3940
import java.util.concurrent.ExecutionException;
@@ -188,6 +189,8 @@ public void appendRowsTest() throws Exception {
188189
WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
189190
.setOffset(Int64Value.newBuilder().build())
190191
.setTraceId("traceId-1067401920")
192+
.putAllMissingValueInterpretations(
193+
new HashMap<String, AppendRowsRequest.MissingValueInterpretation>())
191194
.build();
192195

193196
MockStreamObserver<AppendRowsResponse> responseObserver = new MockStreamObserver<>();
@@ -215,6 +218,8 @@ public void appendRowsExceptionTest() throws Exception {
215218
WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
216219
.setOffset(Int64Value.newBuilder().build())
217220
.setTraceId("traceId-1067401920")
221+
.putAllMissingValueInterpretations(
222+
new HashMap<String, AppendRowsRequest.MissingValueInterpretation>())
218223
.build();
219224

220225
MockStreamObserver<AppendRowsResponse> responseObserver = new MockStreamObserver<>();

0 commit comments

Comments
 (0)