diff options
author | Harald Musum <musum@yahooinc.com> | 2024-03-21 19:30:19 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-03-21 19:30:19 +0100 |
commit | 4c183941017686064ff15abe3d56f749ed69adc3 (patch) | |
tree | 174c8f07de031fa7895a5f2f049da4e5462d5a02 /container-search | |
parent | 64d060cceccb4d567f56bbf2fbff93d994e3a52f (diff) | |
parent | ac0fdddfe264774b0671a4262d3ee7440c4563c3 (diff) |
Merge pull request #30710 from vespa-engine/balder/gc-unused-code
- GC unused code.
Diffstat (limited to 'container-search')
6 files changed, 20 insertions, 55 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/federation/FederationSearcher.java b/container-search/src/main/java/com/yahoo/search/federation/FederationSearcher.java index f40caac1562..000fef9b14b 100644 --- a/container-search/src/main/java/com/yahoo/search/federation/FederationSearcher.java +++ b/container-search/src/main/java/com/yahoo/search/federation/FederationSearcher.java @@ -42,7 +42,6 @@ import com.yahoo.search.searchchain.model.federation.FederationOptions; import java.time.Clock; import java.util.ArrayList; import java.util.Collection; -import java.util.Collections; import java.util.HashMap; import java.util.IdentityHashMap; import java.util.Iterator; @@ -95,7 +94,7 @@ public class FederationSearcher extends ForkingSearcher { } // for testing - public FederationSearcher(ComponentId id, SearchChainResolver searchChainResolver, + public FederationSearcher(SearchChainResolver searchChainResolver, Map<String, List<String>> schema2Clusters) { this(searchChainResolver, VirtualSourceResolver.of(), null, schema2Clusters); } @@ -151,7 +150,9 @@ public class FederationSearcher extends ForkingSearcher { } private static void addSearchChain(SearchChainResolver.Builder builder, - FederationConfig.Target target, FederationConfig.Target.SearchChain searchChain) { + FederationConfig.Target target, + FederationConfig.Target.SearchChain searchChain) + { if (!target.id().equals(searchChain.searchChainId())) throw new RuntimeException("Invalid federation config, " + target.id() + " != " + searchChain.searchChainId()); @@ -160,7 +161,8 @@ public class FederationSearcher extends ForkingSearcher { } private static void addSourceForProvider(SearchChainResolver.Builder builder, FederationConfig.Target target, - FederationConfig.Target.SearchChain searchChain, boolean isDefaultProvider) { + FederationConfig.Target.SearchChain searchChain, boolean isDefaultProvider) + { builder.addSourceForProvider( ComponentId.fromString(target.id()), ComponentId.fromString(searchChain.providerId()), @@ -181,14 +183,12 @@ public class FederationSearcher extends ForkingSearcher { public Result search(Query query, Execution execution) { Result mergedResults = execution.search(query); - Results<SearchChainInvocationSpec, UnresolvedSearchChainException> targets = - getTargets(query.getModel().getSources(), query.properties()); + var targets = getTargets(query.getModel().getSources(), query.properties()); warnIfUnresolvedSearchChains(targets.errors(), mergedResults.hits()); - Collection<SearchChainInvocationSpec> prunedTargets = - pruneTargetsWithoutDocumentTypes(query.getModel().getRestrict(), targets.data()); + var prunedTargets = pruneTargetsWithoutDocumentTypes(query.getModel().getRestrict(), targets.data()); - Results<Target, ErrorMessage> regularTargetHandlers = resolveSearchChains(prunedTargets, execution.searchChainRegistry()); + var regularTargetHandlers = resolveSearchChains(prunedTargets, execution.searchChainRegistry()); query.errors().addAll(regularTargetHandlers.errors()); Set<Target> targetHandlers = new LinkedHashSet<>(regularTargetHandlers.data()); @@ -359,8 +359,7 @@ public class FederationSearcher extends ForkingSearcher { public void fill(Result result, String summaryClass, Execution execution) { UniqueExecutionsToResults uniqueExecutionsToResults = new UniqueExecutionsToResults(); addResultsToFill(result.hits(), result, summaryClass, uniqueExecutionsToResults); - Set<Entry<Chain<Searcher>, Map<Query, Result>>> resultsForAllChains = - uniqueExecutionsToResults.resultsToFill.entrySet(); + var resultsForAllChains = uniqueExecutionsToResults.resultsToFill.entrySet(); int numberOfCallsToFillNeeded = 0; for (Entry<Chain<Searcher>, Map<Query, Result>> resultsToFillForAChain : resultsForAllChains) { @@ -563,7 +562,7 @@ public class FederationSearcher extends ForkingSearcher { } private static <T> List<Target> getAdditionalTargets(Query query, Execution execution, TargetSelector<T> targetSelector) { - if (targetSelector == null) return Collections.emptyList(); + if (targetSelector == null) return List.of(); ArrayList<Target> result = new ArrayList<>(); for (FederationTarget<T> target: targetSelector.getTargets(query, execution.searchChainRegistry())) @@ -708,12 +707,6 @@ public class FederationSearcher extends ForkingSearcher { private record Window(int hits, int offset) { - public Integer get(CompoundName parameterName) { - if (parameterName.equals(Query.HITS)) return hits; - if (parameterName.equals(Query.OFFSET)) return offset; - return null; - } - public static Window from(Query query) { return new Window(query.getHits(), query.getOffset()); } diff --git a/container-search/src/main/java/com/yahoo/search/federation/selection/TargetSelector.java b/container-search/src/main/java/com/yahoo/search/federation/selection/TargetSelector.java index c23be6bad14..be42ef1ee0e 100644 --- a/container-search/src/main/java/com/yahoo/search/federation/selection/TargetSelector.java +++ b/container-search/src/main/java/com/yahoo/search/federation/selection/TargetSelector.java @@ -5,7 +5,6 @@ import com.yahoo.processing.execution.chain.ChainRegistry; import com.yahoo.search.Query; import com.yahoo.search.Result; import com.yahoo.search.Searcher; -import com.yahoo.search.federation.selection.FederationTarget; import java.util.Collection; @@ -25,7 +24,7 @@ public interface TargetSelector<T> { Collection<FederationTarget<T>> getTargets(Query query, ChainRegistry<Searcher> searcherChainRegistry); /** - * For modifying the query before sending it to a the target + * For modifying the query before sending it to the target */ void modifyTargetQuery(FederationTarget<T> target, Query query); diff --git a/container-search/src/test/java/com/yahoo/search/federation/DuplicateSourceTestCase.java b/container-search/src/test/java/com/yahoo/search/federation/DuplicateSourceTestCase.java index 514a087bed1..f911e215867 100644 --- a/container-search/src/test/java/com/yahoo/search/federation/DuplicateSourceTestCase.java +++ b/container-search/src/test/java/com/yahoo/search/federation/DuplicateSourceTestCase.java @@ -37,8 +37,7 @@ public class DuplicateSourceTestCase { SearchChainResolver resolver = new SearchChainResolver.Builder() .addSearchChain(new ComponentId(chain1), List.of(schema1, schema2)) .build(); - FederationSearcher searcher = new FederationSearcher(new ComponentId("test"), resolver, - Map.of(schema1, List.of(chain1), schema2, List.of(chain1))); + var searcher = new FederationSearcher(resolver, Map.of(schema1, List.of(chain1), schema2, List.of(chain1))); Result result = searcher.search(new Query("?query=test&sources=doc1%2cdoc2"), new Execution(Execution.Context.createContextStub(searchChains))); diff --git a/container-search/src/test/java/com/yahoo/search/federation/FederationSearcherTestCase.java b/container-search/src/test/java/com/yahoo/search/federation/FederationSearcherTestCase.java index af0e0ef69a8..5d2e19d02a3 100644 --- a/container-search/src/test/java/com/yahoo/search/federation/FederationSearcherTestCase.java +++ b/container-search/src/test/java/com/yahoo/search/federation/FederationSearcherTestCase.java @@ -284,7 +284,7 @@ public class FederationSearcherTestCase { builder.addSourceForProvider(news, provider1, provider1, true, options, List.of()); builder.addSourceForProvider(news, provider2, provider2, false, options, List.of()); - return new FederationSearcher(new ComponentId("federation"), builder.build(), Map.of()); + return new FederationSearcher(builder.build(), Map.of()); } private static class MockProvider extends Searcher { @@ -304,30 +304,4 @@ public class FederationSearcherTestCase { } - private static class QueryCheckSearcher extends Searcher { - - private static final String STATUS = "status"; - public static final String FEDERATION_SEARCHER_HAS_CLONED_THE_QUERY = "FederationSearcher has cloned the query."; - public static final String OK = "Got the correct query."; - private final Query query; - - QueryCheckSearcher(Query query) { - this.query = query; - } - - @Override - public Result search(Query query, Execution execution) { - Result result = new Result(query); - if (query != this.query) { - result.hits().addError(ErrorMessage - .createErrorInPluginSearcher(FEDERATION_SEARCHER_HAS_CLONED_THE_QUERY)); - } else { - final Hit h = new Hit("QueryCheckSearcher status hit"); - h.setField(STATUS, OK); - result.hits().add(h); - } - return result; - } - } - } diff --git a/container-search/src/test/java/com/yahoo/search/federation/FederationTester.java b/container-search/src/test/java/com/yahoo/search/federation/FederationTester.java index ec540e43dfd..6016e85bc17 100644 --- a/container-search/src/test/java/com/yahoo/search/federation/FederationTester.java +++ b/container-search/src/test/java/com/yahoo/search/federation/FederationTester.java @@ -47,7 +47,7 @@ class FederationTester { } FederationSearcher buildFederationSearcher() { - return new FederationSearcher(ComponentId.fromString("federation"), builder.build(), Map.of()); + return new FederationSearcher(builder.build(), Map.of()); } public Result search() { diff --git a/container-search/src/test/java/com/yahoo/search/searchchain/test/FutureDataTestCase.java b/container-search/src/test/java/com/yahoo/search/searchchain/test/FutureDataTestCase.java index 36c80e852d1..bfcde54d65b 100644 --- a/container-search/src/test/java/com/yahoo/search/searchchain/test/FutureDataTestCase.java +++ b/container-search/src/test/java/com/yahoo/search/searchchain/test/FutureDataTestCase.java @@ -39,11 +39,11 @@ public class FutureDataTestCase { Searcher syncProviderSearcher = new SyncProviderSearcher(); Chain<Searcher> asyncSource = new Chain<>(new ComponentId("async"), asyncProviderSearcher); Chain<Searcher> syncSource = new Chain<>(new ComponentId("sync"), syncProviderSearcher); - SearchChainResolver searchChainResolver = - new SearchChainResolver.Builder().addSearchChain(new ComponentId("sync"), new FederationOptions().setUseByDefault(true)). - addSearchChain(new ComponentId("async"), new FederationOptions().setUseByDefault(true)). - build(); - Chain<Searcher> main = new Chain<>(new FederationSearcher(new ComponentId("federator"), searchChainResolver, Map.of())); + var searchChainResolver = new SearchChainResolver.Builder() + .addSearchChain(new ComponentId("sync"), new FederationOptions().setUseByDefault(true)) + .addSearchChain(new ComponentId("async"), new FederationOptions().setUseByDefault(true)) + .build(); + Chain<Searcher> main = new Chain<>(new FederationSearcher(searchChainResolver, Map.of())); SearchChainRegistry searchChainRegistry = new SearchChainRegistry(); searchChainRegistry.register(main); searchChainRegistry.register(syncSource); |