fn apply_closure_to_edge<'s, T>(
edge: Collection<'s, T, Column<(Row, T, Diff)>>,
name: &str,
closure: JoinClosure,
) -> (Collection<'s, T, Column<(Row, T, Diff)>>, VecCollection<'s, T, DataflowErrorSer, Diff>)where
T: RenderTimestamp,Expand description
Applies closure to every record of edge, writing the rows it computes onto the
output edge.
The closure borrows the row it reads, so reading the edge costs nothing, whereas
decoding it would cost an owned Row per record.