risingwave_hummock_sdk::table_watermark

Function merge_multiple_new_table_watermarks

source
pub fn merge_multiple_new_table_watermarks(
    table_watermarks_list: impl IntoIterator<Item = HashMap<TableId, TableWatermarks>>,
) -> HashMap<TableId, TableWatermarks>