diff --git a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteCommittedStream.java b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteCommittedStream.java index 0ecd78f22e..1fc6b0f45b 100644 --- a/samples/snippets/src/main/java/com/example/bigquerystorage/WriteCommittedStream.java +++ b/samples/snippets/src/main/java/com/example/bigquerystorage/WriteCommittedStream.java @@ -69,7 +69,7 @@ public static void writeCommittedStream(String projectId, String datasetName, St JSONArray jsonArr = new JSONArray(); jsonArr.put(record); - ApiFuture future = writer.append(jsonArr, i, false); + ApiFuture future = writer.append(jsonArr, i); AppendRowsResponse response = future.get(); } @@ -106,7 +106,7 @@ public static void writeToDefaultStream(String projectId, String datasetName, St JSONArray jsonArr = new JSONArray(); jsonArr.put(record); - ApiFuture future = writer.append(jsonArr, false); + ApiFuture future = writer.append(jsonArr); AppendRowsResponse response = future.get(); } } catch (Exception e) { diff --git a/samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java b/samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java index 5d357a3e2c..5cc504962a 100644 --- a/samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java +++ b/samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java @@ -57,7 +57,7 @@ public static void writePendingStream(String projectId, String datasetName, Stri JSONArray jsonArr = new JSONArray(); jsonArr.put(record); - ApiFuture future = writer.append(jsonArr, false); + ApiFuture future = writer.append(jsonArr); AppendRowsResponse response = future.get(); } FinalizeWriteStreamResponse finalizeResponse =