risingwave_stream::common::table::state_table

Function deserialize_keyed_row_stream

source
fn deserialize_keyed_row_stream<'a>(
    iter: impl StateStoreIter + 'a,
    deserializer: &'a impl ValueRowSerde,
) -> impl KeyedRowStream<'a>