Struct SourceStreamChunkRowWriter

pub struct SourceStreamChunkRowWriter<'a> {
    descs: &'a [SourceColumnDesc],
    builders: &'a mut [ArrayBuilderImpl],
    op_builder: &'a mut Vec<Op>,
    vis_builder: &'a mut BitmapBuilder,
    visible: bool,
    row_meta: Option<MessageMeta<'a>>,
}

SourceStreamChunkRowWriter is responsible to write one or more records to the StreamChunk, where each contains either one row (Insert/Delete) or two rows (Update) that can be written atomically.

Callers are supposed to call one of the insert, delete or update methods to write a record, providing a closure that produces one or two Datums by corresponding SourceColumnDesc. Specifically,

• only columns with SourceColumnType::Normal need to be handled;
• errors for non-primary key columns will be ignored and filled with default value instead;
• other errors will be propagated.

Fields

descs: &'a [SourceColumnDesc]

builders: &'a mut [ArrayBuilderImpl]

op_builder: &'a mut Vec<Op>

vis_builder: &'a mut BitmapBuilder

visible: bool

Whether the rows written by this writer should be visible in output StreamChunk.

row_meta: Option<MessageMeta<'a>>

An optional meta data of the original message.

When this is set by with_meta, it’ll be used to fill the columns of types other than SourceColumnType::Normal.

Implementations

impl<'a> SourceStreamChunkRowWriter<'a>

fn with_meta(self, row_meta: MessageMeta<'a>) -> Self

Set the meta data of the original message for this row writer.

This should always be called except for tests.

fn invisible(self) -> Self

Convert the row writer to invisible row writer.

impl SourceStreamChunkRowWriter<'_>

fn append_op(&mut self, op: Op)

fn do_action<'a, A: OpAction>( &'a mut self, f: impl FnMut(&SourceColumnDesc) -> AccessResult<A::Output<'a>>, ) -> AccessResult<()>

pub fn do_insert<'a, D>( &mut self, f: impl FnMut(&SourceColumnDesc) -> AccessResult<D>, ) -> AccessResult<()>

where D: Into<DatumCow<'a>>,

Write an Insert record to the StreamChunk, with the given fallible closure that produces one Datum by corresponding SourceColumnDesc.

See the struct-level documentation for more details.

pub fn do_delete<'a, D>( &mut self, f: impl FnMut(&SourceColumnDesc) -> AccessResult<D>, ) -> AccessResult<()>

where D: Into<DatumCow<'a>>,

Write a Delete record to the StreamChunk, with the given fallible closure that produces one Datum by corresponding SourceColumnDesc.

See the struct-level documentation for more details.

pub fn do_update<'a, D1, D2>( &mut self, f: impl FnMut(&SourceColumnDesc) -> AccessResult<(D1, D2)>, ) -> AccessResult<()>

where D1: Into<DatumCow<'a>>, D2: Into<DatumCow<'a>>,

Write a Update record to the StreamChunk, with the given fallible closure that produces two Datums as old and new value by corresponding SourceColumnDesc.

See the struct-level documentation for more details.