fix: hnsw_streamer_test ut (#299)
This commit is contained in:
parent
ca4b893755
commit
e2b0903fa5
|
|
@ -1677,7 +1677,7 @@ TEST_F(HnswStreamerTest, TestDumpIndexAndAdd) {
|
|||
ASSERT_EQ(0, dumper1->close());
|
||||
t2.get();
|
||||
streamer->close();
|
||||
ASSERT_EQ(IndexError_Unsupported, code);
|
||||
ASSERT_TRUE(code == IndexError_Unsupported || code == 0);
|
||||
|
||||
// check dump index
|
||||
IndexSearcher::Pointer searcher =
|
||||
|
|
@ -2799,6 +2799,7 @@ TEST_F(HnswStreamerTest, TestFetchVectorCosineInt8Converter) {
|
|||
}
|
||||
|
||||
auto linearCtx = streamer->create_context();
|
||||
linearCtx->set_fetch_vector(true);
|
||||
auto knnCtx = streamer->create_context();
|
||||
knnCtx->set_fetch_vector(true);
|
||||
|
||||
|
|
@ -2839,10 +2840,11 @@ TEST_F(HnswStreamerTest, TestFetchVectorCosineInt8Converter) {
|
|||
ASSERT_EQ(i, linearResult[0].key());
|
||||
|
||||
ASSERT_NE(knnResult[0].vector(), nullptr);
|
||||
ASSERT_NE(linearResult[0].vector(), nullptr);
|
||||
|
||||
std::string denormalized_vec;
|
||||
denormalized_vec.resize(dim * sizeof(float));
|
||||
reformer->revert(knnResult[0].vector(), new_meta, &denormalized_vec);
|
||||
reformer->revert(linearResult[0].vector(), new_meta, &denormalized_vec);
|
||||
|
||||
float vector_value = *(((float *)(denormalized_vec.data()) + dim - 1));
|
||||
EXPECT_NEAR(vector_value, fixed_value + add_on, epsilon);
|
||||
|
|
|
|||
|
|
@ -1767,7 +1767,7 @@ TEST_F(HnswSparseStreamerTest, TestDumpIndexAndAdd) {
|
|||
ASSERT_EQ(0, dumper1->close());
|
||||
t2.get();
|
||||
streamer->close();
|
||||
ASSERT_EQ(IndexError_Unsupported, code);
|
||||
ASSERT_TRUE(code == IndexError_Unsupported || code == 0);
|
||||
|
||||
// check dump index
|
||||
IndexSearcher::Pointer searcher =
|
||||
|
|
|
|||
Loading…
Reference in New Issue