fn arrange_keyed_join_input<'s, T>(
keyed: Stream<'s, T, Column<((Row, Row), T, Diff)>>,
errs: Stream<'s, T, Vec<(DataflowErrorSer, T, Diff)>>,
batcher: ArrangementBatcher,
) -> (Arranged<'s, TraceAgent<RowRowSpine<T, Diff>>>, VecCollection<'s, T, DataflowErrorSer, Diff>)where
T: Lattice + RenderTimestamp,Expand description
Exchanges keyed join updates by key and arranges them into a RowRowSpine.