risingwave_stream::executor::source

Function get_split_offset_mapping_from_chunk

source
pub fn get_split_offset_mapping_from_chunk(
    chunk: &StreamChunk,
    split_idx: usize,
    offset_idx: usize,
) -> Option<HashMap<SplitId, String>>