feat: Store the RankedMap into the inner sled tree

This commit is contained in:
Clément Renault 2019-04-16 12:06:40 +02:00
parent b7805fee93
commit ee2bad20c7
No known key found for this signature in database
GPG Key ID: 0151CDAB43460DAE

View File

@ -8,7 +8,7 @@ use meilidb_core::write_to_bytes::WriteToBytes;
use meilidb_core::{DocumentId, Index as WordIndex}; use meilidb_core::{DocumentId, Index as WordIndex};
use sled::IVec; use sled::IVec;
use crate::{Schema, SchemaAttr}; use crate::{Schema, SchemaAttr, RankedMap};
#[derive(Debug)] #[derive(Debug)]
pub enum Error { pub enum Error {
@ -119,14 +119,17 @@ impl Database {
pub struct Index { pub struct Index {
schema: Schema, schema: Schema,
word_index: Arc<ArcSwap<WordIndex>>, word_index: Arc<ArcSwap<WordIndex>>,
ranked_map: Arc<ArcSwap<RankedMap>>,
inner: Arc<sled::Tree>, inner: Arc<sled::Tree>,
} }
impl Index { impl Index {
fn from_raw(inner: Arc<sled::Tree>) -> Result<Index, Error> { fn from_raw(inner: Arc<sled::Tree>) -> Result<Index, Error> {
let schema = {
let bytes = inner.get("schema")?; let bytes = inner.get("schema")?;
let bytes = bytes.ok_or(Error::SchemaMissing)?; let bytes = bytes.ok_or(Error::SchemaMissing)?;
let schema = Schema::read_from_bin(bytes.as_ref())?; Schema::read_from_bin(bytes.as_ref())?
};
let bytes = inner.get("word-index")?; let bytes = inner.get("word-index")?;
let bytes = bytes.ok_or(Error::WordIndexMissing)?; let bytes = bytes.ok_or(Error::WordIndexMissing)?;
@ -141,7 +144,16 @@ impl Index {
Arc::new(ArcSwap::new(Arc::new(word_index))) Arc::new(ArcSwap::new(Arc::new(word_index)))
}; };
Ok(Index { schema, word_index, inner }) let ranked_map = {
let map = match inner.get("ranked-map")? {
Some(bytes) => bincode::deserialize(bytes.as_ref())?,
None => RankedMap::default(),
};
Arc::new(ArcSwap::new(Arc::new(map)))
};
Ok(Index { schema, word_index, ranked_map, inner })
} }
fn new_from_raw(inner: Arc<sled::Tree>, schema: Schema) -> Result<Index, Error> { fn new_from_raw(inner: Arc<sled::Tree>, schema: Schema) -> Result<Index, Error> {
@ -153,7 +165,9 @@ impl Index {
inner.set("word-index", word_index.into_bytes())?; inner.set("word-index", word_index.into_bytes())?;
let word_index = Arc::new(ArcSwap::new(Arc::new(word_index))); let word_index = Arc::new(ArcSwap::new(Arc::new(word_index)));
Ok(Index { schema, word_index, inner }) let ranked_map = Arc::new(ArcSwap::new(Arc::new(RankedMap::default())));
Ok(Index { schema, word_index, ranked_map, inner })
} }
pub fn schema(&self) -> &Schema { pub fn schema(&self) -> &Schema {
@ -164,10 +178,18 @@ impl Index {
self.word_index.lease() self.word_index.lease()
} }
pub fn ranked_map(&self) -> Lease<Arc<RankedMap>> {
self.ranked_map.lease()
}
fn update_word_index(&self, word_index: Arc<WordIndex>) { fn update_word_index(&self, word_index: Arc<WordIndex>) {
self.word_index.store(word_index) self.word_index.store(word_index)
} }
fn update_ranked_map(&self, ranked_map: Arc<RankedMap>) {
self.ranked_map.store(ranked_map)
}
pub fn set_document_attribute<V>( pub fn set_document_attribute<V>(
&self, &self,
id: DocumentId, id: DocumentId,