Enum ChangeEvent 

pub enum ChangeEvent {
    Insert {
        data: Arc<RecordBatch>,
        timestamp: i64,
        sequence: u64,
    },
    Delete {
        data: Arc<RecordBatch>,
        timestamp: i64,
        sequence: u64,
    },
    Update {
        old: Arc<RecordBatch>,
        new: Arc<RecordBatch>,
        timestamp: i64,
        sequence: u64,
    },
    Watermark {
        timestamp: i64,
    },
    Snapshot {
        data: Arc<RecordBatch>,
        timestamp: i64,
        sequence: u64,
    },
}

A change event carrying Arrow data for subscriber delivery.

Each variant includes the minimal data needed for that event type. Data is shared via Arc<RecordBatch> for zero-copy fan-out to multiple subscribers.

Variants

Insert

A new row batch was inserted.

Fields

data: Arc<RecordBatch>

The inserted rows.

timestamp: i64

Event timestamp.

sequence: u64

Sequence number from the notification.

Delete

A row batch was deleted.

Fields

data: Arc<RecordBatch>

The deleted rows.

timestamp: i64

Event timestamp.

sequence: u64

Sequence number from the notification.

Update

A row batch was updated (before + after).

Fields

old: Arc<RecordBatch>

The old row values.

new: Arc<RecordBatch>

The new row values.

timestamp: i64

Event timestamp.

sequence: u64

Sequence number from the notification.

Watermark

Watermark progress (no data).

Fields

timestamp: i64

The new watermark timestamp.

Snapshot

Initial snapshot delivery.

Fields

data: Arc<RecordBatch>

The snapshot rows.

timestamp: i64

Event timestamp.

sequence: u64

Sequence number from the notification.

Implementations

impl ChangeEvent

pub fn insert(data: Arc<RecordBatch>, timestamp: i64, sequence: u64) -> Self

Creates an insert change event.

pub fn delete(data: Arc<RecordBatch>, timestamp: i64, sequence: u64) -> Self

Creates a delete change event.

pub fn update( old: Arc<RecordBatch>, new: Arc<RecordBatch>, timestamp: i64, sequence: u64, ) -> Self

Creates an update change event with old and new values.

pub fn watermark(timestamp: i64) -> Self

Creates a watermark change event.

pub fn snapshot(data: Arc<RecordBatch>, timestamp: i64, sequence: u64) -> Self

Creates a snapshot change event.

pub fn event_type(&self) -> EventType

Returns the EventType for this change event.

pub fn timestamp(&self) -> i64

Returns the event timestamp.

pub fn sequence(&self) -> Option<u64>

Returns the sequence number, or None for watermark events.

pub fn row_count(&self) -> usize

Returns the total number of rows in this event.

For Update events, returns the row count of the new batch. For Watermark, returns 0.

pub fn has_data(&self) -> bool

Returns true if this event carries data rows.

pub fn from_changelog_record(record: &ChangelogRecord, sequence: u64) -> Self

Creates a ChangeEvent from a ChangelogRecord.

Maps CDC operations to subscription event types:

• Insert / UpdateAfter → ChangeEvent::Insert
• Delete / UpdateBefore → ChangeEvent::Delete

Trait Implementations

impl Clone for ChangeEvent

fn clone(&self) -> ChangeEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeEvent

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

Formats the value using the given formatter.