Enum Record

pub enum Record<R: Row> {
    Insert {
        new_row: R,
    },
    Delete {
        old_row: R,
    },
    Update {
        old_row: R,
        new_row: R,
    },
}

Generic type to represent a row change.

Variants

Insert

Fields

new_row: R

Delete

Fields

old_row: R

Update

Fields

old_row: R

new_row: R

Implementations

impl<R: Row> Record<R>

pub fn into_rows(self) -> impl Iterator<Item = (Op, R)>

Convert this stream record to one or two rows with corresponding ops.

pub fn to_record_type(&self) -> RecordType

Get record type of this record.

pub fn to_stream_chunk(&self, data_types: &[DataType]) -> StreamChunk

Convert this stream record to a stream chunk containing only 1 or 2 rows.

pub fn as_ref(&self) -> Record<&R>

Convert from &Record<R> to Record<&R>.

Trait Implementations

impl<R: Clone + Row> Clone for Record<R>

fn clone(&self) -> Record<R>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<R: Debug + Row> Debug for Record<R>

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

Formats the value using the given formatter.

impl<R: Copy + Row> Copy for Record<R>