Fix lint errors

Author: ShuranZhang

samples/snippets/src/main/java/com/example/spanner/ChangeStreamsTxnExclusionSample.java

@@ -16,24 +16,26 @@
 
 package com.example.spanner;
 
+import com.google.api.gax.rpc.ServerStream;
 import com.google.cloud.spanner.CommitResponse;
 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.cloud.spanner.Statement;
 import com.google.cloud.spanner.TransactionContext;
 import com.google.cloud.spanner.TransactionManager;
-import java.util.Collections;
-import com.google.spanner.v1.BatchWriteResponse;
-import com.google.api.gax.rpc.ServerStream;
-import com.google.rpc.Code;
-import com.google.cloud.spanner.MutationGroup;
 import com.google.common.collect.ImmutableList;
+import com.google.rpc.Code;
+import com.google.spanner.v1.BatchWriteResponse;
+import java.util.Collections;
 
-/** Sample showing how to set exclude transaction from change streams in different write requests. */
+/**
+ * Sample showing how to set exclude transaction from change streams in different write requests.
+ */
 public class ChangeStreamsTxnExclusionSample {
 
   static void setExcludeTxnFromChangeStreams() {
@@ -107,15 +109,16 @@ static void writeAtLeastOnceExcludedFromChangeStreams(DatabaseClient client) {
   static void batchWriteAtLeastOnceExcludedFromChangeStreams(DatabaseClient client) {
     ServerStream<BatchWriteResponse> responses =
         client.batchWriteAtLeastOnce(
-            ImmutableList.of(MutationGroup.of(
-                Mutation.newInsertOrUpdateBuilder("Singers")
-                    .set("SingerId")
-                    .to(116)
-                    .set("FirstName")
-                    .to("Scarlet")
-                    .set("LastName")
-                    .to("Terry")
-                    .build())),
+            ImmutableList.of(
+                MutationGroup.of(
+                    Mutation.newInsertOrUpdateBuilder("Singers")
+                        .set("SingerId")
+                        .to(116)
+                        .set("FirstName")
+                        .to("Scarlet")
+                        .set("LastName")
+                        .to("Terry")
+                        .build())),
             Options.excludeTxnFromChangeStreams());
     for (BatchWriteResponse response : responses) {
       if (response.getStatus().getCode() == Code.OK_VALUE) {
@@ -124,9 +127,10 @@ static void batchWriteAtLeastOnceExcludedFromChangeStreams(DatabaseClient client
             response.getIndexesList(), response.getCommitTimestamp());
       } else {
         System.out.printf(
-            "Mutation group could not be applied with error code %s and "
-                + "error message %s", response.getIndexesList(),
-            Code.forNumber(response.getStatus().getCode()), response.getStatus().getMessage());
+            "Mutation group could not be applied with error code %s and " + "error message %s",
+            response.getIndexesList(),
+            Code.forNumber(response.getStatus().getCode()),
+            response.getStatus().getMessage());
       }
     }
   }
@@ -138,7 +142,8 @@ static void pdmlExcludedFromChangeStreams(DatabaseClient client) {
   }
 
   static void txnManagerExcludedFromChangeStreams(DatabaseClient client) {
-    try (TransactionManager manager = client.transactionManager(Options.excludeTxnFromChangeStreams())) {
+    try (TransactionManager manager =
+        client.transactionManager(Options.excludeTxnFromChangeStreams())) {
       TransactionContext transaction = manager.begin();
       transaction.buffer(
           Mutation.newInsertOrUpdateBuilder("Singers")

samples/snippets/src/test/java/com/example/spanner/ChangeStreamsTxnExclusionSampleIT.java

@@ -33,9 +33,7 @@
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
 
-/**
- * Integration tests for {@link ChangeStreamsTxnExclusionSample}
- */
+/** Integration tests for {@link ChangeStreamsTxnExclusionSample} */
 @RunWith(JUnit4.class)
 public class ChangeStreamsTxnExclusionSampleIT extends SampleTestBase {
 
@@ -62,24 +60,24 @@ public static void createTestDatabase() throws Exception {
   @Before
   public void insertTestData() {
     final DatabaseClient client = spanner.getDatabaseClient(databaseId);
-    client.write(Arrays.asList(
-        Mutation.newInsertBuilder("Singers")
-            .set("SingerId")
-            .to(1L)
-            .set("FirstName")
-            .to("first name 1")
-            .set("LastName")
-            .to("last name 1")
-            .build(),
-        Mutation.newInsertBuilder("Singers")
-            .set("SingerId")
-            .to(2L)
-            .set("FirstName")
-            .to("first name 2")
-            .set("LastName")
-            .to("last name 2")
-            .build()
-    ));
+    client.write(
+        Arrays.asList(
+            Mutation.newInsertBuilder("Singers")
+                .set("SingerId")
+                .to(1L)
+                .set("FirstName")
+                .to("first name 1")
+                .set("LastName")
+                .to("last name 1")
+                .build(),
+            Mutation.newInsertBuilder("Singers")
+                .set("SingerId")
+                .to(2L)
+                .set("FirstName")
+                .to("first name 2")
+                .set("LastName")
+                .to("last name 2")
+                .build()));
   }
 
   @After
@@ -91,23 +89,33 @@ public void removeTestData() {
   @Test
   public void testSetExcludeTxnFromChangeStreamsSampleSample() throws Exception {
     final DatabaseClient client = spanner.getDatabaseClient(databaseId);
-    String out = runSample(() -> ChangeStreamsTxnExclusionSample.rwTxnExcludedFromChangeStreams(client));
+    String out =
+        runSample(() -> ChangeStreamsTxnExclusionSample.rwTxnExcludedFromChangeStreams(client));
     assertThat(out).contains("New singer inserted.");
     assertThat(out).contains("Singer first name updated.");
 
     out = runSample(() -> ChangeStreamsTxnExclusionSample.writeExcludedFromChangeStreams(client));
     assertThat(out).contains("New singer inserted.");
 
-    out = runSample(() -> ChangeStreamsTxnExclusionSample.writeAtLeastOnceExcludedFromChangeStreams(client));
+    out =
+        runSample(
+            () ->
+                ChangeStreamsTxnExclusionSample.writeAtLeastOnceExcludedFromChangeStreams(client));
     assertThat(out).contains("New singer inserted.");
 
-    out = runSample(() -> ChangeStreamsTxnExclusionSample.batchWriteAtLeastOnceExcludedFromChangeStreams(client));
+    out =
+        runSample(
+            () ->
+                ChangeStreamsTxnExclusionSample.batchWriteAtLeastOnceExcludedFromChangeStreams(
+                    client));
     assertThat(out).contains("have been applied");
 
     out = runSample(() -> ChangeStreamsTxnExclusionSample.pdmlExcludedFromChangeStreams(client));
     assertThat(out).contains("Singers deleted.");
 
-    out = runSample(() -> ChangeStreamsTxnExclusionSample.txnManagerExcludedFromChangeStreams(client));
+    out =
+        runSample(
+            () -> ChangeStreamsTxnExclusionSample.txnManagerExcludedFromChangeStreams(client));
     assertThat(out).contains("New singer inserted.");
   }
 }