feat(rust): implement is_between on the rust side

crates/polars-lazy/Cargo.toml

@@ -84,6 +84,7 @@ repeat_by = ["polars-plan/repeat_by"]
 round_series = ["polars-plan/round_series", "polars-ops/round_series"]
 is_first_distinct = ["polars-plan/is_first_distinct"]
 is_last_distinct = ["polars-plan/is_last_distinct"]
+is_between = ["polars-plan/is_between"]
 is_unique = ["polars-plan/is_unique"]
 cross_join = ["polars-plan/cross_join", "polars-pipe?/cross_join", "polars-ops/cross_join"]
 asof_join = ["polars-plan/asof_join", "polars-time", "polars-ops/asof_join"]

crates/polars-ops/Cargo.toml

@@ -66,6 +66,7 @@ is_first_distinct = []
 is_last_distinct = []
 is_unique = []
 unique_counts = []
+is_between = []
 approx_unique = []
 fused = []
 cutqcut = ["dtype-categorical", "dtype-struct"]

crates/polars-ops/src/series/ops/is_between.rs

@@ -0,0 +1,34 @@
+use std::ops::BitAnd;
+
+use polars_core::prelude::*;
+#[cfg(feature = "serde")]
+use serde::{Deserialize, Serialize};
+
+#[derive(Copy, Clone, Debug, Hash, Eq, PartialEq, Default)]
+#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
+pub enum ClosedInterval {
+    #[default]
+    Both,
+    Left,
+    Right,
+    None,
+}
+
+pub fn is_between(
+    s: &Series,
+    lower: &Series,
+    upper: &Series,
+    closed: ClosedInterval,
+) -> PolarsResult<BooleanChunked> {
+    let left_cmp_op = match closed {
+        ClosedInterval::None | ClosedInterval::Right => Series::gt,
+        ClosedInterval::Both | ClosedInterval::Left => Series::gt_eq,
+    };
+    let right_cmp_op = match closed {
+        ClosedInterval::None | ClosedInterval::Left => Series::lt,
+        ClosedInterval::Both | ClosedInterval::Right => Series::lt_eq,
+    };
+    let left = left_cmp_op(s, lower)?;
+    let right = right_cmp_op(s, upper)?;
+    Ok(left.bitand(right))
+}

crates/polars-ops/src/series/ops/mod.rs

@@ -18,6 +18,8 @@ mod fused;
 mod horizontal;
 #[cfg(feature = "convert_index")]
 mod index;
+#[cfg(feature = "is_between")]
+mod is_between;
 #[cfg(feature = "is_first_distinct")]
 mod is_first_distinct;
 #[cfg(feature = "is_in")]
@@ -68,6 +70,8 @@ pub use fused::*;
 pub use horizontal::*;
 #[cfg(feature = "convert_index")]
 pub use index::*;
+#[cfg(feature = "is_between")]
+pub use is_between::*;
 #[cfg(feature = "is_first_distinct")]
 pub use is_first_distinct::*;
 #[cfg(feature = "is_in")]

crates/polars-plan/Cargo.toml

@@ -94,6 +94,7 @@ round_series = ["polars-ops/round_series"]
 is_first_distinct = ["polars-core/is_first_distinct", "polars-ops/is_first_distinct"]
 is_last_distinct = ["polars-core/is_last_distinct", "polars-ops/is_last_distinct"]
 is_unique = ["polars-ops/is_unique"]
+is_between = ["polars-ops/is_between"]
 cross_join = ["polars-ops/cross_join"]
 asof_join = ["polars-core/asof_join", "polars-time", "polars-ops/asof_join"]
 concat_str = []

crates/polars-plan/src/dsl/function_expr/boolean.rs

