File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -39,7 +39,7 @@ use crate::dataset_exec::DatasetExec;
3939use crate :: pyarrow_filter_expression:: PyArrowFilterExpression ;
4040
4141// Wraps a pyarrow.dataset.Dataset class and implements a Datafusion TableProvider around it
42- #[ derive( Debug , Clone ) ]
42+ #[ derive( Debug ) ]
4343pub ( crate ) struct Dataset {
4444 dataset : PyObject ,
4545}
Original file line number Diff line number Diff line change @@ -53,7 +53,7 @@ impl Iterator for PyArrowBatchesAdapter {
5353
5454 fn next ( & mut self ) -> Option < Self :: Item > {
5555 Python :: with_gil ( |py| {
56- let mut batches = self . batches . clone ( ) . into_bound ( py) ;
56+ let mut batches = self . batches . clone_ref ( py ) . into_bound ( py) ;
5757 Some (
5858 batches
5959 . next ( ) ?
@@ -65,7 +65,7 @@ impl Iterator for PyArrowBatchesAdapter {
6565}
6666
6767// Wraps a pyarrow.dataset.Dataset class and implements a Datafusion ExecutionPlan around it
68- #[ derive( Debug , Clone ) ]
68+ #[ derive( Debug ) ]
6969pub ( crate ) struct DatasetExec {
7070 dataset : PyObject ,
7171 schema : SchemaRef ,
You can’t perform that action at this time.
0 commit comments