flow::compute::render::map

Function mfp_subgraph

Source 
fn mfp_subgraph(
    arrange: &ArrangeHandler,
    input: impl IntoIterator<Item = (Row, i64, i64)>,
    mfp_plan: &MfpPlan,
    now: i64,
    err_collector: &ErrCollector,
    scheduler: &Scheduler,
    send: &PortCtx<SEND, TeeingHandoff<(Row, i64, i64)>>,
)