aboutsummaryrefslogtreecommitdiffstats
path: root/streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2024-02-11 13:18:09 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2024-02-11 13:21:19 +0000
commitab2e746543da87d457efd5029ae1b6cdca311fc1 (patch)
tree274df998b040f0fcbdd3f1f0807759cf0c0ae372 /streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp
parent9dbe7cde3cbdbebccfa89ff6ae0daa8143591fab (diff)
It is know up front that if we sort by rank or by sortblob. So instead of detecting by first hit,
and hoping the rest are the same, set expectations ahead and assert all hits are correct.
Diffstat (limited to 'streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp')
-rw-r--r--streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp b/streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp
index a54d2adee78..ff47b5cb9d4 100644
--- a/streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp
+++ b/streamingvisitors/src/vespa/searchvisitor/rankprocessor.cpp
@@ -133,9 +133,9 @@ RankProcessor::initQueryEnvironment()
}
void
-RankProcessor::initHitCollector(size_t wantedHitCount)
+RankProcessor::initHitCollector(size_t wantedHitCount, bool use_sort_blob)
{
- _hitCollector = std::make_unique<HitCollector>(wantedHitCount);
+ _hitCollector = std::make_unique<HitCollector>(wantedHitCount, use_sort_blob);
}
void
@@ -145,7 +145,7 @@ RankProcessor::setupRankProgram(RankProgram &program)
}
void
-RankProcessor::init(bool forRanking, size_t wantedHitCount)
+RankProcessor::init(bool forRanking, size_t wantedHitCount, bool use_sort_blob)
{
initQueryEnvironment();
if (forRanking) {
@@ -167,7 +167,7 @@ RankProcessor::init(bool forRanking, size_t wantedHitCount)
_rankProgram = _rankSetup.create_dump_program();
setupRankProgram(*_rankProgram);
}
- initHitCollector(wantedHitCount);
+ initHitCollector(wantedHitCount, use_sort_blob);
}
RankProcessor::RankProcessor(std::shared_ptr<const RankManager::Snapshot> snapshot,
@@ -197,15 +197,15 @@ RankProcessor::RankProcessor(std::shared_ptr<const RankManager::Snapshot> snapsh
}
void
-RankProcessor::initForRanking(size_t wantedHitCount)
+RankProcessor::initForRanking(size_t wantedHitCount, bool use_sort_blob)
{
- return init(true, wantedHitCount);
+ return init(true, wantedHitCount, use_sort_blob);
}
void
RankProcessor::initForDumping(size_t wantedHitCount)
{
- return init(false, wantedHitCount);
+ return init(false, wantedHitCount, false);
}
void