Struct StreamingAppender 

pub struct StreamingAppender { /* private fields */ }

A streaming appender for buffered, single-label data loading.

Rows are buffered internally and flushed to the underlying BulkWriter when the buffer reaches batch_size. Call finish() to flush remaining rows and commit.

The appender is always created from a Transaction, which owns the session write guard for the appender’s lifetime; the appender itself acquires no guard.

Implementations

impl StreamingAppender

pub async fn append( &mut self, properties: impl Into<HashMap<String, Value>>, ) -> Result<()>

Append a single row of properties.

The row is buffered internally. When the buffer reaches batch_size, it is automatically flushed to the underlying bulk writer.

pub async fn write_batch(&mut self, batch: &RecordBatch) -> Result<()>

Append an Arrow RecordBatch of rows.

Each row in the batch is converted to a property map and buffered. Columns in the batch become property keys; values are converted from Arrow types to Uni Values via arrow_to_value.

pub async fn finish(self) -> Result<BulkStats>

Flush all buffered rows and commit the bulk writer.

Consumes the appender. Returns statistics about the loading operation.

pub async fn abort(self) -> Result<()>

Abort the appender without committing.

Consumes the appender. Discards all buffered rows and rolls back any batches that were already flushed to storage, so no partially loaded rows survive the abort.

Errors

Returns an error if the underlying bulk writer fails to roll back its flushed tables.

pub fn buffered_count(&self) -> usize

Get the number of rows currently buffered (not yet flushed).