refactor(python): Remove unused functions from the rust side (#23757)

Author: eitsupi

crates/polars-python/src/dataframe/io.rs

@@ -11,10 +11,7 @@ use pyo3::pybacked::PyBackedStr;
 
 use super::PyDataFrame;
 use crate::conversion::Wrap;
-use crate::file::{
-    EitherRustPythonFile, get_either_file, get_file_like, get_mmap_bytes_reader,
-    get_mmap_bytes_reader_and_path,
-};
+use crate::file::{get_file_like, get_mmap_bytes_reader, get_mmap_bytes_reader_and_path};
 use crate::prelude::PyCompatLevel;
 use crate::utils::EnterPolarsExt;
 
@@ -127,58 +124,6 @@ impl PyDataFrame {
         })
     }
 
-    #[staticmethod]
-    #[cfg(feature = "parquet")]
-    #[pyo3(signature = (py_f, columns, projection, n_rows, row_index, low_memory, parallel, use_statistics, rechunk))]
-    pub fn read_parquet(
-        py: Python<'_>,
-        py_f: PyObject,
-        columns: Option<Vec<String>>,
-        projection: Option<Vec<usize>>,
-        n_rows: Option<usize>,
-        row_index: Option<(String, IdxSize)>,
-        low_memory: bool,
-        parallel: Wrap<ParallelStrategy>,
-        use_statistics: bool,
-        rechunk: bool,
-    ) -> PyResult<Self> {
-        use EitherRustPythonFile::*;
-
-        let row_index = row_index.map(|(name, offset)| RowIndex {
-            name: name.into(),
-            offset,
-        });
-
-        _ = use_statistics;
-
-        match get_either_file(py_f, false)? {
-            Py(f) => {
-                let buf = std::io::Cursor::new(f.to_memslice());
-                py.enter_polars_df(move || {
-                    ParquetReader::new(buf)
-                        .with_projection(projection)
-                        .with_columns(columns)
-                        .read_parallel(parallel.0)
-                        .with_slice(n_rows.map(|x| (0, x)))
-                        .with_row_index(row_index)
-                        .set_low_memory(low_memory)
-                        .set_rechunk(rechunk)
-                        .finish()
-                })
-            },
-            Rust(f) => py.enter_polars_df(move || {
-                ParquetReader::new(f)
-                    .with_projection(projection)
-                    .with_columns(columns)
-                    .read_parallel(parallel.0)
-                    .with_slice(n_rows.map(|x| (0, x)))
-                    .with_row_index(row_index)
-                    .set_rechunk(rechunk)
-                    .finish()
-            }),
-        }
-    }
-
     #[staticmethod]
     #[cfg(feature = "json")]
     #[pyo3(signature = (py_f, infer_schema_length, schema, schema_overrides))]
@@ -209,33 +154,6 @@ impl PyDataFrame {
         })
     }
 
-    #[staticmethod]
-    #[cfg(feature = "json")]
-    #[pyo3(signature = (py_f, ignore_errors, schema, schema_overrides))]
-    pub fn read_ndjson(
-        py: Python<'_>,
-        py_f: Bound<PyAny>,
-        ignore_errors: bool,
-        schema: Option<Wrap<Schema>>,
-        schema_overrides: Option<Wrap<Schema>>,
-    ) -> PyResult<Self> {
-        let mmap_bytes_r = get_mmap_bytes_reader(&py_f)?;
-
-        let mut builder = JsonReader::new(mmap_bytes_r)
-            .with_json_format(JsonFormat::JsonLines)
-            .with_ignore_errors(ignore_errors);
-
-        if let Some(schema) = schema {
-            builder = builder.with_schema(Arc::new(schema.0));
-        }
-
-        if let Some(schema) = schema_overrides.as_ref() {
-            builder = builder.with_schema_overwrite(&schema.0);
-        }
-
-        py.enter_polars_df(move || builder.finish())
-    }
-
     #[staticmethod]
     #[cfg(feature = "ipc")]
     #[pyo3(signature = (py_f, columns, projection, n_rows, row_index, memory_map))]

crates/polars-python/src/functions/lazy.rs

@@ -169,11 +169,6 @@ pub fn collect_all_with_callback(
     })
 }
 
-#[pyfunction]
-pub fn cols(names: Vec<String>) -> PyExpr {
-    dsl::cols(names).as_expr().into()
-}
-
 #[pyfunction]
 pub fn concat_lf(
     seq: &Bound<'_, PyAny>,

py-polars/src/lib.rs

@@ -186,7 +186,6 @@ fn polars(py: Python, m: &Bound<PyModule>) -> PyResult<()> {
         .unwrap();
     m.add_wrapped(wrap_pyfunction!(functions::collect_all_with_callback))
         .unwrap();
-    m.add_wrapped(wrap_pyfunction!(functions::cols)).unwrap();
     m.add_wrapped(wrap_pyfunction!(functions::concat_lf))
         .unwrap();
     m.add_wrapped(wrap_pyfunction!(functions::concat_arr))