diff options
author | Tor Egge <Tor.Egge@online.no> | 2023-04-21 11:44:33 +0200 |
---|---|---|
committer | Tor Egge <Tor.Egge@online.no> | 2023-04-21 11:44:33 +0200 |
commit | bb882d760f931c655a569f3d09744021395203b0 (patch) | |
tree | 926c1f3d13bd44d80be01cb47d708d8d84820b30 /container-search/src/main | |
parent | 6795d0352a225559efdfd68260a578cba22a5da4 (diff) |
Remove (SearchResult|DocumentSummary)(Command|Reply) storage and documentapi messages.
Diffstat (limited to 'container-search/src/main')
-rw-r--r-- | container-search/src/main/java/com/yahoo/vespa/streamingvisitors/VdsVisitor.java | 22 |
1 files changed, 1 insertions, 21 deletions
diff --git a/container-search/src/main/java/com/yahoo/vespa/streamingvisitors/VdsVisitor.java b/container-search/src/main/java/com/yahoo/vespa/streamingvisitors/VdsVisitor.java index 70dff6730ff..409b807c833 100644 --- a/container-search/src/main/java/com/yahoo/vespa/streamingvisitors/VdsVisitor.java +++ b/container-search/src/main/java/com/yahoo/vespa/streamingvisitors/VdsVisitor.java @@ -9,9 +9,7 @@ import com.yahoo.documentapi.VisitorDataHandler; import com.yahoo.documentapi.VisitorParameters; import com.yahoo.documentapi.VisitorSession; import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol; -import com.yahoo.documentapi.messagebus.protocol.DocumentSummaryMessage; import com.yahoo.documentapi.messagebus.protocol.QueryResultMessage; -import com.yahoo.documentapi.messagebus.protocol.SearchResultMessage; import com.yahoo.io.GrowableByteBuffer; import com.yahoo.messagebus.Message; @@ -300,12 +298,8 @@ class VdsVisitor extends VisitorDataHandler implements Visitor { public void onMessage(Message m, AckToken token) { if (m instanceof QueryResultMessage qm) { onQueryResult(qm.getResult(), qm.getSummary()); - } else if (m instanceof SearchResultMessage) { - onSearchResult(((SearchResultMessage) m).getResult()); - } else if (m instanceof DocumentSummaryMessage dsm) { - onDocumentSummary(dsm.getResult()); } else { - throw new UnsupportedOperationException("Received unsupported message " + m + ". VdsVisitor can only accept query result, search result, and documentsummary messages."); + throw new UnsupportedOperationException("Received unsupported message " + m + ". VdsVisitor can only accept query result messages."); } ack(token); } @@ -320,13 +314,6 @@ class VdsVisitor extends VisitorDataHandler implements Visitor { handleSummary(summary); } - public void onSearchResult(SearchResult sr) { - if (log.isLoggable(Level.FINEST)) { - log.log(Level.FINEST, "Got SearchResult for query with selection " + params.getDocumentSelection()); - } - handleSearchResult(sr); - } - private void handleSearchResult(SearchResult sr) { final int hitCountTotal = sr.getTotalHitCount(); final int hitCount = sr.getHitCount(); @@ -377,13 +364,6 @@ class VdsVisitor extends VisitorDataHandler implements Visitor { } } - public void onDocumentSummary(DocumentSummary ds) { - if (log.isLoggable(Level.FINEST)) { - log.log(Level.FINEST, "Got DocumentSummary for query with selection " + params.getDocumentSelection()); - } - handleSummary(ds); - } - private void handleSummary(DocumentSummary ds) { int summaryCount = ds.getSummaryCount(); if (log.isLoggable(Level.FINE)) { |