diff options
author | Tor Egge <Tor.Egge@online.no> | 2023-12-07 14:36:53 +0100 |
---|---|---|
committer | Tor Egge <Tor.Egge@online.no> | 2023-12-07 14:36:53 +0100 |
commit | 6fdfffbd6c8e205c67906cc5f7a5df9002be4a27 (patch) | |
tree | 69e9b2cee095783c86c7766674529b37057f4576 /streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp | |
parent | 10a580357998b4c750729f27d3ef2e224dd69af7 (diff) |
Add MultiTerm and InTerm for streaming search.
Diffstat (limited to 'streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp')
-rw-r--r-- | streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp b/streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp index 8805cc5b3ec..6b15b7cb88e 100644 --- a/streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp +++ b/streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp @@ -4,6 +4,7 @@ #include "rankprocessor.h" #include <vespa/searchlib/fef/handle.h> #include <vespa/searchlib/fef/simpletermfielddata.h> +#include <vespa/searchlib/query/streaming/multi_term.h> #include <vespa/searchlib/query/streaming/nearest_neighbor_query_node.h> #include <vespa/vsm/vsm/fieldsearchspec.h> #include <algorithm> @@ -26,6 +27,7 @@ using search::fef::TermFieldMatchData; using search::fef::TermFieldMatchDataPosition; using search::streaming::Hit; using search::streaming::HitList; +using search::streaming::MultiTerm; using search::streaming::Query; using search::streaming::QueryTerm; using search::streaming::QueryTermList; @@ -273,6 +275,10 @@ RankProcessor::unpack_match_data(uint32_t docid, MatchData &matchData, QueryWrap tmd->setRawScore(docid, raw_score.value()); } } + } else if (auto multi_term = term.getTerm()->as_multi_term()) { + auto& qtd = static_cast<QueryTermData &>(term.getTerm()->getQueryItem()); + auto& td = qtd.getTermData(); + multi_term->unpack_match_data(docid, td, matchData); } else if (!term.isPhraseTerm() || term.isFirstPhraseTerm()) { // consider 1 term data per phrase bool isPhrase = term.isFirstPhraseTerm(); QueryTermData & qtd = static_cast<QueryTermData &>(term.getTerm()->getQueryItem()); |