Struct ChangelogRecord 

pub struct ChangelogRecord {
    pub operation: CdcOperation,
    pub weight: i32,
    pub emit_timestamp: i64,
    pub event: Event,
}

A changelog record with Z-set weight for CDC pipelines.

This wraps an event with metadata needed for change data capture:

• Operation type (insert/delete/update)
• Z-set weight (+1/-1)
• Timestamp of the change

Used by EmitStrategy::Changelog to emit structured change records that can be consumed by downstream systems expecting CDC format.

Example

use laminar_core::operator::window::{ChangelogRecord, CdcOperation};
use laminar_core::operator::Event;

// Create an insert record
let record = ChangelogRecord::insert(event, 1000);
assert_eq!(record.operation, CdcOperation::Insert);
assert_eq!(record.weight, 1);

// Create a retraction pair for an update
let (before, after) = ChangelogRecord::update(old_event, new_event, 1000);
assert_eq!(before.weight, -1);  // Retract old
assert_eq!(after.weight, 1);    // Insert new

Fields

operation: CdcOperation

The CDC operation type

weight: i32

Z-set weight (+1 for insert, -1 for delete)

emit_timestamp: i64

Timestamp when this change was emitted

event: Event

The event data

Implementations

impl ChangelogRecord

pub fn insert(event: Event, emit_timestamp: i64) -> Self

Creates an insert changelog record.

pub fn delete(event: Event, emit_timestamp: i64) -> Self

Creates a delete changelog record.

pub fn update( old_event: Event, new_event: Event, emit_timestamp: i64, ) -> (Self, Self)

Creates an update retraction pair (before and after records).

Returns a tuple of (UpdateBefore, UpdateAfter) records. The first should be emitted before the second to properly retract the old value.

pub fn new(operation: CdcOperation, event: Event, emit_timestamp: i64) -> Self

Creates a changelog record from raw parts.

pub fn is_insert(&self) -> bool

Returns true if this is an insert-type record.

pub fn is_delete(&self) -> bool

Returns true if this is a delete-type record.

Trait Implementations

impl Clone for ChangelogRecord

fn clone(&self) -> ChangelogRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangelogRecord

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

Formats the value using the given formatter.