This is an automated email from the ASF dual-hosted git repository.
HyukjinKwon pushed a commit to branch branch-4.2
in repository https://gitbox.apache.org/repos/asf/spark-connect-rust.git
The following commit(s) were added to refs/heads/branch-4.2 by this push:
new 5adef48 [SPARK-59109][FOLLOWUP] Apply cargo fmt to the API-parity
changes
5adef48 is described below
commit 5adef489560172bec7d2013d9d1447fbf79a7be5
Author: Hyukjin Kwon <[email protected]>
AuthorDate: Sat Aug 29 20:10:27 2026 +0900
[SPARK-59109][FOLLOWUP] Apply cargo fmt to the API-parity changes
The parity fix left two spots unformatted (Column.between's wrapped
signature
and DataFrame.groupingSets' let-binding); `cargo fmt --all --check` flagged
them
in the rustfmt + clippy job. Format them. No behavior change.
Co-authored-by: Isaac <[email protected]>
---
crates/pyspark-rs/src/column.rs | 7 ++++++-
crates/pyspark-rs/src/dataframe.rs | 3 ++-
2 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/crates/pyspark-rs/src/column.rs b/crates/pyspark-rs/src/column.rs
index a332df7..75b8643 100644
--- a/crates/pyspark-rs/src/column.rs
+++ b/crates/pyspark-rs/src/column.rs
@@ -429,7 +429,12 @@ impl PyColumn {
}
// --- named Column methods (PySpark camelCase) ---
- fn between(&self, py: Python<'_>, lowerBound: Py<PyAny>, upperBound:
Py<PyAny>) -> PyResult<PyColumn> {
+ fn between(
+ &self,
+ py: Python<'_>,
+ lowerBound: Py<PyAny>,
+ upperBound: Py<PyAny>,
+ ) -> PyResult<PyColumn> {
let l = to_column(&lowerBound.bind(py))?;
let u = to_column(&upperBound.bind(py))?;
Ok(PyColumn::new(self.column.clone().between(l, u)))
diff --git a/crates/pyspark-rs/src/dataframe.rs
b/crates/pyspark-rs/src/dataframe.rs
index 48bd5b1..7f0e04c 100644
--- a/crates/pyspark-rs/src/dataframe.rs
+++ b/crates/pyspark-rs/src/dataframe.rs
@@ -475,7 +475,8 @@ impl PyDataFrame {
/// Grouping sets aggregation: `groupingSets([[a, b], [a], []])`.
#[pyo3(name = "groupingSets")]
fn grouping_sets(&self, groupingSets: Vec<Vec<Bound<'_, PyAny>>>) ->
PyResult<PyGroupedData> {
- let mut out: Vec<Vec<spark_connect::column::Column>> =
Vec::with_capacity(groupingSets.len());
+ let mut out: Vec<Vec<spark_connect::column::Column>> =
+ Vec::with_capacity(groupingSets.len());
for s in groupingSets {
out.push(to_column_list(s)?);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
