File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed
datafusion-examples/examples/udf Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -74,7 +74,7 @@ impl TableFunctionImpl for TableListUdtf {
7474 ) ;
7575 }
7676 let state = args
77- . session
77+ . session ( )
7878 . as_any ( )
7979 . downcast_ref :: < SessionState > ( )
8080 . ok_or_else ( || {
Original file line number Diff line number Diff line change @@ -510,9 +510,9 @@ pub trait TableProviderFactory: Debug + Sync + Send {
510510/// Describes arguments provided to the table function call.
511511pub struct TableFunctionArgs < ' e , ' s > {
512512 /// Call arguments.
513- pub exprs : & ' e [ Expr ] ,
513+ exprs : & ' e [ Expr ] ,
514514 /// Session within which the function is called.
515- pub session : & ' s dyn Session ,
515+ session : & ' s dyn Session ,
516516}
517517
518518impl < ' e , ' s > TableFunctionArgs < ' e , ' s > {
Original file line number Diff line number Diff line change @@ -274,7 +274,7 @@ impl From<FFI_TableFunction> for Arc<dyn TableFunctionImpl> {
274274impl TableFunctionImpl for ForeignTableFunction {
275275 fn call_with_args ( & self , args : TableFunctionArgs ) -> Result < Arc < dyn TableProvider > > {
276276 let session = FFI_SessionRef :: new (
277- args. session ,
277+ args. session ( ) ,
278278 self . 0 . runtime ( ) ,
279279 self . 0 . logical_codec . clone ( ) ,
280280 ) ;
You can’t perform that action at this time.
0 commit comments