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.

Write Guard

The appender holds the session’s write guard for its entire lifetime (unless created from a Transaction, where the Transaction manages the guard). Only one write context (transaction, bulk writer, or appender) can be active per session at a time. The guard is released on finish(), abort(), or drop().

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. The write guard is released when this method returns (or on error via Drop).

pub fn abort(self)

Abort the appender without committing.

Consumes the appender. Discards all buffered and previously flushed rows. Releases the write guard.

pub fn buffered_count(&self) -> usize

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

Trait Implementations

impl Drop for StreamingAppender

fn drop(&mut self)

Executes the destructor for this type.