Struct InvertedIndex 

pub struct InvertedIndex { /* private fields */ }

Term-to-VID inverted index for efficient set-membership queries.

Supports both full rebuilds from a vertex dataset and incremental updates for optimal performance during small mutations.

Implementations

impl InvertedIndex

pub async fn new( base_uri: &str, config: InvertedIndexConfig, ) -> Result<InvertedIndex, Error>

Open or initialize an inverted index at base_uri for the given config.

pub async fn build_from_dataset( &mut self, vertex_dataset: &VertexDataset, progress: impl Fn(usize), ) -> Result<(), Error>

Rebuild the index from scratch by scanning vertex_dataset.

Calls progress every 10 000 vertices with the running document count. Uses segmented accumulation to stay within the 256 MB memory limit.

pub async fn query_any(&self, terms: &[String]) -> Result<Vec<Vid>, Error>

Return all VIDs whose term list intersects terms (OR semantics).

pub async fn apply_incremental_updates( &mut self, added: &HashMap<Vid, Vec<String>>, removed: &HashSet<Vid>, ) -> Result<(), Error>

Applies incremental updates to the inverted index.

This method efficiently updates the index by:

1. Loading existing postings
2. Removing VIDs that have been deleted
3. Adding new VIDs with their associated terms
4. Writing the updated postings back

Errors

Returns an error if loading or writing postings fails.

pub fn extract_terms_from_value(&self, value: &Value) -> Option<Vec<String>>

Extracts terms from a JSON value representing a List<String>.

Returns None if the value is not an array of strings.

pub fn is_initialized(&self) -> bool

Returns true if the index dataset exists.

pub fn property(&self) -> &str

Returns the property name this index is built on.

Trait Implementations

impl Debug for InvertedIndex

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.