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

Function transform_upstream

Source 
pub fn transform_upstream(
    upstream: BoxedMessageStream,
    output_columns: Vec<ColumnDesc>,
    timestamp_handling: Option<TimestampHandling>,
    timestamptz_handling: Option<TimestamptzHandling>,
    time_handling: Option<TimeHandling>,
    handle_toast_columns: bool,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>