From 41a817828d3d8024952075cf0a34b2085956febb Mon Sep 17 00:00:00 2001
From: Jeremy Ford <jeremy.l.ford@gmail.com>
Date: Mon, 29 Jul 2024 21:08:27 -0400
Subject: [PATCH] DBZ-8054 Formatting

---
 .../processor/AbstractLogMinerEventProcessor.java      |  2 +-
 ...stractTransactionCachingLogMinerEventProcessor.java | 10 +++++-----
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java
index e54877558..55c54b185 100644
--- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java
+++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java
@@ -1546,7 +1546,7 @@ protected void abandonTransactionOverEventThreshold(T transaction) {
         metrics.incrementOversizedTransactionCount();
     }
 
-    //this implementation is different
+    // this implementation is different
     @Override
     public void abandonTransactions(Duration retention) throws InterruptedException {
         if (!Duration.ZERO.equals(retention)) {
diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractTransactionCachingLogMinerEventProcessor.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractTransactionCachingLogMinerEventProcessor.java
index 3d48d8a36..71e7f2e2e 100644
--- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractTransactionCachingLogMinerEventProcessor.java
+++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractTransactionCachingLogMinerEventProcessor.java
@@ -97,7 +97,7 @@ protected boolean isRecentlyProcessed(String transactionId) {
         return getProcessedTransactionsCache().containsKey(transactionId);
     }
 
-    //from EmbeddedInfinispanLogMinerEventProcessor, impl is different
+    // from EmbeddedInfinispanLogMinerEventProcessor, impl is different
     @Override
     protected Scn getTransactionCacheMinimumScn() {
         return getTransactionCache().streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getValue)
@@ -106,20 +106,20 @@ protected Scn getTransactionCacheMinimumScn() {
                 .orElse(Scn.NULL));
     }
 
-    //from EmbeddedInfinispanLogMinerEventProcessor, impl is different
+    // from EmbeddedInfinispanLogMinerEventProcessor, impl is different
     protected Optional<T> getOldestTransactionInCache() {
         return getTransactionCache().streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getValue)
                 .min(this::oldestTransactionComparison));
     }
 
-    //from EmbeddedInfinispanLogMinerEventProcessor, impl is different
+    // from EmbeddedInfinispanLogMinerEventProcessor, impl is different
     @Override
     protected String getFirstActiveTransactionKey() {
         return getTransactionCache()
                 .streamAndReturn(stream -> stream.map(LogMinerCache.Entry::getKey).findFirst()).orElse(null);
     }
 
-    //this impl is different
+    // this impl is different
     @Override
     protected void removeEventWithRowId(LogMinerEventRow row) {
         // locate the events based solely on XIDUSN and XIDSLT.
@@ -179,7 +179,7 @@ protected boolean hasSchemaChangeBeenSeen(LogMinerEventRow row) {
         return getSchemaChangesCache().containsKey(row.getScn().toString());
     }
 
-    //different from AbstractInfinispanLogMinerEventProcessor
+    // different from AbstractInfinispanLogMinerEventProcessor
     @Override
     protected T getAndRemoveTransactionFromCache(String transactionId) {
         return getTransactionCache().remove(transactionId);