decode_snapshot

risingwave_stream::executor::over_window::eowc

Function decode_snapshot 

Source 
fn decode_snapshot(
    bytes: &[u8],
    pk_deser: &OrderedRowSerde,
) -> StreamExecutorResult<WindowStateSnapshot>
Expand description

Decode a WindowStateSnapshot from bytes during recovery using protobuf.