Skip to main content

apply_closure

Function apply_closure 

Source
fn apply_closure<'a>(
    closure: &'a JoinClosure,
    datums: &mut DatumVecBorrow<'a>,
    temp_storage: &'a RowArena,
) -> Result<Option<Row>, DataflowErrorSer>
Expand description

Applies closure to the datums of one record, packing the row it computes.

The two finalization paths differ only in where the datums come from, so this is what they share.