Skip to main content

decode_progress

risingwave_stream::executor::over_window::eowc

Function decode_progress 

Source 
fn decode_progress(
    bytes: &[u8],
    pk_deser: &OrderedRowSerde,
) -> StreamExecutorResult<PartitionProgress>