risingwave_stream::from_proto::agg_common

Function build_distinct_dedup_table_from_proto

Source 
pub async fn build_distinct_dedup_table_from_proto<S: StateStore>(
    dedup_tables: &HashMap<u32, Table>,
    store: S,
    vnodes: Option<Arc<Bitmap>>,
    streaming_config: &StreamingConfig,
) -> HashMap<usize, StateTable<S>>