Skip to main content

write_rows

surreal_sync_runtime::pipeline

Function write_rows 

Source 
pub async fn write_rows<S: SurrealSink>(
    sink: &S,
    pipeline: &Pipeline,
    rows: Vec<Row>,
    opts: &ApplyOpts,
) -> Result<()>
Expand description

Transform then sink rows via the same overlapping ApplyContext window as CDC. Shared by full sync and snapshot flushes.

Rows become upsert Changes and honor max_in_flight / batch_size. Homogeneous upsert batches coalesce to SurrealSink::write_rows inside the ordered sink step.