Skip to content

Commit b3bdc48

Browse files
committed
fix removal of lambda features
1 parent 6f2c92b commit b3bdc48

2 files changed

Lines changed: 9 additions & 22 deletions

File tree

datafusion/core/src/execution/session_state.rs

Lines changed: 9 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -1576,28 +1576,16 @@ impl SessionStateBuilder {
15761576

15771577
if let Some(lambda_functions) = lambda_functions {
15781578
for udlf in lambda_functions {
1579-
let config_options = state.config().options();
1580-
match udlf.with_updated_config(config_options) {
1581-
Some(new_udf) => {
1582-
if let Err(err) = state.register_udlf(new_udf) {
1583-
debug!(
1584-
"Failed to re-register updated UDLF '{}': {}",
1585-
udlf.name(),
1586-
err
1587-
);
1588-
}
1579+
match state.register_udlf(Arc::clone(&udlf)) {
1580+
Ok(Some(existing)) => {
1581+
debug!("Overwrote existing UDLF '{}'", existing.name());
1582+
}
1583+
Ok(None) => {
1584+
debug!("Registered UDLF '{}'", udlf.name());
1585+
}
1586+
Err(err) => {
1587+
debug!("Failed to register UDLF '{}': {}", udlf.name(), err);
15891588
}
1590-
None => match state.register_udlf(Arc::clone(&udlf)) {
1591-
Ok(Some(existing)) => {
1592-
debug!("Overwrote existing UDLF '{}'", existing.name());
1593-
}
1594-
Ok(None) => {
1595-
debug!("Registered UDLF '{}'", udlf.name());
1596-
}
1597-
Err(err) => {
1598-
debug!("Failed to register UDLF '{}': {}", udlf.name(), err);
1599-
}
1600-
},
16011589
}
16021590
}
16031591
}

datafusion/expr/src/udlf.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
//! [`LambdaUDF`]: Lambda User Defined Functions
1919
2020
use crate::expr::schema_name_from_exprs_comma_separated_without_space;
21-
use crate::simplify::{ExprSimplifyResult, SimplifyContext};
2221
use crate::{ColumnarValue, Documentation, Expr};
2322
use arrow::array::{ArrayRef, RecordBatch};
2423
use arrow::datatypes::{DataType, Field, FieldRef, Schema};

0 commit comments

Comments
 (0)