@@ -26,7 +26,6 @@ use pyo3::types::PyCapsule;
2626
2727use crate :: catalog:: PyTable ;
2828use crate :: dataframe:: PyDataFrame ;
29- use crate :: dataset:: Dataset ;
3029use crate :: errors:: { py_datafusion_err, PyDataFusionResult } ;
3130use crate :: utils:: { get_tokio_runtime, validate_pycapsule} ;
3231
@@ -113,30 +112,3 @@ impl PyTableProvider {
113112 PyCapsule :: new ( py, provider, Some ( name. clone ( ) ) )
114113 }
115114}
116-
117- #[ deprecated( note = "Use PyTableProvider methods (as_arc, into_inner) directly instead" ) ]
118- pub ( crate ) fn pyany_to_table_provider (
119- table_provider : & Bound < ' _ , PyAny > ,
120- ) -> PyResult < Arc < dyn TableProvider + Send > > {
121- if table_provider. hasattr ( "__datafusion_table_provider__" ) ? {
122- let capsule = table_provider
123- . getattr ( "__datafusion_table_provider__" ) ?
124- . call0 ( ) ?;
125- let capsule = capsule. downcast :: < PyCapsule > ( ) . map_err ( py_datafusion_err) ?;
126- validate_pycapsule ( capsule, "datafusion_table_provider" ) ?;
127-
128- let provider = unsafe { capsule. reference :: < FFI_TableProvider > ( ) } ;
129- let provider: ForeignTableProvider = provider. into ( ) ;
130- Ok ( Arc :: new ( provider) as Arc < dyn TableProvider + Send > )
131- } else if let Ok ( py_table) = table_provider. extract :: < PyTable > ( ) {
132- Ok ( py_table. table ( ) )
133- } else if let Ok ( py_provider) = table_provider. extract :: < PyTableProvider > ( ) {
134- Ok ( py_provider. as_arc ( ) )
135- } else if let Ok ( inner) = table_provider. getattr ( "table" ) {
136- pyany_to_table_provider ( & inner)
137- } else {
138- let py = table_provider. py ( ) ;
139- let provider = Dataset :: new ( table_provider, py) ?;
140- Ok ( Arc :: new ( provider) as Arc < dyn TableProvider + Send > )
141- }
142- }
0 commit comments