This is an automated email from the ASF dual-hosted git repository.
cshannon pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/main by this push:
new eaa13849cd Removed unused method that was missed in (#3773)
eaa13849cd is described below
commit eaa13849cd71c777fb3dd77c311615c1bce4cede
Author: Christopher L. Shannon (cshannon) <[email protected]>
AuthorDate: Sat Sep 30 12:38:05 2023 -0400
Removed unused method that was missed in (#3773)
---
.../accumulo/tserver/tablet/CompactableUtils.java | 25 ----------------------
1 file changed, 25 deletions(-)
diff --git
a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/CompactableUtils.java
b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/CompactableUtils.java
index 5a27fb28eb..321c07a714 100644
---
a/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/CompactableUtils.java
+++
b/server/tserver/src/main/java/org/apache/accumulo/tserver/tablet/CompactableUtils.java
@@ -22,7 +22,6 @@ import java.io.IOException;
import java.io.UncheckedIOException;
import java.util.Collection;
import java.util.Collections;
-import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
import java.util.Optional;
@@ -53,7 +52,6 @@ import org.apache.accumulo.core.data.TabletId;
import org.apache.accumulo.core.data.Value;
import org.apache.accumulo.core.dataImpl.TabletIdImpl;
import org.apache.accumulo.core.file.FileOperations;
-import org.apache.accumulo.core.file.FileSKVIterator;
import org.apache.accumulo.core.iterators.SortedKeyValueIterator;
import org.apache.accumulo.core.metadata.CompactableFileImpl;
import org.apache.accumulo.core.metadata.ReferencedTabletFile;
@@ -63,19 +61,16 @@ import
org.apache.accumulo.core.sample.impl.SamplerConfigurationImpl;
import org.apache.accumulo.core.spi.common.ServiceEnvironment;
import org.apache.accumulo.core.spi.compaction.CompactionJob;
import org.apache.accumulo.core.spi.compaction.CompactionKind;
-import org.apache.accumulo.core.spi.crypto.CryptoService;
import org.apache.accumulo.core.summary.Gatherer;
import org.apache.accumulo.core.summary.SummarizerFactory;
import org.apache.accumulo.core.summary.SummaryCollection;
import org.apache.accumulo.core.summary.SummaryReader;
-import org.apache.accumulo.core.util.Pair;
import org.apache.accumulo.server.ServiceEnvironmentImpl;
import org.apache.accumulo.server.compaction.CompactionStats;
import org.apache.accumulo.server.compaction.FileCompactor;
import
org.apache.accumulo.server.compaction.FileCompactor.CompactionCanceledException;
import org.apache.accumulo.server.compaction.FileCompactor.CompactionEnv;
import org.apache.accumulo.server.conf.TableConfiguration;
-import org.apache.accumulo.server.fs.VolumeManager;
import org.apache.accumulo.server.util.MetadataTableUtil;
import org.apache.accumulo.tserver.tablet.CompactableImpl.CompactionHelper;
import org.apache.hadoop.conf.Configuration;
@@ -86,26 +81,6 @@ import com.google.common.collect.Collections2;
public class CompactableUtils {
- public static Map<StoredTabletFile,Pair<Key,Key>> getFirstAndLastKeys(Tablet
tablet,
- Set<StoredTabletFile> allFiles) throws IOException {
- final Map<StoredTabletFile,Pair<Key,Key>> result = new HashMap<>();
- final FileOperations fileFactory = FileOperations.getInstance();
- final VolumeManager fs = tablet.getTabletServer().getVolumeManager();
- final TableConfiguration tableConf = tablet.getTableConfiguration();
- final CryptoService cs = tableConf.getCryptoService();
- for (StoredTabletFile file : allFiles) {
- FileSystem ns = fs.getFileSystemByPath(file.getPath());
- try (FileSKVIterator openReader =
- fileFactory.newReaderBuilder().forFile(file, ns, ns.getConf(), cs)
- .withTableConfiguration(tableConf).seekToBeginning().build()) {
- Key first = openReader.getFirstKey();
- Key last = openReader.getLastKey();
- result.put(file, new Pair<>(first, last));
- }
- }
- return result;
- }
-
static Map<String,String> computeOverrides(Tablet tablet,
Set<CompactableFile> files) {
var tconf = tablet.getTableConfiguration();
