MCPcopy Create free account
hub / github.com/apache/datafusion / registry

Method registry

datafusion/core/src/dataframe/mod.rs:1812–1814  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

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 ///

Callers 2

simple_udfFunction · 0.80
registryFunction · 0.80

Calls 1

as_refMethod · 0.45

Tested by 1

registryFunction · 0.64