aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@oath.com>2018-02-01 16:33:59 +0100
committerGitHub <noreply@github.com>2018-02-01 16:33:59 +0100
commitb79496d5bbf72e3d617502cec20871ca33a4da25 (patch)
tree3f3860cc0bc4af7c21fad23df281a6eea3c6b737 /vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
parentbf3004f40f29b129f6c05562b9b1786d574bae94 (diff)
parent752f5b5b3d7bb0726c45b38cf580b93c4916dc60 (diff)
Merge pull request #4873 from vespa-engine/vekterli/add-fieldset-and-concurrency-support-to-document-v1-visiting-api
Add fieldset and concurrency support to document v1 visiting api
Diffstat (limited to 'vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java')
-rw-r--r--vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
index 8fe2007e88a..d6ae4a9285a 100644
--- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
+++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
@@ -385,14 +385,14 @@ public class OperationHandlerImpl implements OperationHandler {
VisitorParameters params = new VisitorParameters(selection.toString());
// Only return fieldset that is part of the document.
- params.fieldSet(restUri.getDocumentType() + ":[document]");
+ params.fieldSet(options.fieldSet.orElse(restUri.getDocumentType() + ":[document]"));
params.setMaxBucketsPerVisitor(1);
params.setMaxPending(32);
params.setMaxFirstPassHits(1);
params.setMaxTotalHits(options.wantedDocumentCount
.map(n -> Math.min(Math.max(n, 1), WANTED_DOCUMENT_COUNT_UPPER_BOUND))
.orElse(1));
- params.setThrottlePolicy(new StaticThrottlePolicy().setMaxPendingCount(1));
+ params.setThrottlePolicy(new StaticThrottlePolicy().setMaxPendingCount(options.concurrency.orElse(1)));
params.setToTimestamp(0L);
params.setFromTimestamp(0L);
params.setSessionTimeoutMs(VISIT_TIMEOUT_MS);