Struct ChangeRows 

pub struct ChangeRows {
    pub upserts: Vec<RecordBatch>,
    pub deletes: Vec<RecordBatch>,
}

A changelog batch split by its SyncMode::CHANGE_TYPE_COLUMN into the rows that upsert vs. the rows that delete, both with the _change_type column stripped so they render like ordinary table rows.

INSERT / UPDATE_AFTER → upserts; DELETE → deletes. UPDATE_BEFORE is dropped: it is the pre-image of an in-place update whose UPDATE_AFTER upsert overwrites the node, so emitting a delete for it would destroy the updated row (deletes are applied last in the sink). An unknown change type is a hard error (better than silently dropping a row).

Fields

upserts: Vec<RecordBatch>

Rows to feed the upsert pipeline (vertices + edges).

deletes: Vec<RecordBatch>

Rows that name nodes to remove.

Implementations

impl ChangeRows

pub fn is_empty(&self) -> bool

Trait Implementations

impl Debug for ChangeRows

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ChangeRows

fn default() -> Self

Returns the “default value” for a type.