From 73146f87bd781dd2aba0c8b45e8e4b4d32183a01 Mon Sep 17 00:00:00 2001
From: Yiru Tang <yiru@google.com>
Date: Thu, 21 Sep 2023 22:16:41 +0000
Subject: [PATCH 1/2] feat: add sample code about default
 missingValueInterpretation

---
 .../com/example/bigquerystorage/WriteToDefaultStream.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
index 9b831e45df..94abcb82b4 100644
--- a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
+++ b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
@@ -178,6 +178,10 @@ public void initialize(TableName parentTable)
                       .setChannelsPerCpu(2)
                       .build())
               .setEnableConnectionPool(true)
+              // If value is missing in json and there is a default value configured on bigquery
+              // column, apply the default value to the missing value field.
+              .setDefaultMissingValueInterpretation(
+                  AppendRowsRequest.MissingValueInterpretation.DEFAULT_VALUE)
               .build();
     }
 

From d4ebf72322b71a1d2b138d2520dcb57db282b6bd Mon Sep 17 00:00:00 2001
From: Yiru Tang <yiru@google.com>
Date: Fri, 22 Sep 2023 20:14:08 +0000
Subject: [PATCH 2/2] .

---
 .../java/com/example/bigquerystorage/WriteToDefaultStream.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
index 94abcb82b4..feccef61f0 100644
--- a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
+++ b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java
@@ -26,6 +26,7 @@
 import com.google.cloud.bigquery.BigQueryOptions;
 import com.google.cloud.bigquery.QueryJobConfiguration;
 import com.google.cloud.bigquery.TableResult;
+import com.google.cloud.bigquery.storage.v1.AppendRowsRequest;
 import com.google.cloud.bigquery.storage.v1.AppendRowsResponse;
 import com.google.cloud.bigquery.storage.v1.BigQueryWriteClient;
 import com.google.cloud.bigquery.storage.v1.BigQueryWriteSettings;