chore: run code formatter

Author: olavloite

src/main/java/com/google/cloud/spanner/jdbc/JdbcConnection.java

@@ -114,7 +114,8 @@ static boolean useLegacyValidCheck() {
   }
 
   @VisibleForTesting
-  static Attributes createOpenTelemetryAttributes(DatabaseId databaseId, boolean includeConnectionId) {
+  static Attributes createOpenTelemetryAttributes(
+      DatabaseId databaseId, boolean includeConnectionId) {
     AttributesBuilder attributesBuilder = Attributes.builder();
     // A unique connection ID should only be included for tracing and not for metrics.
     if (includeConnectionId) {

src/test/java/com/google/cloud/spanner/jdbc/it/ITOpenTelemetryTest.java

@@ -61,7 +61,6 @@
 import java.util.concurrent.Future;
 import java.util.concurrent.ThreadLocalRandom;
 import java.util.concurrent.TimeUnit;
-import java.util.function.Supplier;
 import org.junit.AfterClass;
 import org.junit.Before;
 import org.junit.BeforeClass;
@@ -146,8 +145,7 @@ public void testGlobalOpenTelemetry() throws Exception {
   }
 
   @Test
-  public void testOpenTelemetryInProperties()
-      throws Exception {
+  public void testOpenTelemetryInProperties() throws Exception {
     // Make sure there is no Global OpenTelemetry.
     GlobalOpenTelemetry.resetForTest();
     Properties info = new Properties();
@@ -225,30 +223,35 @@ private void testOpenTelemetry(Connection connection)
       assertUpdateResult(statement.executeLargeUpdate(), spannerSql);
     }
   }
-  
+
   private interface ConnectionProducer {
     Connection createConnection() throws SQLException;
   }
-  
-  private void testOpenTelemetryConcurrency(ConnectionProducer connectionProducer) throws Exception {
+
+  private void testOpenTelemetryConcurrency(ConnectionProducer connectionProducer)
+      throws Exception {
     int numThreads = 16;
     int numIterations = 1000;
     ExecutorService executor = Executors.newFixedThreadPool(16);
     List<Future<?>> futures = new ArrayList<>(numThreads);
-    for (int n=0; n<numThreads; n++) {
-      futures.add(executor.submit((Callable<Void>) () -> {
-        try (Connection connection = connectionProducer.createConnection(); Statement statement = connection.createStatement()) {
-          for (int i = 0; i < numIterations; i++) {
-            UUID uuid = UUID.randomUUID();
-            String sql = "select '" + uuid + "'";
-
-            try (ResultSet resultSet = statement.executeQuery(sql)) {
-              assertQueryResult(resultSet, sql, uuid, false);
-            }
-          }
-        }
-        return null;
-      }));
+    for (int n = 0; n < numThreads; n++) {
+      futures.add(
+          executor.submit(
+              (Callable<Void>)
+                  () -> {
+                    try (Connection connection = connectionProducer.createConnection();
+                        Statement statement = connection.createStatement()) {
+                      for (int i = 0; i < numIterations; i++) {
+                        UUID uuid = UUID.randomUUID();
+                        String sql = "select '" + uuid + "'";
+
+                        try (ResultSet resultSet = statement.executeQuery(sql)) {
+                          assertQueryResult(resultSet, sql, uuid, false);
+                        }
+                      }
+                    }
+                    return null;
+                  }));
     }
     executor.shutdown();
     assertTrue(executor.awaitTermination(600L, TimeUnit.SECONDS));