risingwave_stream::executor::backfill::utils

Function mapping_message

source
pub(crate) fn mapping_message(
    msg: Message,
    upstream_indices: &[usize],
) -> Option<Message>