Struct ChangelogBatch 

pub struct ChangelogBatch { /* private fields */ }

A typed changelog envelope over a plain Arrow RecordBatch.

Append-only SQL stays as Source<RecordBatch>. This type is only used once a source or operator can emit retractions.

Implementations

impl ChangelogBatch

pub fn try_new(ops: Vec<ChangeOp>, batch: RecordBatch) -> Result<Self>

Builds a changelog batch and validates that row operations match the payload row count and update-pair adjacency rules.

pub fn insert_only(batch: RecordBatch) -> Self

Wraps an append-only Arrow batch as insert-only changelog data.

pub fn ops(&self) -> &[ChangeOp]

Returns the row-level changelog operations.

pub fn batch(&self) -> &RecordBatch

Returns the Arrow payload batch.

pub fn num_rows(&self) -> usize

Returns the number of rows in the payload batch.

pub fn is_insert_only(&self) -> bool

Returns true when every row is an insert.

Trait Implementations

impl Clone for ChangelogBatch

fn clone(&self) -> ChangelogBatch

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ChangelogBatch

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

Formats the value using the given formatter.

impl SqlEventPayload for ChangelogBatch

fn event_time_batch(&self) -> &RecordBatch

Returns the Arrow batch containing the configured event-time column.

fn event_time_partition(&self, _row: usize) -> Option<i64>

Partition identity for one row within this source.

fn event_time_active_partitions(&self) -> Option<Vec<i64>>

Partitions that can still produce rows for this source.