diff --git a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSinkHandler.java b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSinkHandler.java
index d1a2b8710cd23..945fdff50d31c 100644
--- a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSinkHandler.java
+++ b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSinkHandler.java
@@ -49,10 +49,10 @@ public ExchangeSinkHandler(BlockFactory blockFactory, int maxBufferSize, LongSup
         this.lastUpdatedInMillis = new AtomicLong(nowInMillis.getAsLong());
     }
 
-    private class LocalExchangeSink implements ExchangeSink {
+    private class ExchangeSinkImpl implements ExchangeSink {
         boolean finished;
 
-        LocalExchangeSink() {
+        ExchangeSinkImpl() {
             onChanged();
             outstandingSinks.incrementAndGet();
         }
@@ -155,7 +155,7 @@ private void notifyListeners() {
      * @see ExchangeSinkOperator
      */
     public ExchangeSink createExchangeSink() {
-        return new LocalExchangeSink();
+        return new ExchangeSinkImpl();
     }
 
     /**
diff --git a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSourceHandler.java b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSourceHandler.java
index 859b1fc73c3e1..7492fa8c19385 100644
--- a/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSourceHandler.java
+++ b/x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSourceHandler.java
@@ -44,10 +44,10 @@ public ExchangeSourceHandler(int maxBufferSize, Executor fetchExecutor) {
         this.outstandingSources = new PendingInstances(() -> buffer.finish(true));
     }
 
-    private class LocalExchangeSource implements ExchangeSource {
+    private class ExchangeSourceImpl implements ExchangeSource {
         private boolean finished;
 
-        LocalExchangeSource() {
+        ExchangeSourceImpl() {
             outstandingSources.trackNewInstance();
         }
 
@@ -95,7 +95,7 @@ public int bufferSize() {
      * @see ExchangeSinkOperator
      */
     public ExchangeSource createExchangeSource() {
-        return new LocalExchangeSource();
+        return new ExchangeSourceImpl();
     }
 
     /**