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

Function transform_upstream

source 
pub fn transform_upstream<'_async0>(
    upstream: BoxedMessageStream,
    output_columns: &'_async0 [ColumnDesc],
) -> impl Stream<Item = Result<Message, StreamExecutorError>> + '_async0