Function mapping_watermark 

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