Skip to main content

apply_rolling_processing_engine

reifydb_sub_flow::operator::window::rolling

Function apply_rolling_processing_engine 

Source 
pub fn apply_rolling_processing_engine(
    operator: &WindowOperator,
    txn: &mut FlowTransaction,
    change: Change,
) -> Result<Change>