File tree 1 file changed +2
-2
lines changed
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -134,7 +134,7 @@ fn digest(value: PyExpr, method: PyExpr) -> PyExpr {
134
134
#[ pyo3( signature = ( * args) ) ]
135
135
fn concat ( args : Vec < PyExpr > ) -> PyResult < PyExpr > {
136
136
let args = args. into_iter ( ) . map ( |e| e. expr ) . collect :: < Vec < _ > > ( ) ;
137
- Ok ( datafusion_expr :: concat ( & args) . into ( ) )
137
+ Ok ( functions :: string :: expr_fn :: concat ( args) . into ( ) )
138
138
}
139
139
140
140
/// Concatenates all but the first argument, with separators.
@@ -144,7 +144,7 @@ fn concat(args: Vec<PyExpr>) -> PyResult<PyExpr> {
144
144
#[ pyo3( signature = ( sep, * args) ) ]
145
145
fn concat_ws ( sep : String , args : Vec < PyExpr > ) -> PyResult < PyExpr > {
146
146
let args = args. into_iter ( ) . map ( |e| e. expr ) . collect :: < Vec < _ > > ( ) ;
147
- Ok ( datafusion_expr :: concat_ws ( lit ( sep) , args) . into ( ) )
147
+ Ok ( functions :: string :: expr_fn :: concat_ws ( lit ( sep) , args) . into ( ) )
148
148
}
149
149
150
150
/// Creates a new Sort Expr
You can’t perform that action at this time.
0 commit comments