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 15
15
// specific language governing permissions and limitations
16
16
// under the License.
17
17
18
+ use datafusion:: catalog:: Session ;
18
19
use pyo3:: exceptions:: PyValueError ;
19
20
/// Implements a Datafusion TableProvider that delegates to a PyArrow Dataset
20
21
/// 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;
30
31
use datafusion:: arrow:: pyarrow:: PyArrowType ;
31
32
use datafusion:: datasource:: { TableProvider , TableType } ;
32
33
use datafusion:: error:: { DataFusionError , Result as DFResult } ;
33
- use datafusion:: execution:: context:: SessionState ;
34
34
use datafusion:: logical_expr:: TableProviderFilterPushDown ;
35
35
use datafusion:: physical_plan:: ExecutionPlan ;
36
36
use datafusion_expr:: Expr ;
@@ -98,7 +98,7 @@ impl TableProvider for Dataset {
98
98
/// parallelized or distributed.
99
99
async fn scan (
100
100
& self ,
101
- _ctx : & SessionState ,
101
+ _ctx : & dyn Session ,
102
102
projection : Option < & Vec < usize > > ,
103
103
filters : & [ Expr ] ,
104
104
// limit can be used to reduce the amount scanned
You can’t perform that action at this time.
0 commit comments