Struct BatchBuilder 

pub struct BatchBuilder { /* private fields */ }

Batch builder for accumulating operations

Implementations

impl BatchBuilder

pub fn new(config: BatchBuilderConfig) -> Self

Create a new batch builder

pub fn auto() -> Self

Create a batch builder with automatic configuration

pub fn on_flush<F>(&mut self, callback: F)

where F: Fn(Vec<BatchOperation>) + Send + Sync + 'static,

Set a callback to be called when batches are flushed

pub fn insert(&mut self, triple: Triple) -> Result<(), OxirsError>

Add an insert operation

pub fn insert_batch(&mut self, triples: Vec<Triple>) -> Result<(), OxirsError>

Add multiple insert operations

pub fn remove(&mut self, triple: Triple) -> Result<(), OxirsError>

Add a remove operation

pub fn query( &mut self, subject: Option<Subject>, predicate: Option<Predicate>, object: Option<Object>, ) -> Result<(), OxirsError>

Add a query operation

pub fn transform<F>(&mut self, f: F) -> Result<(), OxirsError>

where F: Fn(&Triple) -> Option<Triple> + Send + Sync + 'static,

Add a transform operation

pub fn stats(&self) -> &BatchBuilderStats

Get current statistics

pub fn pending_operations(&self) -> usize

Get the current number of pending operations

pub fn flush(&mut self) -> Result<Vec<BatchOperation>, OxirsError>

Flush all pending operations into batch operations