This is an automated email from the ASF dual-hosted git repository.

kturner pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git

commit eaa1f678c96b135534fba89fe585107c4f242e54
Merge: 0ad96b1dc0 7947c2c2df
Author: Keith Turner <ktur...@apache.org>
AuthorDate: Wed Mar 20 18:39:26 2024 -0400

    Merge branch '2.1'

 .../core/client/ClientSideIteratorScanner.java     |  39 +++++++-
 .../accumulo/core/clientImpl/OfflineIterator.java  |  27 +++++-
 .../accumulo/core/clientImpl/ScannerImpl.java      |  10 ++
 .../apache/accumulo/test/ClientSideIteratorIT.java | 108 +++++++++++++++++++++
 4 files changed, 178 insertions(+), 6 deletions(-)

diff --cc 
core/src/main/java/org/apache/accumulo/core/client/ClientSideIteratorScanner.java
index a50561263f,362c4e85d6..7e300e917d
--- 
a/core/src/main/java/org/apache/accumulo/core/client/ClientSideIteratorScanner.java
+++ 
b/core/src/main/java/org/apache/accumulo/core/client/ClientSideIteratorScanner.java
@@@ -122,6 -133,22 +133,16 @@@ public class ClientSideIteratorScanner 
      public SamplerConfiguration getSamplerConfiguration() {
        return samplerConfig;
      }
+ 
 -    @Deprecated(since = "2.1.0")
 -    @Override
 -    public ServiceEnvironment getServiceEnv() {
 -      return new ClientServiceEnvironmentImpl(context.get());
 -    }
 -
+     @Override
+     public PluginEnvironment getPluginEnv() {
+       return new ClientServiceEnvironmentImpl(context.get());
+     }
+ 
+     @Override
+     public TableId getTableId() {
+       return tableId.get();
+     }
    }
  
    /**
diff --cc 
core/src/main/java/org/apache/accumulo/core/clientImpl/OfflineIterator.java
index 0e7a3fd4d2,a03cc811ab..9200591ff2
--- 
a/core/src/main/java/org/apache/accumulo/core/clientImpl/OfflineIterator.java
+++ 
b/core/src/main/java/org/apache/accumulo/core/clientImpl/OfflineIterator.java
@@@ -135,7 -153,24 +140,18 @@@ class OfflineIterator implements Iterat
        if (sampleConf == null) {
          throw new SampleNotPresentException();
        }
-       return new OfflineIteratorEnvironment(authorizations, conf, true, 
sampleConf);
+       return new OfflineIteratorEnvironment(context, tableId, authorizations, 
conf, true,
+           sampleConf);
+     }
+ 
 -    @Deprecated(since = "2.1.0")
 -    @Override
 -    public ServiceEnvironment getServiceEnv() {
 -      return new ClientServiceEnvironmentImpl(context);
 -    }
 -
+     @Override
+     public PluginEnvironment getPluginEnv() {
+       return new ClientServiceEnvironmentImpl(context);
+     }
+ 
+     @Override
+     public TableId getTableId() {
+       return tableId;
      }
    }
  

Reply via email to