feat: add possibility to not simplify UDTF args

Author: askalt

datafusion/common/src/config.rs

@@ -257,6 +257,9 @@ config_namespace! {
         /// parallel file scanning. Setting this to `true` ensures that newlines in values are
         /// parsed successfully, which may reduce performance.
         pub newlines_in_values: bool, default = false
+
+        /// Specifies whether UDTF arguments expressions must be simplified.
+        pub simplify_udtf_args: bool, default = true
     }
 }
 

datafusion/core/src/execution/session_state.rs

@@ -1844,14 +1844,17 @@ impl ContextProvider for SessionContextProvider<'_> {
             );
         let simplifier = ExprSimplifier::new(simplify_context);
         let schema = DFSchema::empty();
-        let args = args
-            .into_iter()
-            .map(|arg| {
-                simplifier
-                    .coerce(arg, &schema)
-                    .and_then(|e| simplifier.simplify(e))
-            })
-            .collect::<datafusion_common::Result<Vec<_>>>()?;
+        let args = if !self.state.config.options().catalog.simplify_udtf_args {
+            args
+        } else {
+            args.into_iter()
+                .map(|arg| {
+                    simplifier
+                        .coerce(arg, &schema)
+                        .and_then(|e| simplifier.simplify(e))
+                })
+                .collect::<datafusion_common::Result<Vec<_>>>()?
+        };
         let provider = tbl_func.create_table_provider_with_args(TableFunctionArgs {
             args: &args,
             session: self.state,

datafusion/sqllogictest/test_files/placeholders.slt

@@ -37,10 +37,9 @@ logical_plan
 02)--Projection: column1 AS id, column2 AS name
 03)----Values: ($1, Utf8View("Samanta") AS Utf8("Samanta")), (Int32(5) AS Int64(5), $2)
 physical_plan
-01)TransformPlanExec: rules=[ResolvePlaceholders: plans_to_modify=1]
-02)--DataSinkExec: sink=MemoryTable (partitions=1)
-03)----ProjectionExec: expr=[column1@0 as id, column2@1 as name]
-04)------DataSourceExec: placeholders=2
+01)DataSinkExec: sink=MemoryTable (partitions=1)
+02)--ProjectionExec: expr=[column1@0 as id, column2@1 as name]
+03)----DataSourceExec: placeholders=2
 
 # Filter with multiple placeholders
 query TT