diff options
author | Jon Bratseth <bratseth@gmail.com> | 2022-06-07 16:38:38 +0200 |
---|---|---|
committer | gjoranv <gv@verizonmedia.com> | 2022-06-08 11:45:31 +0200 |
commit | da6bf15eb506bfab49d49bb599038cc972640a74 (patch) | |
tree | eae69967d2fa7609aeed7bb341cf08f71a6d7780 /documentapi/src/main | |
parent | 8822bf13ddb2ad2c226a8d812efbe08c54d092a2 (diff) |
Remove maxFirstPass support on Vespa 8
Diffstat (limited to 'documentapi/src/main')
-rw-r--r-- | documentapi/src/main/java/com/yahoo/documentapi/VisitorParameters.java | 17 | ||||
-rwxr-xr-x | documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java | 12 |
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() |