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

Method with_param_values

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

Replace all parameters in logical plan with the specified values, in preparation for execution. # Example ``` use datafusion::prelude::*; # use datafusion::{error::Result, assert_batches_eq}; # #[tokio::main] # async fn main() -> Result<()> { # use datafusion_common::ScalarValue; let ctx = SessionContext::new(); # ctx.register_csv("example", "tests/data/example.csv", CsvReadOptions::new()).await

(self, query_values: impl Into<ParamValues>)

Source from the content-addressed store, hash-verified

2365 /// # }
2366 /// ```
2367 pub fn with_param_values(self, query_values: impl Into<ParamValues>) -> Result<Self> {
2368 let plan = self.plan.with_param_values(query_values)?;
2369 Ok(DataFrame {
2370 session_state: self.session_state,
2371 plan,
2372 projection_requires_validation: self.projection_requires_validation,
2373 })
2374 }
2375
2376 /// Cache DataFrame as a memory table.
2377 ///

Calls

no outgoing calls