risingwave_stream::executor::backfill::utils

Function mapping_watermark

source 
fn mapping_watermark(
    watermark: Watermark,
    upstream_indices: &[usize],
) -> Option<Watermark>