Return a `FunctionRegistry` used to plan udf's calls # Example ``` # use datafusion::prelude::*; # use datafusion::error::Result; # #[tokio::main] # async fn main() -> Result<()> { let ctx = SessionContext::new(); let df = ctx .read_csv("tests/data/example.csv", CsvReadOptions::new()) .await?; let f = df.registry(); // use f.udf("name", vec![...]) to use the udf # Ok(()) # } ```
(&self)
| 1810 | /// # } |
| 1811 | /// ``` |
| 1812 | pub fn registry(&self) -> &dyn FunctionRegistry { |
| 1813 | self.session_state.as_ref() |
| 1814 | } |
| 1815 | |
| 1816 | /// Calculate the intersection of two [`DataFrame`]s. The two [`DataFrame`]s must have exactly the same schema |
| 1817 | /// |