Struct StreamingGraphRelationLoader 

pub struct StreamingGraphRelationLoader { /* private fields */ }

Streaming loader for typed biomedical graph relation rows.

Implementations

impl StreamingGraphRelationLoader

pub fn new(format: GraphInputFormat) -> Self

Create a loader for the given input format.

pub fn with_chunk_rows(self, chunk_rows: usize) -> Self

Set the maximum number of rows accounted to a single streaming chunk.

pub fn load_path( &self, path: impl AsRef<Path>, ) -> Result<GraphRelationLoadReport>

Stream a graph file and return provenance and histogram telemetry.

pub fn load_path_with_sink( &self, path: impl AsRef<Path>, sink: impl FnMut(GraphEdgeRow), ) -> Result<GraphRelationLoadReport>

Stream a graph file into a caller-provided edge sink and return telemetry.

Trait Implementations

impl Clone for StreamingGraphRelationLoader

fn clone(&self) -> StreamingGraphRelationLoader

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamingGraphRelationLoader

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

Formats the value using the given formatter.