@@ -374,7 +374,7 @@ pub fn build_compute_dataflow(
374374 ) ;
375375
376376 for ( id, ( oks, errs) ) in imported_sources. into_iter ( ) {
377- // Imports read row-shaped data from persist; encode it to the
377+ // Imports read row-shaped data from persist. Encode it to the
378378 // columnar edge at the boundary. The batches are already
379379 // consolidated, so this leaf-encode is non-consolidating.
380380 let bundle = crate :: render:: CollectionBundle :: from_edge (
@@ -477,7 +477,7 @@ pub fn build_compute_dataflow(
477477 ) ;
478478
479479 for ( id, ( oks, errs) ) in imported_sources. into_iter ( ) {
480- // Imports read row-shaped data from persist; encode it to the
480+ // Imports read row-shaped data from persist. Encode it to the
481481 // columnar edge at the boundary. The batches are already
482482 // consolidated, so this leaf-encode is non-consolidating.
483483 let bundle = crate :: render:: CollectionBundle :: from_edge (
@@ -673,7 +673,7 @@ where
673673 start_signal,
674674 |e, _| e. clone ( ) ,
675675 ) ;
676- // The filtered index collection is row-shaped; encode it to
676+ // The filtered index collection is row-shaped. Encode it to
677677 // the columnar edge at the boundary. It is already
678678 // consolidated, so this leaf-encode is non-consolidating.
679679 CollectionBundle :: from_edge (
0 commit comments