Helper to find columns from names
(&self, names: &[String])
| 2496 | |
| 2497 | // Helper to find columns from names |
| 2498 | fn find_columns(&self, names: &[String]) -> Result<Vec<FieldRef>> { |
| 2499 | let schema = self.logical_plan().schema(); |
| 2500 | names |
| 2501 | .iter() |
| 2502 | .map(|name| { |
| 2503 | schema |
| 2504 | .field_with_name(None, name) |
| 2505 | .cloned() |
| 2506 | .map_err(|_| plan_datafusion_err!("Column '{}' not found", name)) |
| 2507 | }) |
| 2508 | .collect() |
| 2509 | } |
| 2510 | |
| 2511 | /// Find qualified columns for this dataframe from names |
| 2512 | /// |
no test coverage detected