fn demux_join_results<'s, T>(
results: Stream<'s, T, Vec<(Result<Row, DataflowErrorSer>, T, Diff)>>,
) -> (Collection<'s, T, Column<(Row, T, Diff)>>, VecCollection<'s, T, DataflowErrorSer, Diff>)where
T: RenderTimestamp,Expand description
Splits a stage’s Results, writing the rows onto the edge and the errors to a Vec.
LinearJoinSpec::render has one output, so a stage whose closure can error produces
Results and separates them afterwards. The rows are pushed borrowed, so the split is
also the encode.