snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2024-11-27 04:25:06 +08:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Reduce the ram consumption when re-indexing all the documents

Browse Source
This commit is contained in:
Clément Renault 2019-10-29 17:46:23 +01:00
parent 41065305aa
commit 4dff8a215e
No known key found for this signature in database
GPG Key ID: 92ADA4E935E71FA4
1 changed files with 43 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

82
meilidb-core/src/update/documents_addition.rs
View File

@ -150,7 +150,7 @@ pub fn apply_documents_addition(
main_store, main_store,
postings_lists_store, postings_lists_store,
docs_words_store, docs_words_store,
ranked_map, &ranked_map,
number_of_inserted_documents, number_of_inserted_documents,
indexer, indexer,
) )
@ -179,54 +179,58 @@ pub fn reindex_all_documents(
} }
// 2. remove the documents posting lists // 2. remove the documents posting lists
let number_of_inserted_documents = documents_ids_to_reindex.len();
main_store.put_words_fst(writer, &fst::Set::default())?; main_store.put_words_fst(writer, &fst::Set::default())?;
main_store.put_ranked_map(writer, &ranked_map)?; main_store.put_ranked_map(writer, &ranked_map)?;
main_store.put_number_of_documents(writer, |_| 0)?; main_store.put_number_of_documents(writer, |_| 0)?;
postings_lists_store.clear(writer)?; postings_lists_store.clear(writer)?;
docs_words_store.clear(writer)?; docs_words_store.clear(writer)?;
let stop_words = match main_store.stop_words_fst(writer)? { // 3. re-index chunks of documents (otherwise we make the borrow checker unhappy)
Some(stop_words) => stop_words, for documents_ids in documents_ids_to_reindex.chunks(100) {
None => fst::Set::default(), let stop_words = match main_store.stop_words_fst(writer)? {
}; Some(stop_words) => stop_words,
None => fst::Set::default(),
};
// 3. re-index one document by one document (otherwise we make the borrow checker unhappy) let number_of_inserted_documents = documents_ids.len();
let mut indexer = RawIndexer::new(stop_words); let mut indexer = RawIndexer::new(stop_words);
let mut ram_store = HashMap::new(); let mut ram_store = HashMap::new();
for document_id in documents_ids_to_reindex { for document_id in documents_ids {
for result in documents_fields_store.document_fields(writer, document_id)? { for result in documents_fields_store.document_fields(writer, *document_id)? {
let (attr, bytes) = result?; let (attr, bytes) = result?;
let value: serde_json::Value = serde_json::from_slice(bytes)?; let value: serde_json::Value = serde_json::from_slice(bytes)?;
ram_store.insert((document_id, attr), value); ram_store.insert((document_id, attr), value);
}
for ((docid, attr), value) in ram_store.drain() {
serialize_value(
writer,
attr,
schema.props(attr),
*docid,
documents_fields_store,
documents_fields_counts_store,
&mut indexer,
&mut ranked_map,
&value,
)?;
}
} }
for ((docid, attr), value) in ram_store.drain() { // 4. write the new index in the main store
serialize_value( write_documents_addition_index(
writer, writer,
attr, main_store,
schema.props(attr), postings_lists_store,
docid, docs_words_store,
documents_fields_store, &ranked_map,
documents_fields_counts_store, number_of_inserted_documents,
&mut indexer, indexer,
&mut ranked_map, )?;
&value,
)?;
}
} }
// 4. write the new index in the main store Ok(())
write_documents_addition_index(
writer,
main_store,
postings_lists_store,
docs_words_store,
ranked_map,
number_of_inserted_documents,
indexer,
)
} }
pub fn write_documents_addition_index( pub fn write_documents_addition_index(
@ -234,7 +238,7 @@ pub fn write_documents_addition_index(
main_store: store::Main, main_store: store::Main,
postings_lists_store: store::PostingsLists, postings_lists_store: store::PostingsLists,
docs_words_store: store::DocsWords, docs_words_store: store::DocsWords,
ranked_map: RankedMap, ranked_map: &RankedMap,
number_of_inserted_documents: usize, number_of_inserted_documents: usize,
indexer: RawIndexer, indexer: RawIndexer,
) -> MResult<()> { ) -> MResult<()> {
@ -279,7 +283,7 @@ pub fn write_documents_addition_index(
}; };
main_store.put_words_fst(writer, &words)?; main_store.put_words_fst(writer, &words)?;
main_store.put_ranked_map(writer, &ranked_map)?; main_store.put_ranked_map(writer, ranked_map)?;
main_store.put_number_of_documents(writer, |old| old + number_of_inserted_documents as u64)?; main_store.put_number_of_documents(writer, |old| old + number_of_inserted_documents as u64)?;
Ok(()) Ok(())