Updated Polars to 0.39.0

CHANGELOG.md

@@ -1,6 +1,6 @@
-## 0.9.1 (unreleased)
+## 0.10.0 (unreleased)
 
-- Updated Polars to 0.38.3
+- Updated Polars to 0.39.0
 - Added support for writing JSON to string
 - Added support for writing Parquet to `StringIO`
 - Added support for cross joins

ext/polars/Cargo.toml

@@ -15,14 +15,14 @@ ahash = "0.8"
 chrono = "0.4"
 either = "1.8"
 magnus = "0.6"
-polars-core = "=0.38.3"
-polars-parquet = "=0.38.3"
-polars-utils = "=0.38.3"
+polars-core = "=0.39.0"
+polars-parquet = "=0.39.0"
+polars-utils = "=0.39.0"
 serde_json = "1"
 smartstring = "1"
 
 [dependencies.polars]
-version = "=0.38.3"
+version = "=0.39.0"
 features = [
     "abs",
     "approx_unique",

ext/polars/src/conversion/anyvalue.rs

@@ -3,8 +3,8 @@ use magnus::{
     class, prelude::*, r_hash::ForEach, Float, Integer, IntoValue, RArray, RHash, RString, Ruby,
     TryConvert, Value,
 };
-use polars::frame::row::any_values_to_dtype;
 use polars::prelude::*;
+use polars_core::utils::any_values_to_supertype_and_n_dtypes;
 
 use super::{struct_dict, ObjectValue, Wrap};
 
@@ -120,7 +120,8 @@ impl<'s> TryConvert for Wrap<AnyValue<'s>> {
                     avs.push(Wrap::<AnyValue>::try_convert(item?)?.0)
                 }
 
-                let (dtype, _n_types) = any_values_to_dtype(&avs).map_err(RbPolarsErr::from)?;
+                let (dtype, _n_types) =
+                    any_values_to_supertype_and_n_dtypes(&avs).map_err(RbPolarsErr::from)?;
 
                 // push the rest
                 avs.reserve(list.len());

ext/polars/src/expr/array.rs

@@ -59,8 +59,12 @@ impl RbExpr {
         self.inner.clone().arr().arg_max().into()
     }
 
-    pub fn arr_get(&self, index: &RbExpr) -> Self {
-        self.inner.clone().arr().get(index.inner.clone()).into()
+    pub fn arr_get(&self, index: &RbExpr, null_on_oob: bool) -> Self {
+        self.inner
+            .clone()
+            .arr()
+            .get(index.inner.clone(), null_on_oob)
+            .into()
     }
 
     pub fn arr_join(&self, separator: &RbExpr, ignore_nulls: bool) -> Self {

ext/polars/src/expr/general.rs

@@ -267,7 +267,7 @@ impl RbExpr {
     pub fn sort_with(&self, descending: bool, nulls_last: bool) -> Self {
         self.clone()
             .inner
-            .sort_with(SortOptions {
+            .sort(SortOptions {
                 descending,
                 nulls_last,
                 multithreaded: true,
@@ -323,9 +323,28 @@ impl RbExpr {
         self.clone().inner.gather(idx.inner.clone()).into()
     }
 
-    pub fn sort_by(&self, by: RArray, reverse: Vec<bool>) -> RbResult<Self> {
+    pub fn sort_by(
+        &self,
+        by: RArray,
+        descending: Vec<bool>,
+        nulls_last: bool,
+        multithreaded: bool,
+        maintain_order: bool,
+    ) -> RbResult<Self> {
         let by = rb_exprs_to_exprs(by)?;
-        Ok(self.clone().inner.sort_by(by, reverse).into())
+        Ok(self
+            .clone()
+            .inner
+            .sort_by(
+                by,
+                SortMultipleOptions {
+                    descending,
+                    nulls_last,
+                    multithreaded,
+                    maintain_order,
+                },
+            )
+            .into())
     }
 
     pub fn backward_fill(&self, limit: FillNullLimit) -> Self {