summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search
diff options
context:
space:
mode:
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search')
-rw-r--r--container-search/src/main/java/com/yahoo/search/grouping/result/FlatteningSearcher.java5
-rw-r--r--container-search/src/main/java/com/yahoo/search/result/DefaultErrorHit.java1
-rw-r--r--container-search/src/main/java/com/yahoo/search/result/HitGroup.java12
3 files changed, 8 insertions, 10 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/grouping/result/FlatteningSearcher.java b/container-search/src/main/java/com/yahoo/search/grouping/result/FlatteningSearcher.java
index 87a9cb61a0e..cc428aec7a7 100644
--- a/container-search/src/main/java/com/yahoo/search/grouping/result/FlatteningSearcher.java
+++ b/container-search/src/main/java/com/yahoo/search/grouping/result/FlatteningSearcher.java
@@ -22,12 +22,13 @@ import java.util.Iterator;
@Before(GroupingExecutor.COMPONENT_NAME)
public class FlatteningSearcher extends Searcher {
- private final CompoundName flatten = CompoundName.from("grouping.flatten");
+ private final CompoundName groupingFlatten = CompoundName.from("grouping.flatten");
+ private final CompoundName flatten = CompoundName.from("flatten");
@Override
public Result search(Query query, Execution execution) {
+ if ( ! query.properties().getBoolean(groupingFlatten, true)) return execution.search(query);
if ( ! query.properties().getBoolean(flatten, true)) return execution.search(query);
- if ( ! query.properties().getBoolean("flatten", true)) return execution.search(query);
query.trace("Flattening groups", 2);
int originalHits = query.getHits();
diff --git a/container-search/src/main/java/com/yahoo/search/result/DefaultErrorHit.java b/container-search/src/main/java/com/yahoo/search/result/DefaultErrorHit.java
index 5fd41be0a54..fdd5c79adb6 100644
--- a/container-search/src/main/java/com/yahoo/search/result/DefaultErrorHit.java
+++ b/container-search/src/main/java/com/yahoo/search/result/DefaultErrorHit.java
@@ -75,6 +75,7 @@ public class DefaultErrorHit extends Hit implements ErrorHit, Cloneable {
/** Add all errors from another error hit to this */
public void addErrors(ErrorHit errorHit) {
+ if (this == errorHit) return;
for (Iterator<? extends ErrorMessage> i = errorHit.errorIterator(); i.hasNext();) {
addError(i.next());
}
diff --git a/container-search/src/main/java/com/yahoo/search/result/HitGroup.java b/container-search/src/main/java/com/yahoo/search/result/HitGroup.java
index c6447f85e61..51c0caf38a9 100644
--- a/container-search/src/main/java/com/yahoo/search/result/HitGroup.java
+++ b/container-search/src/main/java/com/yahoo/search/result/HitGroup.java
@@ -19,7 +19,6 @@ import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.concurrent.CompletableFuture;
-import java.util.stream.Collectors;
/**
* <p>A group of ordered hits. Since hitGroup is itself a kind of Hit,
@@ -504,9 +503,7 @@ public class HitGroup extends Hit implements DataList<Hit>, Cloneable, Iterable<
int currentIndex = -1;
ListenableArrayList<Hit> newHits = new ListenableArrayList<>(numHits);
- for (Iterator<Hit> i = hits.iterator(); i.hasNext();) {
- Hit hit = i.next();
-
+ for (Hit hit : hits) {
if (hit.isAuxiliary()) {
newHits.add(hit);
} else {
@@ -700,7 +697,6 @@ public class HitGroup extends Hit implements DataList<Hit>, Cloneable, Iterable<
// -------------- State bookkeeping
/** Ensures result invariants. Must be called when a hit is added to this result. */
- @SuppressWarnings("deprecation")
private void handleNewHit(Hit hit) {
if (!hit.isAuxiliary())
concreteHitCount++;
@@ -848,8 +844,8 @@ public class HitGroup extends Hit implements DataList<Hit>, Cloneable, Iterable<
HitGroup hitGroupClone = (HitGroup) super.clone();
hitGroupClone.hits = new ListenableArrayList<>(this.hits.size());
hitGroupClone.unmodifiableHits = Collections.unmodifiableList(hitGroupClone.hits);
- for (Iterator<Hit> i = this.hits.iterator(); i.hasNext();) {
- Hit hitClone = i.next().clone();
+ for (Hit value : this.hits) {
+ Hit hitClone = value.clone();
hitGroupClone.hits.add(hitClone);
}
if (this.errorHit != null) { // Find the cloned error and assign it
@@ -944,7 +940,7 @@ public class HitGroup extends Hit implements DataList<Hit>, Cloneable, Iterable<
}
private Iterable<Hit> fillableHits() {
- Predicate<Hit> isFillable = hit -> hit.isFillable();
+ Predicate<Hit> isFillable = Hit::isFillable;
return Iterables.filter(hits, isFillable);
}