Struct raphtory_io::graph_loader::source::json_loader::JsonLinesLoader

pub struct JsonLinesLoader<REC: DeserializeOwned> { /* private fields */ }

A struct that defines the CSV loader with configurable options.

Implementations

impl<REC: DeserializeOwned + Debug + Sync> JsonLinesLoader<REC>

pub fn new(path: PathBuf, regex_filter: Option<Regex>) -> Self

Creates a new CSV loader with the given path.

pub fn load_into_graph<F, G>(&self, g: &G, loader: F) -> Result<(), JsonErr>where REC: DeserializeOwned + Debug, F: Fn(REC, &G) -> Result<(), GraphError> + Send + Sync, G: Sync,

Load data from all JSON files in the directory into a graph.

Arguments

• g - A reference to the graph object where the data should be loaded.
• loader - A closure that takes a deserialized record and the graph object as arguments and adds the record to the graph.

Returns

A Result containing an empty Ok value if the data is loaded successfully.

Errors

An error of type CsvErr is returned if an I/O error occurs while reading the files or parsing the CSV data.

Trait Implementations

impl<REC: Debug + DeserializeOwned> Debug for JsonLinesLoader<REC>

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

Formats the value using the given formatter.