Struct StreamingResolver 

pub struct StreamingResolver { /* private fields */ }

Streaming entity resolver using the Doubling Algorithm.

Implementations

impl StreamingResolver

pub fn new(config: StreamingConfig) -> Self

Create a new streaming resolver.

pub fn add_mention(&mut self, mention: EntityMention) -> IdentityId

Add an entity mention to the resolver.

This is the main entry point for streaming entity resolution. Returns the cluster ID that the mention was added to.

pub fn add_entity( &mut self, doc_id: impl Into<String>, surface: impl Into<String>, entity_type: Option<String>, ) -> IdentityId

Add an entity with simple parameters.

pub fn clusters(&self) -> Vec<&EntityCluster>

Get all current clusters.

pub fn get_cluster(&self, id: IdentityId) -> Option<&EntityCluster>

Get a cluster by ID.

pub fn num_clusters(&self) -> usize

Get the number of clusters.

pub fn num_mentions(&self) -> usize

Get the total number of mentions processed.

pub fn merge_clusters(&mut self)

Manually trigger cluster merging.

impl StreamingResolver

pub fn to_identities(&self) -> Vec<Identity>

Convert all clusters to anno_core::Identity objects.

Returns a vector of Identities representing the current clustering state. Useful for exporting streaming resolution results into the anno::core format.

pub fn add_track( &mut self, doc_id: impl Into<String>, track: &Track, ) -> IdentityId

Add entities from a Track.

Convenience method that extracts relevant information from an anno_core::Track and adds it to the resolver.

Trait Implementations

impl Debug for StreamingResolver

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

Formats the value using the given formatter.

impl Default for StreamingResolver

fn default() -> Self

Returns the “default value” for a type.