fix: Sample should show sending multiple rows in one request

README.md

@@ -49,20 +49,20 @@ If you are using Maven without BOM, add this to your dependencies:
 If you are using Gradle 5.x or later, add this to your dependencies
 
 ```Groovy
-implementation platform('com.google.cloud:libraries-bom:23.0.0')
+implementation platform('com.google.cloud:libraries-bom:23.1.0')
 
 implementation 'com.google.cloud:google-cloud-bigquerystorage'
 ```
 If you are using Gradle without BOM, add this to your dependencies
 
 ```Groovy
-implementation 'com.google.cloud:google-cloud-bigquerystorage:2.3.1'
+implementation 'com.google.cloud:google-cloud-bigquerystorage:2.3.2'
 ```
 
 If you are using SBT, add this to your dependencies
 
 ```Scala
-libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.3.1"
+libraryDependencies += "com.google.cloud" % "google-cloud-bigquerystorage" % "2.3.2"
 ```
 
 ## Authentication

samples/snippets/src/main/java/com/example/bigquerystorage/WriteCommittedStream.java

@@ -64,17 +64,19 @@ public static void writeCommittedStream(String projectId, String datasetName, St
       try (JsonStreamWriter writer =
           JsonStreamWriter.newBuilder(writeStream.getName(), writeStream.getTableSchema())
               .build()) {
-        // Append 10 JSON objects to the stream.
-        for (int i = 0; i < 10; i++) {
+        // Write two batches to the stream, each with 10 JSON records.
+        for (int i = 0; i < 2; i++) {
           // Create a JSON object that is compatible with the table schema.
-          JSONObject record = new JSONObject();
-          record.put("col1", String.format("record %03d", i));
           JSONArray jsonArr = new JSONArray();
-          jsonArr.put(record);
+          for (int j = 0; j < 10; j++) {
+            JSONObject record = new JSONObject();
+            record.put("col1", String.format("record %03d-%03d", i, j));
+            jsonArr.put(record);
+          }
 
           // To detect duplicate records, pass the index as the record offset.
           // To disable deduplication, omit the offset or use WriteStream.Type.DEFAULT.
-          ApiFuture<AppendRowsResponse> future = writer.append(jsonArr, /*offset=*/ i);
+          ApiFuture<AppendRowsResponse> future = writer.append(jsonArr, /*offset=*/ i * 10);
           AppendRowsResponse response = future.get();
         }
       }

samples/snippets/src/main/java/com/example/bigquerystorage/WritePendingStream.java

@@ -67,14 +67,15 @@ public static void writePendingStream(String projectId, String datasetName, Stri
       try (JsonStreamWriter writer =
           JsonStreamWriter.newBuilder(writeStream.getName(), writeStream.getTableSchema())
               .build()) {
-        // Append 10 JSON objects to the stream.
-        for (int i = 0; i < 10; i++) {
+        // Write two batches to the stream, each with 10 JSON records.
+        for (int i = 0; i < 2; i++) {
           // Create a JSON object that is compatible with the table schema.
-          JSONObject record = new JSONObject();
-          record.put("col1", String.format("batch-record %03d", i));
           JSONArray jsonArr = new JSONArray();
-          jsonArr.put(record);
-
+          for (int j = 0; j < 10; j++) {
+            JSONObject record = new JSONObject();
+            record.put("col1", String.format("batch-record %03d-%03d", i, j));
+            jsonArr.put(record);
+          }
           ApiFuture<AppendRowsResponse> future = writer.append(jsonArr);
           AppendRowsResponse response = future.get();
         }

samples/snippets/src/main/java/com/example/bigquerystorage/WriteToDefaultStream.java

@@ -56,14 +56,15 @@ public static void writeToDefaultStream(String projectId, String datasetName, St
     // https://googleapis.dev/java/google-cloud-bigquerystorage/latest/com/google/cloud/bigquery/storage/v1beta2/JsonStreamWriter.html
     try (JsonStreamWriter writer =
         JsonStreamWriter.newBuilder(parentTable.toString(), tableSchema).build()) {
-      // Append 10 JSON objects to the stream.
-      for (int i = 0; i < 10; i++) {
+      // Write two batches to the stream, each with 10 JSON records.
+      for (int i = 0; i < 2; i++) {
         // Create a JSON object that is compatible with the table schema.
-        JSONObject record = new JSONObject();
-        record.put("test_string", String.format("record %03d", i));
         JSONArray jsonArr = new JSONArray();
-        jsonArr.put(record);
-
+        for (int j = 0; j < 10; j++) {
+          JSONObject record = new JSONObject();
+          record.put("test_string", String.format("record %03d-%03d", i, j));
+          jsonArr.put(record);
+        }
         ApiFuture<AppendRowsResponse> future = writer.append(jsonArr);
         AppendRowsResponse response = future.get();
       }