allenma commented on code in PR #5911:
URL: https://github.com/apache/arrow-datafusion/pull/5911#discussion_r1168498023
##########
datafusion/physical-expr/src/functions.rs:
##########
@@ -64,6 +65,22 @@ pub fn create_physical_expr(
let data_type = function::return_type(fun, &input_expr_types)?;
+ // if function will be converted to case expression
+ if let BuiltinScalarFunction::If = fun {
+ if input_phy_exprs.len() != 3 {
+ return Err(DataFusionError::Internal(format!(
+ "{:?} args were supplied but IF function takes exactly 3 args",
+ input_phy_exprs.len(),
+ )));
+ }
+ let (when_expr, then_expr, else_expr) = (
+ Arc::clone(&input_phy_exprs[0]),
+ Arc::clone(&input_phy_exprs[1]),
+ Arc::clone(&input_phy_exprs[2]),
+ );
+ return case(None, vec![(when_expr, then_expr)], Some(else_expr));
Review Comment:
Good idea, let me check how to do it:)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
