File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 1515// specific language governing permissions and limitations
1616// under the License.
1717
18+ use datafusion:: catalog:: Session ;
1819use pyo3:: exceptions:: PyValueError ;
1920/// Implements a Datafusion TableProvider that delegates to a PyArrow Dataset
2021/// This allows us to use PyArrow Datasets as Datafusion tables while pushing down projections and filters
@@ -30,7 +31,6 @@ use datafusion::arrow::datatypes::SchemaRef;
3031use datafusion:: arrow:: pyarrow:: PyArrowType ;
3132use datafusion:: datasource:: { TableProvider , TableType } ;
3233use datafusion:: error:: { DataFusionError , Result as DFResult } ;
33- use datafusion:: execution:: context:: SessionState ;
3434use datafusion:: logical_expr:: TableProviderFilterPushDown ;
3535use datafusion:: physical_plan:: ExecutionPlan ;
3636use datafusion_expr:: Expr ;
@@ -98,7 +98,7 @@ impl TableProvider for Dataset {
9898 /// parallelized or distributed.
9999 async fn scan (
100100 & self ,
101- _ctx : & SessionState ,
101+ _ctx : & dyn Session ,
102102 projection : Option < & Vec < usize > > ,
103103 filters : & [ Expr ] ,
104104 // limit can be used to reduce the amount scanned
You can’t perform that action at this time.
0 commit comments