risingwave_stream::executor::top_n::utils

Function serialize_pk_to_cache_key

source 
pub fn serialize_pk_to_cache_key(
    pk: impl Row,
    cache_key_serde: &(OrderedRowSerde, OrderedRowSerde, usize),
) -> (Vec<u8>, Vec<u8>)
Expand description

For a given pk (Row), it can be split into order_key and additional_pk according to order_by_len, and the two split parts are serialized separately.