File tree Expand file tree Collapse file tree 2 files changed +2
-4
lines changed Expand file tree Collapse file tree 2 files changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -581,10 +581,8 @@ impl PySessionContext {
581581 let capsule = capsule. downcast :: < PyCapsule > ( ) ?;
582582 // validate_pycapsule(capsule, "arrow_array_stream")?;
583583
584- let provider = unsafe { FFI_TableProvider :: from_raw ( capsule . pointer ( ) as _ ) } ;
584+ let provider = unsafe { capsule . reference :: < FFI_TableProvider > ( ) } ;
585585 let provider = ForeignTableProvider :: new ( provider) ;
586- let schema = provider. schema ( ) ;
587- println ! ( "Got schema through TableProvider trait." ) ;
588586
589587 let _ = self . ctx . register_table ( name, Arc :: new ( provider) ) ?;
590588 }
Original file line number Diff line number Diff line change @@ -97,7 +97,7 @@ impl PyScalarUDF {
9797 let function = create_udf (
9898 name,
9999 input_types. 0 ,
100- return_type. 0 ,
100+ Arc :: new ( return_type. 0 ) ,
101101 parse_volatility ( volatility) ?,
102102 to_scalar_function_impl ( func) ,
103103 ) ;
You can’t perform that action at this time.
0 commit comments