flow::compute::render::map

Function eval_mfp_core

Source 
fn eval_mfp_core(
    input: impl IntoIterator<Item = (Row, i64, i64)>,
    mfp_plan: &MfpPlan,
    now: i64,
    err_collector: &ErrCollector,
) -> Vec<((Row, Row), i64, i64)>
Expand description

The core of evaluating MFP operator, given a MFP and a input, evaluate the MFP operator, return the output updates And possibly any number of errors that occurred during the evaluation