Function drain_through_mfp

fn drain_through_mfp<T>(
    input_row: &Row,
    input_time: &T,
    input_diff: &Diff,
    datum_vec: &mut DatumVec,
    extensions: &[(Row, Diff)],
    mfp_plan: &MfpPlan,
    until: &Antichain<Timestamp>,
    ok_output: &mut Session<'_, '_, T, ConsolidatingContainerBuilder<Vec<(Row, T, Diff)>>, InputCapability<T>>,
    err_output: &mut Session<'_, '_, T, ConsolidatingContainerBuilder<Vec<(DataflowError, T, Diff)>>, InputCapability<T>>,
    budget: &mut usize,
)
where
    T: RenderTimestamp,

Drains a list of extensions to input_row through a supplied MfpPlan and into output buffers.

The method decodes input_row, and should be amortized across non-trivial extensions.