snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-26 12:05:05 +08:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

Merge pull request #56 from meilisearch/asc-desc-criteria-non-faceted

Browse Source 
Return non-faceted documents to complete the requested limit
This commit is contained in:
Clément Renault 2020-12-17 14:34:36 +01:00 committed by GitHub
commit b032ceb5d4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 27 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/search/mod.rs
View File

@ -156,18 +156,16 @@ impl<'a> Search<'a> {
field_id: FieldId, field_id: FieldId,
facet_type: FacetType, facet_type: FacetType,
ascending: bool, ascending: bool,
documents_ids: RoaringBitmap, mut documents_ids: RoaringBitmap,
limit: usize, limit: usize,
) -> anyhow::Result<Vec<DocumentId>> ) -> anyhow::Result<Vec<DocumentId>>
{ {
let mut limit_tmp = limit; let mut output: Vec<_> = match facet_type {
let mut output = Vec::new();
match facet_type {
FacetType::Float => { FacetType::Float => {
if documents_ids.len() <= 1000 { if documents_ids.len() <= 1000 {
let db = self.index.field_id_docid_facet_values.remap_key_type::<FieldDocIdFacetF64Codec>(); let db = self.index.field_id_docid_facet_values.remap_key_type::<FieldDocIdFacetF64Codec>();
let mut docids_values = Vec::with_capacity(documents_ids.len() as usize); let mut docids_values = Vec::with_capacity(documents_ids.len() as usize);
for docid in documents_ids { for docid in documents_ids.iter() {
let left = (field_id, docid, f64::MIN); let left = (field_id, docid, f64::MIN);
let right = (field_id, docid, f64::MAX); let right = (field_id, docid, f64::MAX);
let mut iter = db.range(self.rtxn, &(left..=right))?; let mut iter = db.range(self.rtxn, &(left..=right))?;
@ -179,9 +177,9 @@ impl<'a> Search<'a> {
docids_values.sort_unstable_by_key(|(_, value)| *value); docids_values.sort_unstable_by_key(|(_, value)| *value);
let iter = docids_values.into_iter().map(|(id, _)| id); let iter = docids_values.into_iter().map(|(id, _)| id);
if ascending { if ascending {
Ok(iter.take(limit).collect()) iter.take(limit).collect()
} else { } else {
Ok(iter.rev().take(limit).collect()) iter.rev().take(limit).collect()
} }
} else { } else {
let facet_fn = if ascending { let facet_fn = if ascending {
@ -189,20 +187,22 @@ impl<'a> Search<'a> {
} else { } else {
FacetIter::<f64, FacetLevelValueF64Codec>::new_reverse FacetIter::<f64, FacetLevelValueF64Codec>::new_reverse
}; };
for result in facet_fn(self.rtxn, self.index, field_id, documents_ids)? { let mut limit_tmp = limit;
let mut output = Vec::new();
for result in facet_fn(self.rtxn, self.index, field_id, documents_ids.clone())? {
let (_val, docids) = result?; let (_val, docids) = result?;
limit_tmp = limit_tmp.saturating_sub(docids.len() as usize); limit_tmp = limit_tmp.saturating_sub(docids.len() as usize);
output.push(docids); output.push(docids);
if limit_tmp == 0 { break } if limit_tmp == 0 { break }
} }
Ok(output.into_iter().flatten().take(limit).collect()) output.into_iter().flatten().take(limit).collect()
} }
}, },
FacetType::Integer => { FacetType::Integer => {
if documents_ids.len() <= 1000 { if documents_ids.len() <= 1000 {
let db = self.index.field_id_docid_facet_values.remap_key_type::<FieldDocIdFacetI64Codec>(); let db = self.index.field_id_docid_facet_values.remap_key_type::<FieldDocIdFacetI64Codec>();
let mut docids_values = Vec::with_capacity(documents_ids.len() as usize); let mut docids_values = Vec::with_capacity(documents_ids.len() as usize);
for docid in documents_ids { for docid in documents_ids.iter() {
let left = (field_id, docid, i64::MIN); let left = (field_id, docid, i64::MIN);
let right = (field_id, docid, i64::MAX); let right = (field_id, docid, i64::MAX);
let mut iter = db.range(self.rtxn, &(left..=right))?; let mut iter = db.range(self.rtxn, &(left..=right))?;
@ -214,9 +214,9 @@ impl<'a> Search<'a> {
docids_values.sort_unstable_by_key(|(_, value)| *value); docids_values.sort_unstable_by_key(|(_, value)| *value);
let iter = docids_values.into_iter().map(|(id, _)| id); let iter = docids_values.into_iter().map(|(id, _)| id);
if ascending { if ascending {
Ok(iter.take(limit).collect()) iter.take(limit).collect()
} else { } else {
Ok(iter.rev().take(limit).collect()) iter.rev().take(limit).collect()
} }
} else { } else {
let facet_fn = if ascending { let facet_fn = if ascending {
@ -224,17 +224,30 @@ impl<'a> Search<'a> {
} else { } else {
FacetIter::<i64, FacetLevelValueI64Codec>::new_reverse FacetIter::<i64, FacetLevelValueI64Codec>::new_reverse
}; };
for result in facet_fn(self.rtxn, self.index, field_id, documents_ids)? { let mut limit_tmp = limit;
let mut output = Vec::new();
for result in facet_fn(self.rtxn, self.index, field_id, documents_ids.clone())? {
let (_val, docids) = result?; let (_val, docids) = result?;
limit_tmp = limit_tmp.saturating_sub(docids.len() as usize); limit_tmp = limit_tmp.saturating_sub(docids.len() as usize);
output.push(docids); output.push(docids);
if limit_tmp == 0 { break } if limit_tmp == 0 { break }
} }
Ok(output.into_iter().flatten().take(limit).collect()) output.into_iter().flatten().take(limit).collect()
} }
}, },
FacetType::String => bail!("criteria facet type must be a number"), FacetType::String => bail!("criteria facet type must be a number"),
};
// if there isn't enough documents to return we try to complete that list
// with documents that are maybe not faceted under this field and therefore
// not returned by the previous facet iteration.
if output.len() < limit {
output.iter().for_each(|n| { documents_ids.remove(*n); });
let remaining = documents_ids.iter().take(limit - output.len());
output.extend(remaining);
} }
Ok(output)
} }
pub fn execute(&self) -> anyhow::Result<SearchResult> { pub fn execute(&self) -> anyhow::Result<SearchResult> {