summaryrefslogtreecommitdiffstats
path: root/documentapi/src/main
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2022-06-07 16:38:38 +0200
committergjoranv <gv@verizonmedia.com>2022-06-08 11:45:31 +0200
commitda6bf15eb506bfab49d49bb599038cc972640a74 (patch)
treeeae69967d2fa7609aeed7bb341cf08f71a6d7780 /documentapi/src/main
parent8822bf13ddb2ad2c226a8d812efbe08c54d092a2 (diff)
Remove maxFirstPass support on Vespa 8
Diffstat (limited to 'documentapi/src/main')
-rw-r--r--documentapi/src/main/java/com/yahoo/documentapi/VisitorParameters.java17
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java12
2 files changed, 2 insertions, 27 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/VisitorParameters.java b/documentapi/src/main/java/com/yahoo/documentapi/VisitorParameters.java
index 503def16c21..651269f8db2 100644
--- a/documentapi/src/main/java/com/yahoo/documentapi/VisitorParameters.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/VisitorParameters.java
@@ -38,7 +38,6 @@ public class VisitorParameters extends Parameters {
private Map<String, byte []> libraryParameters = new TreeMap<>();
private Route visitRoute = null;
private final float weight = 1;
- private long maxFirstPassHits = -1;
private long maxTotalHits = -1;
private int maxBucketsPerVisitor = 1;
private boolean dynamicallyIncreaseMaxBucketsPerVisitor = false;
@@ -88,7 +87,6 @@ public class VisitorParameters extends Parameters {
setLocalDataHandler(params.getLocalDataHandler());
}
setControlHandler(params.getControlHandler());
- setMaxFirstPassHits(params.getMaxFirstPassHits());
setMaxTotalHits(params.getMaxTotalHits());
setMaxBucketsPerVisitor(params.getMaxBucketsPerVisitor());
setPriority(params.getPriority());
@@ -272,20 +270,6 @@ public class VisitorParameters extends Parameters {
// TODO: Document: Where is the default - does this ever return null, or does it return "storage" if input is null?
public Route getRoute() { return visitRoute; }
- /** Set the maximum number of documents to visit (max documents returned by the visitor)
- *
- * @deprecated use setMaxTotalHits instead
- */
- @Deprecated(since = "7", forRemoval = true) // TODO: Vespa 8: remove
- public void setMaxFirstPassHits(long max) { maxFirstPassHits = max; }
-
- /** @return Returns the maximum number of documents to visit (max documents returned by the visitor)
- *
- * @deprecated Use getMaxTotalHits() instead
- */
- @Deprecated(since = "7", forRemoval = true) // TODO: Vespa 8: remove
- public long getMaxFirstPassHits() { return maxFirstPassHits; }
-
/** Set the maximum number of documents to visit (max documents returned by the visitor) */
public void setMaxTotalHits(long max) { maxTotalHits = max; }
@@ -368,7 +352,6 @@ public class VisitorParameters extends Parameters {
sb.append(" Field set: ").append(fieldSet).append('\n');
sb.append(" Route: ").append(visitRoute).append('\n');
sb.append(" Weight: ").append(weight).append('\n');
- sb.append(" Max firstpass hits: ").append(maxFirstPassHits).append('\n');
sb.append(" Max total hits: ").append(maxTotalHits).append('\n');
sb.append(" Max buckets: ").append(maxBucketsPerVisitor).append('\n');
sb.append(" Priority: ").append(getPriority().toString()).append('\n');
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
index 46a05687701..ccd9c65e77e 100755
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
@@ -1000,11 +1000,6 @@ public class MessageBusVisitorSession implements VisitorSession {
@SuppressWarnings("removal") // TODO: Vespa 8: remove
private boolean enoughHitsReceived() {
// TODO: Vespa 8: remove "Nth pass" concept entirely from API and internals
- if (params.getMaxFirstPassHits() != -1
- && statistics.getDocumentsReturned() >= params.getMaxFirstPassHits())
- {
- return true;
- }
if (params.getMaxTotalHits() != -1
&& (statistics.getDocumentsReturned() >= params.getMaxTotalHits()))
{
@@ -1105,11 +1100,8 @@ public class MessageBusVisitorSession implements VisitorSession {
trace.getRoot().addChild(reply.getTrace().getRoot());
}
- // TODO: Vespa 8 remove this unused functionality
- if (params.getDynamicallyIncreaseMaxBucketsPerVisitor()
- && (reply.getVisitorStatistics().getDocumentsReturned()
- < params.getMaxFirstPassHits() / 2.0))
- {
+ // TODO: Vespa 8 remove this unused functionality (?)
+ if (params.getDynamicallyIncreaseMaxBucketsPerVisitor()) {
// Attempt to increase parallelism to reduce latency of visiting
// Ensure new count is within [1, 128]
int newMaxBuckets = Math.max(Math.min((int)(params.getMaxBucketsPerVisitor()