snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-10-02 09:46:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

update to the latest version of cellulite and steppe

Browse Source
This commit is contained in:
Tamo
2025-07-22 16:24:49 +02:00
parent c0905d6650
commit d19892d2ea
9 changed files with 13 additions and 135 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
crates/milli/src/update/index_documents/mod.rs
View File

@@ -542,8 +542,7 @@ where
}
tracing::warn!("Building cellulite");
let cellulite = cellulite::Cellulite::new(self.index.cellulite);
cellulite.build(self.wtxn, &Progress::default())?;
self.index.cellulite.build(self.wtxn, &Progress::default())?;
self.execute_prefix_databases(
word_docids.map(MergerBuilder::build),

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

@@ -629,8 +629,6 @@ pub(crate) fn write_typed_chunk_into_index(
}
let merger = builder.build();
let cellulite = cellulite::Cellulite::new(index.cellulite);
let mut iter = merger.into_stream_merger_iter()?;
while let Some((key, value)) = iter.next()? {
// convert the key back to a u32 (4 bytes)
@@ -639,14 +637,14 @@ pub(crate) fn write_typed_chunk_into_index(
let deladd_obkv = KvReaderDelAdd::from_slice(value);
if let Some(_value) = deladd_obkv.get(DelAdd::Deletion) {
cellulite.delete(wtxn, docid)?;
index.cellulite.delete(wtxn, docid)?;
}
if let Some(value) = deladd_obkv.get(DelAdd::Addition) {
tracing::warn!("Adding one geojson to cellulite");
let geojson =
geojson::GeoJson::from_reader(value).map_err(UserError::SerdeJson)?;
cellulite
index.cellulite
.add(wtxn, docid, &geojson)
.map_err(InternalError::CelluliteError)?;
}