summaryrefslogtreecommitdiffstats
path: root/container-search
diff options
context:
space:
mode:
authorOlli Virtanen <olli.virtanen@oath.com>2019-03-12 15:56:27 +0100
committerOlli Virtanen <olli.virtanen@oath.com>2019-03-12 15:56:27 +0100
commit78782a95591616c81eacac047ff2e863a9bd8cb9 (patch)
tree5da2d0e52d73de98c331c3c475065f76b8ca892d /container-search
parent66ec8a5349ac6e81148ba7556ce4d056e55b7bd6 (diff)
Minor cleanup
Diffstat (limited to 'container-search')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/rpc/ProtobufSerialization.java31
1 files changed, 16 insertions, 15 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/ProtobufSerialization.java b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/ProtobufSerialization.java
index 7807b20f72d..e77451ee3fd 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/ProtobufSerialization.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/ProtobufSerialization.java
@@ -38,12 +38,23 @@ public class ProtobufSerialization {
return convertFromQuery(query, serverId, includeQueryData).toByteArray();
}
+ public static byte[] serializeResult(Result searchResult) {
+ return convertFromResult(searchResult).toByteArray();
+ }
+
+ public static Result deserializeToResult(byte[] payload, Query query, VespaBackEndSearcher searcher)
+ throws InvalidProtocolBufferException {
+ var protobuf = Search.Reply.parseFrom(payload);
+ var result = convertToResult(query, protobuf, searcher.getDocumentDatabase(query));
+ return result;
+ }
+
private static Search.Request convertFromQuery(Query query, String serverId, boolean includeQueryData) {
var builder = Search.Request.newBuilder().setHits(query.getHits()).setOffset(query.getOffset())
.setTimeout((int) query.getTimeLeft());
mergeToRequestFromRanking(query.getRanking(), builder, includeQueryData);
- mergeToRequestFromModel(query.getModel(), builder, includeQueryData);
+ mergeToRequestFromModel(query.getModel(), builder);
if (query.getGroupingSessionCache() || query.getRanking().getQueryCache()) {
// TODO verify that the session key is included whenever rank properties would have been
@@ -71,7 +82,7 @@ public class ProtobufSerialization {
return builder.build();
}
- private static void mergeToRequestFromModel(Model model, Search.Request.Builder builder, boolean encodeQueryData) {
+ private static void mergeToRequestFromModel(Model model, Search.Request.Builder builder) {
if (model.getDocumentDb() != null) {
builder.setDocumentType(model.getDocumentDb());
}
@@ -90,8 +101,9 @@ public class ProtobufSerialization {
}
}
- private static void mergeToRequestFromPresentation(Presentation presentation, Search.Request.Builder builder, boolean encodeQueryData) {
- if (encodeQueryData && presentation.getHighlight() != null) {
+ private static void mergeToRequestFromPresentation(Presentation presentation, Search.Request.Builder builder,
+ boolean includeQueryData) {
+ if (includeQueryData && presentation.getHighlight() != null) {
MapConverter.convertStringMultiMap(presentation.getHighlight().getHighlightTerms(), builder::addHighlightTerms);
}
}
@@ -136,13 +148,6 @@ public class ProtobufSerialization {
}
}
- public static Result deserializeToResult(byte[] payload, Query query, VespaBackEndSearcher searcher)
- throws InvalidProtocolBufferException {
- var protobuf = Search.Reply.parseFrom(payload);
- var result = convertToResult(query, protobuf, searcher.getDocumentDatabase(query));
- return result;
- }
-
private static Result convertToResult(Query query, Search.Reply protobuf, DocumentDatabase documentDatabase) {
var result = new Result(query);
@@ -216,8 +221,4 @@ public class ProtobufSerialization {
return builder.build();
}
- public static byte[] serializeResult(Result searchResult) {
- return convertFromResult(searchResult).toByteArray();
- }
-
}