mirror of
https://github.com/meilisearch/MeiliSearch
synced 2025-07-03 20:07:09 +02:00
feat: Change updates to be handled using the RocksDB WriteBatch feature
This commit is contained in:
parent
0d2daf27f2
commit
1bfd51d6e9
12 changed files with 289 additions and 840 deletions
|
@ -11,7 +11,7 @@ use std::fs::File;
|
|||
use serde_derive::{Serialize, Deserialize};
|
||||
use structopt::StructOpt;
|
||||
|
||||
use meilidb::database::{Database, Schema, UpdateBuilder};
|
||||
use meilidb::database::{Database, Schema};
|
||||
use meilidb::tokenizer::DefaultBuilder;
|
||||
|
||||
#[derive(Debug, StructOpt)]
|
||||
|
@ -61,8 +61,7 @@ fn index(
|
|||
|
||||
while !end_of_file {
|
||||
let tokenizer_builder = DefaultBuilder::new();
|
||||
let update_path = tempfile::NamedTempFile::new()?;
|
||||
let mut update = UpdateBuilder::new(update_path.path().to_path_buf(), schema.clone());
|
||||
let mut update = database.update()?;
|
||||
|
||||
loop {
|
||||
end_of_file = !rdr.read_record(&mut raw_record)?;
|
||||
|
@ -88,10 +87,8 @@ fn index(
|
|||
|
||||
println!();
|
||||
|
||||
println!("building update...");
|
||||
let update = update.build()?;
|
||||
println!("ingesting update...");
|
||||
database.ingest_update_file(update)?;
|
||||
println!("committing update...");
|
||||
update.commit()?;
|
||||
}
|
||||
|
||||
Ok(database)
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue