summaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandler.java
diff options
context:
space:
mode:
Diffstat (limited to 'vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandler.java')
-rw-r--r--vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandler.java55
1 files changed, 55 insertions, 0 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandler.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandler.java
index e7ed9ce10db..6a811eb5afd 100644
--- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandler.java
+++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandler.java
@@ -27,11 +27,66 @@ public interface OperationHandler {
public final Optional<String> cluster;
public final Optional<String> continuation;
public final Optional<Integer> wantedDocumentCount;
+ public final Optional<String> fieldSet;
+ public final Optional<Integer> concurrency;
+ /** @deprecated Use a VisitOptions.Builder instead */
+ @Deprecated
public VisitOptions(Optional<String> cluster, Optional<String> continuation, Optional<Integer> wantedDocumentCount) {
this.cluster = cluster;
this.continuation = continuation;
this.wantedDocumentCount = wantedDocumentCount;
+ this.fieldSet = Optional.empty();
+ this.concurrency = Optional.empty();
+ }
+
+ private VisitOptions(Builder builder) {
+ this.cluster = Optional.ofNullable(builder.cluster);
+ this.continuation = Optional.ofNullable(builder.continuation);
+ this.wantedDocumentCount = Optional.ofNullable(builder.wantedDocumentCount);
+ this.fieldSet = Optional.ofNullable(builder.fieldSet);
+ this.concurrency = Optional.ofNullable(builder.concurrency);
+ }
+
+ public static class Builder {
+ String cluster;
+ String continuation;
+ Integer wantedDocumentCount;
+ String fieldSet;
+ Integer concurrency;
+
+ public Builder cluster(String cluster) {
+ this.cluster = cluster;
+ return this;
+ }
+
+ public Builder continuation(String continuation) {
+ this.continuation = continuation;
+ return this;
+ }
+
+ public Builder wantedDocumentCount(Integer count) {
+ this.wantedDocumentCount = count;
+ return this;
+ }
+
+ public Builder fieldSet(String fieldSet) {
+ this.fieldSet = fieldSet;
+ return this;
+ }
+
+ public Builder concurrency(Integer concurrency) {
+ this.concurrency = concurrency;
+ return this;
+ }
+
+ public VisitOptions build() {
+ return new VisitOptions(this);
+ }
+ }
+
+ public static Builder builder() {
+ return new Builder();
}
}