File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
datafusion/physical-expr-adapter/src Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -525,7 +525,7 @@ impl<'a> DefaultPhysicalExprAdapterRewriter<'a> {
525525/// ).unwrap();
526526///
527527/// // Adapt the batch to match target schema
528- /// let adapted = adapter.adapt_batch(source_batch).unwrap();
528+ /// let adapted = adapter.adapt_batch(& source_batch).unwrap();
529529///
530530/// assert_eq!(adapted.num_columns(), 3);
531531/// assert_eq!(adapted.column(0).data_type(), &DataType::Utf8); // name
@@ -576,9 +576,7 @@ impl BatchAdapterFactory {
576576 let simplifier = PhysicalExprSimplifier :: new ( & self . target_schema ) ;
577577
578578 let projection = ProjectionExprs :: from_indices (
579- & ( 0 ..self . target_schema . fields ( ) . len ( ) )
580- . map ( |i| i as usize )
581- . collect_vec ( ) ,
579+ & ( 0 ..self . target_schema . fields ( ) . len ( ) ) . collect_vec ( ) ,
582580 & self . target_schema ,
583581 ) ;
584582
You can’t perform that action at this time.
0 commit comments