diff --git a/rust/index/src/fulltext/types.rs b/rust/index/src/fulltext/types.rs index 8468b6c3148..e836eb668bd 100644 --- a/rust/index/src/fulltext/types.rs +++ b/rust/index/src/fulltext/types.rs @@ -325,7 +325,7 @@ impl<'me> FullTextIndexReader<'me> { .then(|token| async move { let positional_posting_list = self .posting_lists_blockfile_reader - .get_range(token.text.as_str()..=token.text.as_str(), ..) + .get_prefix(token.text.as_str()) .await? .collect::>(); Ok::<_, FullTextIndexError>(positional_posting_list) @@ -346,7 +346,7 @@ impl<'me> FullTextIndexReader<'me> { .enumerate() .map(|(i, posting_list)| { if pointers[i] < posting_list.len() { - Some(posting_list[pointers[i]].1) + Some(posting_list[pointers[i]].0) } else { None } @@ -372,7 +372,7 @@ impl<'me> FullTextIndexReader<'me> { // Seed with the positions of the first token. let mut adjusted = posting_lists[0][pointers[0]] - .2 + .1 .iter() .copied() .collect::>(); @@ -380,7 +380,7 @@ impl<'me> FullTextIndexReader<'me> { for i in 1..num_tokens { let byte_delta_from_first_token = tokens[i].offset_from as u32 - tokens[0].offset_from as u32; - let positions = &posting_lists[i][pointers[i]].2; + let positions = &posting_lists[i][pointers[i]].1; let shifted = positions .iter() @@ -424,10 +424,10 @@ impl<'me> FullTextIndexReader<'me> { ) -> Result)>, FullTextIndexError> { let positional_posting_list = self .posting_lists_blockfile_reader - .get_range(token..=token, ..) + .get_prefix(token) .await?; let mut results = vec![]; - for (_, doc_id, positions) in positional_posting_list { + for (doc_id, positions) in positional_posting_list { results.push((doc_id, positions.to_vec())); } Ok(results)