@@ -26,6 +26,10 @@ pub enum BooleanFunction {
     IsUnique,
     #[cfg(feature = "is_unique")]
     IsDuplicated,
+    #[cfg(feature = "is_between")]
+    IsBetween {
+        closed: ClosedInterval,
+    },
     #[cfg(feature = "is_in")]
     IsIn,
     AllHorizontal,
@@ -64,6 +68,8 @@ impl Display for BooleanFunction {
             IsUnique => "is_unique",
             #[cfg(feature = "is_unique")]
             IsDuplicated => "is_duplicated",
+            #[cfg(feature = "is_between")]
+            IsBetween { .. } => "is_between",
             #[cfg(feature = "is_in")]
             IsIn => "is_in",
             AnyHorizontal => "any_horizontal",
@@ -94,6 +100,8 @@ impl From<BooleanFunction> for SpecialEq<Arc<dyn SeriesUdf>> {
             IsUnique => map!(is_unique),
             #[cfg(feature = "is_unique")]
             IsDuplicated => map!(is_duplicated),
+            #[cfg(feature = "is_between")]
+            IsBetween { closed } => map_as_slice!(is_between, closed),
             #[cfg(feature = "is_in")]
             IsIn => wrap!(is_in),
             AllHorizontal => map_as_slice!(all_horizontal),
@@ -171,6 +179,14 @@ fn is_duplicated(s: &Series) -> PolarsResult<Series> {
     polars_ops::prelude::is_duplicated(s).map(|ca| ca.into_series())
 }
 
+#[cfg(feature = "is_between")]
+fn is_between(s: &[Series], closed: ClosedInterval) -> PolarsResult<Series> {
+    let ser = &s[0];
+    let lower = &s[1];
+    let upper = &s[2];
+    polars_ops::prelude::is_between(ser, lower, upper, closed).map(|ca| ca.into_series())
+}
+
 #[cfg(feature = "is_in")]
 fn is_in(s: &mut [Series]) -> PolarsResult<Option<Series>> {
     let left = &s[0];

crates/polars-plan/src/dsl/mod.rs

@@ -1017,6 +1017,17 @@ impl Expr {
         self.apply_private(BooleanFunction::IsDuplicated.into())
     }
 
+    #[allow(clippy::wrong_self_convention)]
+    #[cfg(feature = "is_between")]
+    pub fn is_between<E: Into<Expr>>(self, lower: E, upper: E, closed: ClosedInterval) -> Self {
+        self.map_many_private(
+            BooleanFunction::IsBetween { closed }.into(),
+            &[lower.into(), upper.into()],
+            false,
+            true,
+        )
+    }
+
     /// Get a mask of unique values.
     #[allow(clippy::wrong_self_convention)]
     #[cfg(feature = "is_unique")]

crates/polars/Cargo.toml

@@ -119,6 +119,7 @@ repeat_by = ["polars-ops/repeat_by", "polars-lazy?/repeat_by"]
 is_first_distinct = ["polars-lazy?/is_first_distinct", "polars-ops/is_first_distinct"]
 is_last_distinct = ["polars-lazy?/is_last_distinct", "polars-ops/is_last_distinct"]
 is_unique = ["polars-lazy?/is_unique", "polars-ops/is_unique"]
+is_between = ["polars-lazy?/is_between", "polars-ops/is_between"]
 asof_join = ["polars-core/asof_join", "polars-lazy?/asof_join", "polars-ops/asof_join"]
 cross_join = ["polars-lazy?/cross_join", "polars-ops/cross_join"]
 dot_product = ["polars-core/dot_product"]
@@ -308,6 +309,7 @@ docs-selection = [
   "checked_arithmetic",
   "ndarray",
   "repeat_by",
+  "is_between",
   "is_first_distinct",
   "is_last_distinct",
   "asof_join",

crates/polars/src/lib.rs

@@ -240,6 +240,7 @@
 //!     - `repeat_by` - [Repeat element in an Array N times, where N is given by another array.
 //!     - `is_first_distinct` - Check if element is first unique value.
 //!     - `is_last_distinct` - Check if element is last unique value.
+//!     - `is_between` - Check if this expression is between the given lower and upper bounds.
 //!     - `checked_arithmetic` - checked arithmetic/ returning [`None`] on invalid operations.
 //!     - `dot_product` - Dot/inner product on [`Series`] and [`Expr`].
 //!     - `concat_str` - Concat string data in linear time.

py-polars/Cargo.toml

@@ -55,6 +55,7 @@ features = [
   "is_first_distinct",
   "is_last_distinct",
   "is_unique",
+  "is_between",
   "lazy",
   "list_eval",
   "list_to_struct",

py-polars/docs/source/reference/expressions/boolean.rst

@@ -17,6 +17,7 @@ Boolean
     Expr.is_infinite
     Expr.is_last
     Expr.is_last_distinct
+    Expr.is_between
     Expr.is_nan
     Expr.is_not
     Expr.is_not_nan

py-polars/docs/source/reference/series/descriptive.rst

@@ -22,6 +22,7 @@ Descriptive
     Series.is_integer
     Series.is_last
     Series.is_last_distinct
+    Series.is_between
     Series.is_nan
     Series.is_not_nan
     Series.is_not_null

py-polars/polars/expr/expr.py

@@ -5204,7 +5204,7 @@ def is_between(
         closed: ClosedInterval = "both",
     ) -> Self:
         """
-        Check if this expression is between the given start and end values.
+        Check if this expression is between the given lower and upper bounds.
 
         Parameters
         ----------
@@ -5281,22 +5281,12 @@ def is_between(
         └─────┴────────────┘
 
         """
-        lower_bound = self._from_pyexpr(parse_as_expression(lower_bound))
-        upper_bound = self._from_pyexpr(parse_as_expression(upper_bound))
+        lower_bound = parse_as_expression(lower_bound)
+        upper_bound = parse_as_expression(upper_bound)
 
-        if closed == "none":
-            return (self > lower_bound) & (self < upper_bound)
-        elif closed == "both":
-            return (self >= lower_bound) & (self <= upper_bound)
-        elif closed == "right":
-            return (self > lower_bound) & (self <= upper_bound)
-        elif closed == "left":
-            return (self >= lower_bound) & (self < upper_bound)
-        else:
-            raise ValueError(
-                "`closed` must be one of {'left', 'right', 'both', 'none'},"
-                f" got {closed!r}"
-            )
+        return self._from_pyexpr(
+            self._pyexpr.is_between(lower_bound, upper_bound, closed)
+        )
 
     def hash(
         self,

py-polars/polars/series/series.py

@@ -3894,7 +3894,7 @@ def is_between(
         closed: ClosedInterval = "both",
     ) -> Series:
         """
-        Get a boolean mask of the values that fall between the given start/end values.
+        Get a boolean mask of the values that are between the given lower/upper bounds.
 
         Parameters
         ----------

py-polars/src/conversion.rs

@@ -1424,6 +1424,23 @@ impl FromPyObject<'_> for Wrap<SearchSortedSide> {
     }
 }
 
+impl FromPyObject<'_> for Wrap<ClosedInterval> {
+    fn extract(ob: &PyAny) -> PyResult<Self> {
+        let parsed = match ob.extract::<&str>()? {
+            "both" => ClosedInterval::Both,
+            "left" => ClosedInterval::Left,
+            "right" => ClosedInterval::Right,
+            "none" => ClosedInterval::None,
+            v => {
+                return Err(PyValueError::new_err(format!(
+                    "`closed` must be one of {{'both', 'left', 'right', 'none'}}, got {v}",
+                )))
+            },
+        };
+        Ok(Wrap(parsed))
+    }
+}
+
 impl FromPyObject<'_> for Wrap<WindowMapping> {
     fn extract(ob: &PyAny) -> PyResult<Self> {
         let parsed = match ob.extract::<&str>()? {

py-polars/src/expr/general.rs

@@ -397,6 +397,13 @@ impl PyExpr {
         self.inner.clone().is_unique().into()
     }
 
+    fn is_between(&self, lower: Self, upper: Self, closed: Wrap<ClosedInterval>) -> Self {
+        self.clone()
+            .inner
+            .is_between(lower.inner, upper.inner, closed.0)
+            .into()
+    }
+
     fn approx_n_unique(&self) -> Self {
         self.inner.clone().approx_n_unique().into()
     }