diff options
author | Tor Brede Vekterli <vekterli@oath.com> | 2018-02-01 16:33:59 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-02-01 16:33:59 +0100 |
commit | b79496d5bbf72e3d617502cec20871ca33a4da25 (patch) | |
tree | 3f3860cc0bc4af7c21fad23df281a6eea3c6b737 /vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java | |
parent | bf3004f40f29b129f6c05562b9b1786d574bae94 (diff) | |
parent | 752f5b5b3d7bb0726c45b38cf580b93c4916dc60 (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.java | 4 |
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); |