chore: apply fmt-maven-plugin

Author: igorbernstein2

java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/middleware/OpExecutor.java

@@ -73,8 +73,8 @@ public void execute(Runnable r) {
   }
 
   /**
-   * Runs {@code r} synchronously on the caller thread if this executor is idle, otherwise queues
-   * it for later drain on the backing executor. Either way, FIFO ordering with other tasks is
+   * Runs {@code r} synchronously on the caller thread if this executor is idle, otherwise queues it
+   * for later drain on the backing executor. Either way, FIFO ordering with other tasks is
    * preserved.
    */
   public void runInline(Runnable r) {
@@ -104,7 +104,8 @@ public void runInline(Runnable r) {
     }
   }
 
-  // Schedule a drain on the backing executor. If the backing throws (e.g. RejectedExecutionException
+  // Schedule a drain on the backing executor. If the backing throws (e.g.
+  // RejectedExecutionException
   // during shutdown), reset drainScheduled before propagating so the next execute() can retry
   // instead of wedging the executor with no drainer.
   @GuardedBy("queue")

java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/middleware/RetryingVRpc.java

@@ -122,7 +122,8 @@ public void cancel(@Nullable String message, @Nullable Throwable cause) {
   public void requestNext() {
     // Assert the op-executor affinity even though the body is dead today — when streaming lands
     // and this becomes real, the missing assertion would silently allow off-thread access.
-    // Guarded on context being set so a misuse before start() still throws UnsupportedOperationException
+    // Guarded on context being set so a misuse before start() still throws
+    // UnsupportedOperationException
     // rather than NPE on the assertion.
     if (context != null) {
       context.getExecutor().throwIfNotInThisExecutor();

java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/middleware/VOperationImpl.java

@@ -31,8 +31,8 @@
 
 /**
  * The single edge between the user and the VRpc middleware chain. Trampolines all inbound user
- * calls onto opExecutor and owns the gRPC {@link Context} cancellation listener so that every
- * layer below is single-threaded on opExecutor.
+ * calls onto opExecutor and owns the gRPC {@link Context} cancellation listener so that every layer
+ * below is single-threaded on opExecutor.
  *
  * <p>Precondition: {@link #cancel} must not be called before {@link #start}.
  */

java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionList.java

@@ -170,8 +170,8 @@ void onSessionStarted() {
     }
 
     /**
-     * The session is returned to the pool after a vRPC that reached the wire completes. Updates
-     * the picker's per-AFE latency stats on success; non-OK results skip the latency update so a
+     * The session is returned to the pool after a vRPC that reached the wire completes. Updates the
+     * picker's per-AFE latency stats on success; non-OK results skip the latency update so a
      * fast-failing or cancelled-mid-flight AFE doesn't look the fastest.
      */
     void onVRpcFinish(Duration elapsed, VRpcResult result) {
@@ -183,10 +183,9 @@ void onVRpcFinish(Duration elapsed, VRpcResult result) {
     }
 
     /**
-     * The session is returned to the pool after a pending vRPC was drained but cancelled before
-     * it could be attached to a real call (e.g. user cancelled or deadline expired between
-     * checkoutSession and drainTo). No latency is reported because the vRPC never reached the
-     * wire.
+     * The session is returned to the pool after a pending vRPC was drained but cancelled before it
+     * could be attached to a real call (e.g. user cancelled or deadline expired between
+     * checkoutSession and drainTo). No latency is reported because the vRPC never reached the wire.
      */
     void onPendingVRpcCancelled() {
       releaseToPool();

java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionPoolImpl.java

@@ -716,25 +716,29 @@ private void cancel(Status status, boolean onlyCancelPendingCall) {
       synchronized (SessionPoolImpl.this) {
         pendingRpcs.remove(this); // eager removal; no-op if already drained
       }
-      ctx.getExecutor().execute(() -> {
-        if (isCancelled) return;
-        isCancelled = true;
-        if (realCall != null) {
-          if (!onlyCancelPendingCall) {
-            realCall.cancel(status.getDescription(), status.getCause());
-          }
-        } else {
-          listener.onClose(VRpcResult.createRejectedError(status));
-        }
-      });
+      ctx.getExecutor()
+          .execute(
+              () -> {
+                if (isCancelled) return;
+                isCancelled = true;
+                if (realCall != null) {
+                  if (!onlyCancelPendingCall) {
+                    realCall.cancel(status.getDescription(), status.getCause());
+                  }
+                } else {
+                  listener.onClose(VRpcResult.createRejectedError(status));
+                }
+              });
     }
 
     void cancelWithResult(VRpcResult result) {
-      ctx.getExecutor().execute(() -> {
-        if (isCancelled) return;
-        isCancelled = true;
-        listener.onClose(result);
-      });
+      ctx.getExecutor()
+          .execute(
+              () -> {
+                if (isCancelled) return;
+                isCancelled = true;
+                listener.onClose(result);
+              });
     }
 
     @Override
@@ -750,14 +754,16 @@ private void drainTo(SessionHandle handle) {
       if (deadlineMonitor != null) {
         deadlineMonitor.cancel();
       }
-      ctx.getExecutor().execute(() -> {
-        if (isCancelled) {
-          SessionPoolImpl.this.onPendingVRpcCancelled(handle);
-          return;
-        }
-        realCall = newRealCall(desc, handle);
-        realCall.start(req, ctx, listener);
-      });
+      ctx.getExecutor()
+          .execute(
+              () -> {
+                if (isCancelled) {
+                  SessionPoolImpl.this.onPendingVRpcCancelled(handle);
+                  return;
+                }
+                realCall = newRealCall(desc, handle);
+                realCall.start(req, ctx, listener);
+              });
     }
 
     private VRpcListener<RespT> getListener() {
@@ -908,5 +914,4 @@ public void close() {
       }
     }
   }
-
 }

java-bigtable/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/internal/session/SessionImplTest.java

@@ -683,8 +683,7 @@ void abortFiresWhenListenerOnReadyThrows() throws Exception {
     SessionImpl session = new SessionImpl(metrics, poolInfo, 0, sessionFactory.createNew(), timer);
 
     CountDownLatch onCloseLatch = new CountDownLatch(1);
-    AtomicReference<Status> capturedStatus =
-        new AtomicReference<>();
+    AtomicReference<Status> capturedStatus = new AtomicReference<>();
 
     Session.Listener throwingListener =
         new Session.Listener() {

java-bigtable/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/internal/session/SessionPoolImplTest.java

@@ -78,14 +78,14 @@
 import java.time.Instant;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
-import java.util.function.LongPredicate;
 import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
+import java.util.function.LongPredicate;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Nested;
@@ -429,8 +429,7 @@ public void test() throws Exception {
       // Match anything that isn't one of the two fixed cadences.
       long watchdogMs = Duration.ofMinutes(5).toMillis();
       long afePruneMs = SessionList.SESSION_LIST_PRUNE_INTERVAL.toMillis();
-      LongPredicate isRetrySchedule =
-          d -> d > 0 && d != watchdogMs && d != afePruneMs;
+      LongPredicate isRetrySchedule = d -> d > 0 && d != watchdogMs && d != afePruneMs;
 
       // start the pool
       sessionPool.start(