Revision based on review from @adutra

Author: adnanhemani

runtime/service/src/main/java/org/apache/polaris/service/events/listeners/ConcurrentLinkedQueueWithApproximateSize.java

@@ -23,7 +23,7 @@
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.stream.Stream;
 
-public class ConcurrentLinkedQueueWithApproximateSize<T> {
+class ConcurrentLinkedQueueWithApproximateSize<T> {
   private final ConcurrentLinkedQueue<T> queue = new ConcurrentLinkedQueue<>();
   private final AtomicInteger size = new AtomicInteger();
 

runtime/service/src/test/java/org/apache/polaris/service/events/listeners/InMemoryBufferPolarisPersistenceEventListenerTest.java

@@ -199,7 +199,7 @@ public void testProcessEventIsThreadSafe() throws Exception {
           "Exceptions occurred in concurrent processEvent: ", exceptions.peek());
     }
 
-    ArgumentCaptor<List<PolarisEvent>> eventsCaptor = ArgumentCaptor.forClass(List.class);
+    ArgumentCaptor<List<PolarisEvent>> eventsCaptor = ArgumentCaptor.captor();
     verify(polarisMetaStoreManager, atLeastOnce()).writeEvents(any(), eventsCaptor.capture());
     Awaitility.await("expected amount of records should be processed")
         .atMost(Duration.ofSeconds(30))