Rename LocalExchangeSink and LocalExchangeSource (elastic#106245)

These should not have the term Local.
not-napoleon · Mar 12, 2024 · e42e47e · e42e47e
1 parent 10dcb8e
commit e42e47e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/...ompute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSinkHandler.java b/...ompute/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/...pute/src/main/java/org/elasticsearch/compute/operator/exchange/ExchangeSourceHandler.java b/...pute/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();
     }
 
     /**