replaces a column with an old name with a new name in an expression
(
e: Arc<dyn PhysicalExpr>,
column_old: &phys_expr::Column,
column_new: &phys_expr::Column,
)
| 1240 | |
| 1241 | /// replaces a column with an old name with a new name in an expression |
| 1242 | fn rewrite_column_expr( |
| 1243 | e: Arc<dyn PhysicalExpr>, |
| 1244 | column_old: &phys_expr::Column, |
| 1245 | column_new: &phys_expr::Column, |
| 1246 | ) -> Result<Arc<dyn PhysicalExpr>> { |
| 1247 | e.transform(|expr| { |
| 1248 | if let Some(column) = expr.downcast_ref::<phys_expr::Column>() |
| 1249 | && column == column_old |
| 1250 | { |
| 1251 | return Ok(Transformed::yes(Arc::new(column_new.clone()))); |
| 1252 | } |
| 1253 | |
| 1254 | Ok(Transformed::no(expr)) |
| 1255 | }) |
| 1256 | .data() |
| 1257 | } |
| 1258 | |
| 1259 | fn reverse_operator(op: Operator) -> Result<Operator> { |
| 1260 | op.swap().ok_or_else(|| { |
no test coverage detected
searching dependent graphs…