We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 500b10a commit b29ebd2Copy full SHA for b29ebd2
datafusion/expr/src/logical_plan/tree_node.rs
@@ -365,14 +365,9 @@ fn rewrite_arcs<F>(
365
where
366
F: FnMut(LogicalPlan) -> Result<Transformed<LogicalPlan>>,
367
{
368
- Ok(input_plans
+ input_plans
369
.into_iter()
370
- .map(unwrap_arc)
371
- .map_until_stop_and_collect(&mut f)?
372
- .update_data(|inputs| {
373
- // have a Vec<LogicalPlan>, now need to wrap in `Arc`s again
374
- inputs.into_iter().map(Arc::new).collect::<Vec<_>>()
375
- }))
+ .map_until_stop_and_collect(|plan| rewrite_arc(plan, &mut f))
376
}
377
378
/// Rewrites all inputs for an Extension node "in place"
0 commit comments