Struct AqlGraphLoader 

pub struct AqlGraphLoader { /* private fields */ }

AQL-based graph loader

Implementations

impl AqlGraphLoader

pub fn new( db_config: DatabaseConfiguration, batch_size: u64, vertex_attributes: Vec<DataItem>, edge_attributes: Vec<DataItem>, queries: Vec<Vec<AqlQuery>>, max_type_errors: Option<u64>, ) -> Result<Self, GraphLoaderError>

Create a new AQL graph loader

Arguments

• db_config - Database configuration
• batch_size - Size of batches to fetch from the database
• vertex_attributes - List of vertex attributes to load with their types
• edge_attributes - List of edge attributes to load with their types
• queries - Nested list of AQL queries (outer list = sequential, inner list = parallel)
• max_type_errors - Maximum number of type error messages to collect per GraphBatch
  • None (recommended default): All type errors are reported
  • Some(n): At most n type error messages are collected per GraphBatch (can be 0)

pub async fn do_load<F>(&self, callback: F) -> Result<(), GraphLoaderError>

where F: Fn(&mut GraphBatch) -> Result<(), GraphLoaderError> + Send + Sync + Clone + 'static,

Execute all AQL queries and call the provided callback with vertices and edges