diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-04-19 09:21:18 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-04-19 09:21:18 +0200 |
commit | c46651cd8382731f845a44ba9f46e6d43cbc64d0 (patch) | |
tree | db69cbf093c398b7d4ff44a624057bec7ff7752b | |
parent | 4f542728c8f13882470b7bdc55fe9909fd2ffe81 (diff) |
Simplify and modernize code
-rw-r--r-- | vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java | 64 |
1 files changed, 22 insertions, 42 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java index 2a688ad078b..46aef7536c4 100644 --- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java +++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java @@ -526,23 +526,18 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { parameters = getProperty(request, TIMEOUT, timeoutMillisParser).map(clock.instant()::plusMillis) .map(parameters::withDeadline) .orElse(parameters); - for (String name : names) switch (name) { - case CLUSTER: - parameters = getProperty(request, CLUSTER).map(cluster -> resolveCluster(Optional.of(cluster), clusters).name()) - .map(parameters::withRoute) - .orElse(parameters); - break; - case FIELD_SET: - parameters = getProperty(request, FIELD_SET).map(parameters::withFieldSet) - .orElse(parameters); - break; - case ROUTE: - parameters = getProperty(request, ROUTE).map(parameters::withRoute) - .orElse(parameters); - break; - default: - throw new IllegalArgumentException("Unrecognized document operation parameter name '" + name + "'"); - } + for (String name : names) + parameters = switch (name) { + case CLUSTER -> + getProperty(request, CLUSTER) + .map(cluster -> resolveCluster(Optional.of(cluster), clusters).name()) + .map(parameters::withRoute) + .orElse(parameters); + case FIELD_SET -> getProperty(request, FIELD_SET).map(parameters::withFieldSet).orElse(parameters); + case ROUTE -> getProperty(request, ROUTE).map(parameters::withRoute).orElse(parameters); + default -> + throw new IllegalArgumentException("Unrecognized document operation parameter name '" + name + "'"); + }; return parameters; } @@ -630,10 +625,6 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { private boolean first = true; private ContentChannel channel; - private JsonResponse(ResponseHandler handler) throws IOException { - this(handler, null); - } - private JsonResponse(ResponseHandler handler, HttpRequest request) throws IOException { this.handler = handler; this.request = request; @@ -642,11 +633,6 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { } /** Creates a new JsonResponse with path and id fields written. */ - static JsonResponse create(DocumentPath path, ResponseHandler handler) throws IOException { - return create(path, handler, null); - } - - /** Creates a new JsonResponse with path and id fields written. */ static JsonResponse create(DocumentPath path, ResponseHandler handler, HttpRequest request) throws IOException { JsonResponse response = new JsonResponse(handler, request); response.writePathId(path.rawPath()); @@ -749,23 +735,17 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { } private boolean tensorShortForm() { - if (request != null && - request.parameters().containsKey("format.tensors") && - ( request.parameters().get("format.tensors").contains("long") - || request.parameters().get("format.tensors").contains("long-value"))) { - return false; - } - return true; // default + return request == null || + !request.parameters().containsKey("format.tensors") || + (!request.parameters().get("format.tensors").contains("long") + && !request.parameters().get("format.tensors").contains("long-value"));// default } private boolean tensorDirectValues() { - if (request != null && - request.parameters().containsKey("format.tensors") && - ( request.parameters().get("format.tensors").contains("short-value") - || request.parameters().get("format.tensors").contains("long-value"))) { - return true; - } - return false; // TODO: Flip default on Vespa 9 + return request != null && + request.parameters().containsKey("format.tensors") && + (request.parameters().get("format.tensors").contains("short-value") + || request.parameters().get("format.tensors").contains("long-value"));// TODO: Flip default on Vespa 9 } synchronized void writeSingleDocument(Document document) throws IOException { @@ -1546,11 +1526,11 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { private static Map<String, StorageCluster> parseClusters(ClusterListConfig clusters, AllClustersBucketSpacesConfig buckets) { return clusters.storage().stream() - .collect(toUnmodifiableMap(storage -> storage.name(), + .collect(toUnmodifiableMap(ClusterListConfig.Storage::name, storage -> new StorageCluster(storage.name(), buckets.cluster(storage.name()) .documentType().entrySet().stream() - .collect(toMap(entry -> entry.getKey(), + .collect(toMap(Map.Entry::getKey, entry -> entry.getValue().bucketSpace()))))); } |