risingwave_stream::executor::backfill::cdc::upstream_table::snapshot

Function with_additional_columns

source 
fn with_additional_columns(
    snapshot_chunk: StreamChunk,
    additional_columns: &[ColumnDesc],
    schema_table_name: SchemaTableName,
    database_name: String,
) -> StreamChunk
Expand description

Append additional columns with value as null to the snapshot chunk