snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-09-18 18:56:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

style improvement

Browse Source
This commit is contained in:
Tamo
2025-09-17 17:03:34 +02:00
parent 501e3816a8
commit 6e6fdb70a3
2 changed files with 6 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
crates/milli/src/index.rs
View File

@ -1896,7 +1896,7 @@ impl Index {
field_id_docid_facet_strings, field_id_docid_facet_strings,
vector_store, vector_store,
embedder_category_id, embedder_category_id,
cellulite: _, cellulite,
documents, documents,
} = self; } = self;
@ -1976,13 +1976,10 @@ impl Index {
panic!("Cellulite database count has changed, please update the code accordingly.") panic!("Cellulite database count has changed, please update the code accordingly.")
} }
}; };
sizes.insert("cellulite_item", self.cellulite.item_db_stats(rtxn).map(compute_size)?); sizes.insert("cellulite_item", cellulite.item_db_stats(rtxn).map(compute_size)?);
sizes.insert("cellulite_cell", self.cellulite.cell_db_stats(rtxn).map(compute_size)?); sizes.insert("cellulite_cell", cellulite.cell_db_stats(rtxn).map(compute_size)?);
sizes.insert("cellulite_update", self.cellulite.update_db_stats(rtxn).map(compute_size)?); sizes.insert("cellulite_update", cellulite.update_db_stats(rtxn).map(compute_size)?);
sizes.insert( sizes.insert("cellulite_metadata", cellulite.metadata_db_stats(rtxn).map(compute_size)?);
"cellulite_metadata",
self.cellulite.metadata_db_stats(rtxn).map(compute_size)?,
);
Ok(sizes) Ok(sizes)
} }

8
crates/milli/src/update/index_documents/typed_chunk.rs
View File

@ -632,7 +632,6 @@ pub(crate) fn write_typed_chunk_into_index(
let mut iter = merger.into_stream_merger_iter()?; let mut iter = merger.into_stream_merger_iter()?;
while let Some((key, value)) = iter.next()? { while let Some((key, value)) = iter.next()? {
// convert the key back to a u32 (4 bytes) // convert the key back to a u32 (4 bytes)
tracing::warn!("Key: {:?}, length: {}", key, key.len());
let docid = key.try_into().map(DocumentId::from_be_bytes).unwrap(); let docid = key.try_into().map(DocumentId::from_be_bytes).unwrap();
let deladd_obkv = KvReaderDelAdd::from_slice(value); let deladd_obkv = KvReaderDelAdd::from_slice(value);
@ -640,14 +639,9 @@ pub(crate) fn write_typed_chunk_into_index(
index.cellulite.delete(wtxn, docid)?; index.cellulite.delete(wtxn, docid)?;
} }
if let Some(value) = deladd_obkv.get(DelAdd::Addition) { if let Some(value) = deladd_obkv.get(DelAdd::Addition) {
tracing::warn!("Adding one geojson to cellulite");
let geojson = let geojson =
geojson::GeoJson::from_reader(value).map_err(UserError::SerdeJson)?; geojson::GeoJson::from_reader(value).map_err(UserError::SerdeJson)?;
index index.cellulite.add(wtxn, docid, &geojson)?;
.cellulite
.add(wtxn, docid, &geojson)
.map_err(InternalError::CelluliteError)?;
} }
} }
} }