Method find_qualified_columns

datafusion/core/src/dataframe/mod.rs:2538–2551

Find qualified columns for this dataframe from names # Arguments `names` - Unqualified names to find. # Example ``` # use datafusion::prelude::*; # use datafusion::error::Result; # use datafusion_common::ScalarValue; # #[tokio::main] # async fn main() -> Result<()> { let ctx = SessionContext::new(); ctx.register_csv("first_table", "tests/data/example.csv", CsvReadOptions::new()) .await?; let df

(
        &self,
        names: &[&str],
    )

    /// # }
    /// ```
    pub fn find_qualified_columns(
        &self,
        names: &[&str],
    ) -> Result<Vec<(Option<&TableReference>, &FieldRef)>> {
        let schema = self.logical_plan().schema();
        names
            .iter()
            .map(|name| {
                schema
                    .qualified_field_from_column(&Column::from_name(*name))
                    .map_err(|_| plan_datafusion_err!("Column '{}' not found", name))
            })
            .collect()
    }

    /// Helper for creating DataFrame.
    /// # Example