risingwave_stream::executor::backfill::cdc::cdc_backfill

Function transform_upstream

Source 
pub fn transform_upstream(
    upstream: BoxedMessageStream,
    output_columns: Vec<ColumnDesc>,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>