encode_snapshot

risingwave_stream::executor::over_window::eowc

Function encode_snapshot 

Source 
fn encode_snapshot(
    snapshot: &WindowStateSnapshot,
    pk_ser: &OrderedRowSerde,
) -> Vec<u8> ⓘ
Expand description

Encode a WindowStateSnapshot to bytes for persistence using protobuf.