diff --git a/README.md b/README.md
index 1fc91bd392b..169541eff05 100644
--- a/README.md
+++ b/README.md
@@ -270,6 +270,7 @@ Samples are in the [`samples/`](https://github.com/googleapis/java-spanner/tree/
| Async Runner Example | [source code](https://github.com/googleapis/java-spanner/blob/main/samples/snippets/src/main/java/com/example/spanner/AsyncRunnerExample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-spanner&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/spanner/AsyncRunnerExample.java) |
| Async Transaction Manager Example | [source code](https://github.com/googleapis/java-spanner/blob/main/samples/snippets/src/main/java/com/example/spanner/AsyncTransactionManagerExample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-spanner&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/spanner/AsyncTransactionManagerExample.java) |
| Batch Sample | [source code](https://github.com/googleapis/java-spanner/blob/main/samples/snippets/src/main/java/com/example/spanner/BatchSample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-spanner&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/spanner/BatchSample.java) |
+| Batch Write At Least Once Sample | [source code](https://github.com/googleapis/java-spanner/blob/main/samples/snippets/src/main/java/com/example/spanner/BatchWriteAtLeastOnceSample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-spanner&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/spanner/BatchWriteAtLeastOnceSample.java) |
| Copy Backup Sample | [source code](https://github.com/googleapis/java-spanner/blob/main/samples/snippets/src/main/java/com/example/spanner/CopyBackupSample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-spanner&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/spanner/CopyBackupSample.java) |
| Create Backup With Encryption Key | [source code](https://github.com/googleapis/java-spanner/blob/main/samples/snippets/src/main/java/com/example/spanner/CreateBackupWithEncryptionKey.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-spanner&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/spanner/CreateBackupWithEncryptionKey.java) |
| Create Database With Default Leader Sample | [source code](https://github.com/googleapis/java-spanner/blob/main/samples/snippets/src/main/java/com/example/spanner/CreateDatabaseWithDefaultLeaderSample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-spanner&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/spanner/CreateDatabaseWithDefaultLeaderSample.java) |
diff --git a/samples/snippets/src/main/java/com/example/spanner/BatchWriteAtLeastOnceSample.java b/samples/snippets/src/main/java/com/example/spanner/BatchWriteAtLeastOnceSample.java
new file mode 100644
index 00000000000..bd59562eb28
--- /dev/null
+++ b/samples/snippets/src/main/java/com/example/spanner/BatchWriteAtLeastOnceSample.java
@@ -0,0 +1,135 @@
+/*
+ * Copyright 2023 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.spanner;
+
+// [START spanner_batch_write_at_least_once]
+
+import com.google.api.gax.rpc.ServerStream;
+import com.google.cloud.spanner.DatabaseClient;
+import com.google.cloud.spanner.DatabaseId;
+import com.google.cloud.spanner.Mutation;
+import com.google.cloud.spanner.MutationGroup;
+import com.google.cloud.spanner.Options;
+import com.google.cloud.spanner.Spanner;
+import com.google.cloud.spanner.SpannerOptions;
+import com.google.common.collect.ImmutableList;
+import com.google.rpc.Code;
+import com.google.spanner.v1.BatchWriteResponse;
+
+public class BatchWriteAtLeastOnceSample {
+
+ /***
+ * Assume DDL for the underlying database:
+ * {@code
+ * CREATE TABLE Singers (
+ * SingerId INT64 NOT NULL,
+ * FirstName STRING(1024),
+ * LastName STRING(1024),
+ * ) PRIMARY KEY (SingerId)
+ *
+ * CREATE TABLE Albums (
+ * SingerId INT64 NOT NULL,
+ * AlbumId INT64 NOT NULL,
+ * AlbumTitle STRING(1024),
+ * ) PRIMARY KEY (SingerId, AlbumId),
+ * INTERLEAVE IN PARENT Singers ON DELETE CASCADE
+ * }
+ */
+
+ private static final MutationGroup MUTATION_GROUP1 =
+ MutationGroup.of(
+ Mutation.newInsertOrUpdateBuilder("Singers")
+ .set("SingerId")
+ .to(16)
+ .set("FirstName")
+ .to("Scarlet")
+ .set("LastName")
+ .to("Terry")
+ .build());
+ private static final MutationGroup MUTATION_GROUP2 =
+ MutationGroup.of(
+ Mutation.newInsertOrUpdateBuilder("Singers")
+ .set("SingerId")
+ .to(17)
+ .set("FirstName")
+ .to("Marc")
+ .build(),
+ Mutation.newInsertOrUpdateBuilder("Singers")
+ .set("SingerId")
+ .to(18)
+ .set("FirstName")
+ .to("Catalina")
+ .set("LastName")
+ .to("Smith")
+ .build(),
+ Mutation.newInsertOrUpdateBuilder("Albums")
+ .set("SingerId")
+ .to(17)
+ .set("AlbumId")
+ .to(1)
+ .set("AlbumTitle")
+ .to("Total Junk")
+ .build(),
+ Mutation.newInsertOrUpdateBuilder("Albums")
+ .set("SingerId")
+ .to(18)
+ .set("AlbumId")
+ .to(2)
+ .set("AlbumTitle")
+ .to("Go, Go, Go")
+ .build());
+
+ static void batchWriteAtLeastOnce() {
+ // TODO(developer): Replace these variables before running the sample.
+ final String projectId = "my-project";
+ final String instanceId = "my-instance";
+ final String databaseId = "my-database";
+ batchWriteAtLeastOnce(projectId, instanceId, databaseId);
+ }
+
+ static void batchWriteAtLeastOnce(String projectId, String instanceId, String databaseId) {
+ try (Spanner spanner =
+ SpannerOptions.newBuilder().setProjectId(projectId).build().getService()) {
+ DatabaseId dbId = DatabaseId.of(projectId, instanceId, databaseId);
+ final DatabaseClient dbClient = spanner.getDatabaseClient(dbId);
+
+ // Creates and issues a BatchWrite RPC request that will apply the mutation groups
+ // non-atomically and respond back with a stream of BatchWriteResponse.
+ ServerStream responses =
+ dbClient.batchWriteAtLeastOnce(
+ ImmutableList.of(MUTATION_GROUP1, MUTATION_GROUP2),
+ Options.tag("batch-write-tag"));
+
+ // Iterates through the results in the stream response and prints the MutationGroup indexes,
+ // commit timestamp and status.
+ for (BatchWriteResponse response : responses) {
+ if (response.getStatus().getCode() == Code.OK_VALUE) {
+ System.out.printf(
+ "Mutation group indexes %s have been applied with commit timestamp %s",
+ response.getIndexesList(), response.getCommitTimestamp());
+ } else {
+ System.out.printf(
+ "Mutation group indexes %s could not be applied with error code %s and "
+ + "error message %s", response.getIndexesList(),
+ Code.forNumber(response.getStatus().getCode()), response.getStatus().getMessage());
+ }
+ }
+ }
+ }
+}
+
+// [END spanner_batch_write_at_least_once]
diff --git a/samples/snippets/src/test/java/com/example/spanner/BatchWriteAtLeastOnceSampleIT.java b/samples/snippets/src/test/java/com/example/spanner/BatchWriteAtLeastOnceSampleIT.java
new file mode 100644
index 00000000000..55f28cda41a
--- /dev/null
+++ b/samples/snippets/src/test/java/com/example/spanner/BatchWriteAtLeastOnceSampleIT.java
@@ -0,0 +1,60 @@
+/*
+ * Copyright 2023 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.spanner;
+
+import static org.junit.Assert.assertTrue;
+
+import com.google.cloud.spanner.DatabaseId;
+import com.google.common.collect.ImmutableList;
+import java.util.concurrent.ExecutionException;
+import org.junit.Before;
+import org.junit.Test;
+
+public class BatchWriteAtLeastOnceSampleIT extends SampleTestBase {
+ private static String databaseId;
+
+ @Before
+ public void setup() throws ExecutionException, InterruptedException {
+ databaseId = idGenerator.generateDatabaseId();
+ databaseAdminClient
+ .createDatabase(
+ databaseAdminClient
+ .newDatabaseBuilder(DatabaseId.of(projectId, instanceId, databaseId))
+ .build(),
+ ImmutableList.of(
+ "CREATE TABLE Singers ("
+ + " SingerId INT64 NOT NULL,"
+ + " FirstName STRING(1024),"
+ + " LastName STRING(1024)"
+ + ") PRIMARY KEY (SingerId)",
+ "CREATE TABLE Albums ("
+ + " SingerId INT64 NOT NULL,"
+ + " AlbumId INT64 NOT NULL,"
+ + " AlbumTitle STRING(1024)"
+ + ") PRIMARY KEY (SingerId, AlbumId),"
+ + " INTERLEAVE IN PARENT Singers ON DELETE CASCADE"))
+ .get();
+ }
+
+ @Test
+ public void testBatchWriteAtLeastOnce() throws Exception {
+ final String out =
+ SampleRunner.runSample(() -> BatchWriteAtLeastOnceSample.batchWriteAtLeastOnce(
+ projectId, instanceId, databaseId));
+ assertTrue(out.contains("have been applied with commit timestamp"));
+ }
+}