File tree Expand file tree Collapse file tree 5 files changed +5
-5
lines changed
core/src/physical_optimizer
substrait/src/logical_plan Expand file tree Collapse file tree 5 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -93,7 +93,7 @@ impl PhysicalOptimizerRule for CombinePartialFinalAggregate {
9393 input_agg_exec. filter_expr ( ) . to_vec ( ) ,
9494 input_agg_exec. order_by_expr ( ) . to_vec ( ) ,
9595 input_agg_exec. input ( ) . clone ( ) ,
96- input_agg_exec. input_schema ( ) . clone ( ) ,
96+ input_agg_exec. input_schema ( ) ,
9797 )
9898 . ok ( )
9999 . map ( Arc :: new)
Original file line number Diff line number Diff line change @@ -554,7 +554,7 @@ fn reorder_aggregate_keys(
554554 agg_exec. filter_expr ( ) . to_vec ( ) ,
555555 agg_exec. order_by_expr ( ) . to_vec ( ) ,
556556 partial_agg,
557- agg_exec. input_schema ( ) . clone ( ) ,
557+ agg_exec. input_schema ( ) ,
558558 ) ?) ;
559559
560560 // Need to create a new projection to change the expr ordering back
Original file line number Diff line number Diff line change @@ -75,7 +75,7 @@ impl TopKAggregation {
7575 aggr. filter_expr ( ) . to_vec ( ) ,
7676 aggr. order_by_expr ( ) . to_vec ( ) ,
7777 aggr. input ( ) . clone ( ) ,
78- aggr. input_schema ( ) . clone ( ) ,
78+ aggr. input_schema ( ) ,
7979 )
8080 . expect ( "Unable to copy Aggregate!" )
8181 . with_limit ( Some ( limit) ) ;
Original file line number Diff line number Diff line change @@ -811,7 +811,7 @@ fn concat_internal(args: &[ArrayRef]) -> Result<ArrayRef> {
811811 }
812812 }
813813 // Assume all arrays have the same data type
814- let data_type = list_arrays[ 0 ] . value_type ( ) . clone ( ) ;
814+ let data_type = list_arrays[ 0 ] . value_type ( ) ;
815815 let buffer = valid. finish ( ) ;
816816
817817 let elements = arrays
Original file line number Diff line number Diff line change @@ -326,7 +326,7 @@ pub fn to_substrait_rel(
326326 left : Some ( left) ,
327327 right : Some ( right) ,
328328 r#type : join_type as i32 ,
329- expression : join_expr. clone ( ) ,
329+ expression : join_expr,
330330 post_join_filter : None ,
331331 advanced_extension : None ,
332332 } ) ) ) ,
You can’t perform that action at this time.
0 commit comments