Skip to main content

encode_progress

risingwave_stream::executor::over_window::eowc

Function encode_progress 

Source 
fn encode_progress(
    progress: &PartitionProgress,
    pk_ser: &OrderedRowSerde,
) -> Option<Vec<u8>>
Expand description

Encode a PartitionProgress for persistence, or None if it’s empty.