polars_core/series/
series_trait.rs

1use std::any::Any;
2use std::borrow::Cow;
3
4use arrow::bitmap::{Bitmap, BitmapBuilder};
5use polars_compute::rolling::QuantileMethod;
6
7use crate::chunked_array::cast::CastOptions;
8#[cfg(feature = "object")]
9use crate::chunked_array::object::PolarsObjectSafe;
10use crate::prelude::*;
11use crate::utils::{first_non_null, last_non_null};
12
13#[derive(Debug, Copy, Clone, Eq, PartialEq, Hash)]
14pub enum IsSorted {
15    Ascending,
16    Descending,
17    Not,
18}
19
20impl IsSorted {
21    pub fn reverse(self) -> Self {
22        use IsSorted::*;
23        match self {
24            Ascending => Descending,
25            Descending => Ascending,
26            Not => Not,
27        }
28    }
29}
30
31pub enum BitRepr {
32    U8(UInt8Chunked),
33    U16(UInt16Chunked),
34    U32(UInt32Chunked),
35    U64(UInt64Chunked),
36    #[cfg(feature = "dtype-u128")]
37    U128(UInt128Chunked),
38}
39
40pub(crate) mod private {
41    use polars_utils::aliases::PlSeedableRandomStateQuality;
42
43    use super::*;
44    use crate::chunked_array::flags::StatisticsFlags;
45    use crate::chunked_array::ops::compare_inner::{TotalEqInner, TotalOrdInner};
46
47    pub trait PrivateSeriesNumeric {
48        /// Return a bit representation
49        ///
50        /// If there is no available bit representation this returns `None`.
51        fn bit_repr(&self) -> Option<BitRepr>;
52    }
53
54    pub trait PrivateSeries {
55        #[cfg(feature = "object")]
56        fn get_list_builder(
57            &self,
58            _name: PlSmallStr,
59            _values_capacity: usize,
60            _list_capacity: usize,
61        ) -> Box<dyn ListBuilderTrait> {
62            invalid_operation_panic!(get_list_builder, self)
63        }
64
65        /// Get field (used in schema)
66        fn _field(&self) -> Cow<'_, Field>;
67
68        fn _dtype(&self) -> &DataType;
69
70        fn compute_len(&mut self);
71
72        fn _get_flags(&self) -> StatisticsFlags;
73
74        fn _set_flags(&mut self, flags: StatisticsFlags);
75
76        unsafe fn equal_element(
77            &self,
78            _idx_self: usize,
79            _idx_other: usize,
80            _other: &Series,
81        ) -> bool {
82            invalid_operation_panic!(equal_element, self)
83        }
84        #[expect(clippy::wrong_self_convention)]
85        fn into_total_eq_inner<'a>(&'a self) -> Box<dyn TotalEqInner + 'a>;
86        #[expect(clippy::wrong_self_convention)]
87        fn into_total_ord_inner<'a>(&'a self) -> Box<dyn TotalOrdInner + 'a>;
88
89        fn vec_hash(
90            &self,
91            _build_hasher: PlSeedableRandomStateQuality,
92            _buf: &mut Vec<u64>,
93        ) -> PolarsResult<()>;
94        fn vec_hash_combine(
95            &self,
96            _build_hasher: PlSeedableRandomStateQuality,
97            _hashes: &mut [u64],
98        ) -> PolarsResult<()>;
99
100        /// # Safety
101        ///
102        /// Does no bounds checks, groups must be correct.
103        #[cfg(feature = "algorithm_group_by")]
104        unsafe fn agg_min(&self, groups: &GroupsType) -> Series {
105            Series::full_null(self._field().name().clone(), groups.len(), self._dtype())
106        }
107        /// # Safety
108        ///
109        /// Does no bounds checks, groups must be correct.
110        #[cfg(feature = "algorithm_group_by")]
111        unsafe fn agg_max(&self, groups: &GroupsType) -> Series {
112            Series::full_null(self._field().name().clone(), groups.len(), self._dtype())
113        }
114        /// # Safety
115        ///
116        /// Does no bounds checks, groups must be correct.
117        #[cfg(feature = "algorithm_group_by")]
118        unsafe fn agg_arg_min(&self, groups: &GroupsType) -> Series {
119            Series::full_null(self._field().name().clone(), groups.len(), &IDX_DTYPE)
120        }
121
122        /// # Safety
123        ///
124        /// Does no bounds checks, groups must be correct.
125        #[cfg(feature = "algorithm_group_by")]
126        unsafe fn agg_arg_max(&self, groups: &GroupsType) -> Series {
127            Series::full_null(self._field().name().clone(), groups.len(), &IDX_DTYPE)
128        }
129
130        /// If the [`DataType`] is one of `{Int8, UInt8, Int16, UInt16}` the `Series` is
131        /// first cast to `Int64` to prevent overflow issues.
132        #[cfg(feature = "algorithm_group_by")]
133        unsafe fn agg_sum(&self, groups: &GroupsType) -> Series {
134            Series::full_null(self._field().name().clone(), groups.len(), self._dtype())
135        }
136        /// # Safety
137        ///
138        /// Does no bounds checks, groups must be correct.
139        #[cfg(feature = "algorithm_group_by")]
140        unsafe fn agg_std(&self, groups: &GroupsType, _ddof: u8) -> Series {
141            Series::full_null(self._field().name().clone(), groups.len(), self._dtype())
142        }
143        /// # Safety
144        ///
145        /// Does no bounds checks, groups must be correct.
146        #[cfg(feature = "algorithm_group_by")]
147        unsafe fn agg_var(&self, groups: &GroupsType, _ddof: u8) -> Series {
148            Series::full_null(self._field().name().clone(), groups.len(), self._dtype())
149        }
150        /// # Safety
151        ///
152        /// Does no bounds checks, groups must be correct.
153        #[cfg(feature = "algorithm_group_by")]
154        unsafe fn agg_list(&self, groups: &GroupsType) -> Series {
155            Series::full_null(self._field().name().clone(), groups.len(), self._dtype())
156        }
157
158        /// # Safety
159        ///
160        /// Does no bounds checks, groups must be correct.
161        #[cfg(feature = "bitwise")]
162        unsafe fn agg_and(&self, groups: &GroupsType) -> Series {
163            Series::full_null(self._field().name().clone(), groups.len(), self._dtype())
164        }
165
166        /// # Safety
167        ///
168        /// Does no bounds checks, groups must be correct.
169        #[cfg(feature = "bitwise")]
170        unsafe fn agg_or(&self, groups: &GroupsType) -> Series {
171            Series::full_null(self._field().name().clone(), groups.len(), self._dtype())
172        }
173
174        /// # Safety
175        ///
176        /// Does no bounds checks, groups must be correct.
177        #[cfg(feature = "bitwise")]
178        unsafe fn agg_xor(&self, groups: &GroupsType) -> Series {
179            Series::full_null(self._field().name().clone(), groups.len(), self._dtype())
180        }
181
182        fn subtract(&self, _rhs: &Series) -> PolarsResult<Series> {
183            polars_bail!(opq = subtract, self._dtype());
184        }
185        fn add_to(&self, _rhs: &Series) -> PolarsResult<Series> {
186            polars_bail!(opq = add, self._dtype());
187        }
188        fn multiply(&self, _rhs: &Series) -> PolarsResult<Series> {
189            polars_bail!(opq = multiply, self._dtype());
190        }
191        fn divide(&self, _rhs: &Series) -> PolarsResult<Series> {
192            polars_bail!(opq = divide, self._dtype());
193        }
194        fn remainder(&self, _rhs: &Series) -> PolarsResult<Series> {
195            polars_bail!(opq = remainder, self._dtype());
196        }
197        #[cfg(feature = "algorithm_group_by")]
198        fn group_tuples(&self, _multithreaded: bool, _sorted: bool) -> PolarsResult<GroupsType> {
199            polars_bail!(opq = group_tuples, self._dtype());
200        }
201        #[cfg(feature = "zip_with")]
202        fn zip_with_same_type(
203            &self,
204            _mask: &BooleanChunked,
205            _other: &Series,
206        ) -> PolarsResult<Series> {
207            polars_bail!(opq = zip_with_same_type, self._dtype());
208        }
209
210        #[allow(unused_variables)]
211        fn arg_sort_multiple(
212            &self,
213            by: &[Column],
214            _options: &SortMultipleOptions,
215        ) -> PolarsResult<IdxCa> {
216            polars_bail!(opq = arg_sort_multiple, self._dtype());
217        }
218    }
219}
220
221pub trait SeriesTrait:
222    Send + Sync + private::PrivateSeries + private::PrivateSeriesNumeric
223{
224    /// Rename the Series.
225    fn rename(&mut self, name: PlSmallStr);
226
227    /// Get the lengths of the underlying chunks
228    fn chunk_lengths(&self) -> ChunkLenIter<'_>;
229
230    /// Name of series.
231    fn name(&self) -> &PlSmallStr;
232
233    /// Get field (used in schema)
234    fn field(&self) -> Cow<'_, Field> {
235        self._field()
236    }
237
238    /// Get datatype of series.
239    fn dtype(&self) -> &DataType {
240        self._dtype()
241    }
242
243    /// Underlying chunks.
244    fn chunks(&self) -> &Vec<ArrayRef>;
245
246    /// Underlying chunks.
247    ///
248    /// # Safety
249    /// The caller must ensure the length and the data types of `ArrayRef` does not change.
250    unsafe fn chunks_mut(&mut self) -> &mut Vec<ArrayRef>;
251
252    /// Number of chunks in this Series
253    fn n_chunks(&self) -> usize {
254        self.chunks().len()
255    }
256
257    /// Shrink the capacity of this array to fit its length.
258    fn shrink_to_fit(&mut self) {
259        // no-op
260    }
261
262    /// Take `num_elements` from the top as a zero copy view.
263    fn limit(&self, num_elements: usize) -> Series {
264        self.slice(0, num_elements)
265    }
266
267    /// Get a zero copy view of the data.
268    ///
269    /// When offset is negative the offset is counted from the
270    /// end of the array
271    fn slice(&self, _offset: i64, _length: usize) -> Series;
272
273    /// Get a zero copy view of the data.
274    ///
275    /// When offset is negative the offset is counted from the
276    /// end of the array
277    fn split_at(&self, _offset: i64) -> (Series, Series);
278
279    fn append(&mut self, other: &Series) -> PolarsResult<()>;
280    fn append_owned(&mut self, other: Series) -> PolarsResult<()>;
281
282    #[doc(hidden)]
283    fn extend(&mut self, _other: &Series) -> PolarsResult<()>;
284
285    /// Filter by boolean mask. This operation clones data.
286    fn filter(&self, _filter: &BooleanChunked) -> PolarsResult<Series>;
287
288    /// Take from `self` at the indexes given by `idx`.
289    ///
290    /// Null values in `idx` because null values in the output array.
291    ///
292    /// This operation is clone.
293    fn take(&self, _indices: &IdxCa) -> PolarsResult<Series>;
294
295    /// Take from `self` at the indexes given by `idx`.
296    ///
297    /// Null values in `idx` because null values in the output array.
298    ///
299    /// # Safety
300    /// This doesn't check any bounds.
301    unsafe fn take_unchecked(&self, _idx: &IdxCa) -> Series;
302
303    /// Take from `self` at the indexes given by `idx`.
304    ///
305    /// This operation is clone.
306    fn take_slice(&self, _indices: &[IdxSize]) -> PolarsResult<Series>;
307
308    /// Take from `self` at the indexes given by `idx`.
309    ///
310    /// # Safety
311    /// This doesn't check any bounds.
312    unsafe fn take_slice_unchecked(&self, _idx: &[IdxSize]) -> Series;
313
314    /// Get length of series.
315    fn len(&self) -> usize;
316
317    /// Check if Series is empty.
318    fn is_empty(&self) -> bool {
319        self.len() == 0
320    }
321
322    /// Check if Series only consists of nulls.
323    fn is_full_null(&self) -> bool {
324        self.len() == self.null_count()
325    }
326
327    /// Aggregate all chunks to a contiguous array of memory.
328    fn rechunk(&self) -> Series;
329
330    /// Returns the validity of this series as a single bitmap.
331    fn rechunk_validity(&self) -> Option<Bitmap> {
332        if self.chunks().len() == 1 {
333            return self.chunks()[0].validity().cloned();
334        }
335
336        if !self.has_nulls() || self.is_empty() {
337            return None;
338        }
339
340        let mut bm = BitmapBuilder::with_capacity(self.len());
341        for arr in self.chunks() {
342            if let Some(v) = arr.validity() {
343                bm.extend_from_bitmap(v);
344            } else {
345                bm.extend_constant(arr.len(), true);
346            }
347        }
348        bm.into_opt_validity()
349    }
350
351    /// Sets the validity mask of this Series to the given bitmap.
352    fn with_validity(&self, validity: Option<Bitmap>) -> Series;
353
354    /// Drop all null values and return a new Series.
355    fn drop_nulls(&self) -> Series {
356        if self.null_count() == 0 {
357            Series(self.clone_inner())
358        } else {
359            self.filter(&self.is_not_null()).unwrap()
360        }
361    }
362
363    /// Returns the sum of the array as an f64.
364    fn _sum_as_f64(&self) -> f64 {
365        invalid_operation_panic!(_sum_as_f64, self)
366    }
367
368    /// Returns the mean value in the array
369    /// Returns an option because the array is nullable.
370    fn mean(&self) -> Option<f64> {
371        None
372    }
373
374    /// Returns the std value in the array
375    /// Returns an option because the array is nullable.
376    fn std(&self, _ddof: u8) -> Option<f64> {
377        None
378    }
379
380    /// Returns the var value in the array
381    /// Returns an option because the array is nullable.
382    fn var(&self, _ddof: u8) -> Option<f64> {
383        None
384    }
385
386    /// Returns the median value in the array
387    /// Returns an option because the array is nullable.
388    fn median(&self) -> Option<f64> {
389        None
390    }
391
392    /// Create a new Series filled with values from the given index.
393    ///
394    /// # Example
395    ///
396    /// ```rust
397    /// use polars_core::prelude::*;
398    /// let s = Series::new("a".into(), [0i32, 1, 8]);
399    /// let s2 = s.new_from_index(2, 4);
400    /// assert_eq!(Vec::from(s2.i32().unwrap()), &[Some(8), Some(8), Some(8), Some(8)])
401    /// ```
402    fn new_from_index(&self, _index: usize, _length: usize) -> Series;
403
404    /// Trim all lists of unused start and end elements recursively.
405    ///
406    /// - `None` if nothing needed to be done.
407    /// - `Some(series)` if something changed.
408    fn trim_lists_to_normalized_offsets(&self) -> Option<Series> {
409        None
410    }
411
412    /// Propagate down nulls in nested types.
413    ///
414    /// - `None` if nothing needed to be done.
415    /// - `Some(series)` if something changed.
416    fn propagate_nulls(&self) -> Option<Series> {
417        None
418    }
419
420    fn deposit(&self, validity: &Bitmap) -> Series;
421
422    /// Find the indices of elements where the null masks are different recursively.
423    fn find_validity_mismatch(&self, other: &Series, idxs: &mut Vec<IdxSize>);
424
425    fn cast(&self, _dtype: &DataType, options: CastOptions) -> PolarsResult<Series>;
426
427    /// Get a single value by index. Don't use this operation for loops as a runtime cast is
428    /// needed for every iteration.
429    fn get(&self, index: usize) -> PolarsResult<AnyValue<'_>> {
430        polars_ensure!(index < self.len(), oob = index, self.len());
431        // SAFETY: Just did bounds check
432        let value = unsafe { self.get_unchecked(index) };
433        Ok(value)
434    }
435
436    /// Get a single value by index. Don't use this operation for loops as a runtime cast is
437    /// needed for every iteration.
438    ///
439    /// This may refer to physical types
440    ///
441    /// # Safety
442    /// Does not do any bounds checking
443    unsafe fn get_unchecked(&self, _index: usize) -> AnyValue<'_>;
444
445    fn sort_with(&self, _options: SortOptions) -> PolarsResult<Series> {
446        polars_bail!(opq = sort_with, self._dtype());
447    }
448
449    /// Retrieve the indexes needed for a sort.
450    #[allow(unused)]
451    fn arg_sort(&self, options: SortOptions) -> IdxCa {
452        invalid_operation_panic!(arg_sort, self)
453    }
454
455    /// Count the null values.
456    fn null_count(&self) -> usize;
457
458    /// Return if any the chunks in this [`ChunkedArray`] have nulls.
459    fn has_nulls(&self) -> bool;
460
461    /// Get unique values in the Series.
462    fn unique(&self) -> PolarsResult<Series> {
463        polars_bail!(opq = unique, self._dtype());
464    }
465
466    /// Get unique values in the Series.
467    ///
468    /// A `null` value also counts as a unique value.
469    fn n_unique(&self) -> PolarsResult<usize> {
470        polars_bail!(opq = n_unique, self._dtype());
471    }
472
473    /// Get first indexes of unique values.
474    fn arg_unique(&self) -> PolarsResult<IdxCa> {
475        polars_bail!(opq = arg_unique, self._dtype());
476    }
477
478    /// Get dense ids for each unique value.
479    ///
480    /// Returns: (n_unique, unique_ids)
481    fn unique_id(&self) -> PolarsResult<(IdxSize, Vec<IdxSize>)>;
482
483    /// Get a mask of the null values.
484    fn is_null(&self) -> BooleanChunked;
485
486    /// Get a mask of the non-null values.
487    fn is_not_null(&self) -> BooleanChunked;
488
489    /// return a Series in reversed order
490    fn reverse(&self) -> Series;
491
492    /// Rechunk and return a pointer to the start of the Series.
493    /// Only implemented for numeric types
494    fn as_single_ptr(&mut self) -> PolarsResult<usize> {
495        polars_bail!(opq = as_single_ptr, self._dtype());
496    }
497
498    /// Shift the values by a given period and fill the parts that will be empty due to this operation
499    /// with `Nones`.
500    ///
501    /// *NOTE: If you want to fill the Nones with a value use the
502    /// [`shift` operation on `ChunkedArray<T>`](../chunked_array/ops/trait.ChunkShift.html).*
503    ///
504    /// # Example
505    ///
506    /// ```rust
507    /// # use polars_core::prelude::*;
508    /// fn example() -> PolarsResult<()> {
509    ///     let s = Series::new("series".into(), &[1, 2, 3]);
510    ///
511    ///     let shifted = s.shift(1);
512    ///     assert_eq!(Vec::from(shifted.i32()?), &[None, Some(1), Some(2)]);
513    ///
514    ///     let shifted = s.shift(-1);
515    ///     assert_eq!(Vec::from(shifted.i32()?), &[Some(2), Some(3), None]);
516    ///
517    ///     let shifted = s.shift(2);
518    ///     assert_eq!(Vec::from(shifted.i32()?), &[None, None, Some(1)]);
519    ///
520    ///     Ok(())
521    /// }
522    /// example();
523    /// ```
524    fn shift(&self, _periods: i64) -> Series;
525
526    /// Get the sum of the Series as a new Scalar.
527    ///
528    /// If the [`DataType`] is one of `{Int8, UInt8, Int16, UInt16}` the `Series` is
529    /// first cast to `Int64` to prevent overflow issues.
530    fn sum_reduce(&self) -> PolarsResult<Scalar> {
531        polars_bail!(opq = sum, self._dtype());
532    }
533    /// Get the max of the Series as a new Series of length 1.
534    fn max_reduce(&self) -> PolarsResult<Scalar> {
535        polars_bail!(opq = max, self._dtype());
536    }
537    /// Get the min of the Series as a new Series of length 1.
538    fn min_reduce(&self) -> PolarsResult<Scalar> {
539        polars_bail!(opq = min, self._dtype());
540    }
541    /// Get the median of the Series as a new Series of length 1.
542    fn median_reduce(&self) -> PolarsResult<Scalar> {
543        polars_bail!(opq = median, self._dtype());
544    }
545    /// Get the mean of the Series as a new Scalar
546    fn mean_reduce(&self) -> PolarsResult<Scalar> {
547        polars_bail!(opq = mean, self._dtype());
548    }
549    /// Get the variance of the Series as a new Series of length 1.
550    fn var_reduce(&self, _ddof: u8) -> PolarsResult<Scalar> {
551        polars_bail!(opq = var, self._dtype());
552    }
553    /// Get the standard deviation of the Series as a new Series of length 1.
554    fn std_reduce(&self, _ddof: u8) -> PolarsResult<Scalar> {
555        polars_bail!(opq = std, self._dtype());
556    }
557    /// Get the quantile of the Series as a new Series of length 1.
558    fn quantile_reduce(&self, _quantile: f64, _method: QuantileMethod) -> PolarsResult<Scalar> {
559        polars_bail!(opq = quantile, self._dtype());
560    }
561    /// Get multiple quantiles of the ChunkedArray as a new `List` Scalar
562    fn quantiles_reduce(
563        &self,
564        _quantiles: &[f64],
565        _method: QuantileMethod,
566    ) -> PolarsResult<Scalar> {
567        polars_bail!(opq = quantiles, self._dtype());
568    }
569    /// Get the bitwise AND of the Series as a new Series of length 1,
570    fn and_reduce(&self) -> PolarsResult<Scalar> {
571        polars_bail!(opq = and_reduce, self._dtype());
572    }
573    /// Get the bitwise OR of the Series as a new Series of length 1,
574    fn or_reduce(&self) -> PolarsResult<Scalar> {
575        polars_bail!(opq = or_reduce, self._dtype());
576    }
577    /// Get the bitwise XOR of the Series as a new Series of length 1,
578    fn xor_reduce(&self) -> PolarsResult<Scalar> {
579        polars_bail!(opq = xor_reduce, self._dtype());
580    }
581
582    /// Get the first element of the [`Series`] as a [`Scalar`]
583    ///
584    /// If the [`Series`] is empty, a [`Scalar`] with a [`AnyValue::Null`] is returned.
585    fn first(&self) -> Scalar {
586        let dt = self.dtype();
587        let av = self.get(0).map_or(AnyValue::Null, AnyValue::into_static);
588
589        Scalar::new(dt.clone(), av)
590    }
591
592    /// Get the first non-null element of the [`Series`] as a [`Scalar`]
593    ///
594    /// If the [`Series`] is empty, a [`Scalar`] with a [`AnyValue::Null`] is returned.
595    fn first_non_null(&self) -> Scalar {
596        let av = if self.len() == 0 {
597            AnyValue::Null
598        } else {
599            let idx = if self.has_nulls() {
600                first_non_null(self.chunks().iter().map(|c| c.as_ref())).unwrap_or(0)
601            } else {
602                0
603            };
604            self.get(idx).map_or(AnyValue::Null, AnyValue::into_static)
605        };
606        Scalar::new(self.dtype().clone(), av)
607    }
608
609    /// Get the last element of the [`Series`] as a [`Scalar`]
610    ///
611    /// If the [`Series`] is empty, a [`Scalar`] with a [`AnyValue::Null`] is returned.
612    fn last(&self) -> Scalar {
613        let dt = self.dtype();
614        let av = if self.len() == 0 {
615            AnyValue::Null
616        } else {
617            // SAFETY: len-1 < len if len != 0
618            unsafe { self.get_unchecked(self.len() - 1) }.into_static()
619        };
620
621        Scalar::new(dt.clone(), av)
622    }
623
624    /// Get the last non-null element of the [`Series`] as a [`Scalar`]
625    ///
626    /// If the [`Series`] is empty, a [`Scalar`] with a [`AnyValue::Null`] is returned.
627    fn last_non_null(&self) -> Scalar {
628        let n = self.len();
629        let av = if n == 0 {
630            AnyValue::Null
631        } else {
632            let idx = if self.has_nulls() {
633                last_non_null(self.chunks().iter().map(|c| c.as_ref()), n).unwrap_or(n - 1)
634            } else {
635                n - 1
636            };
637            // SAFETY: len-1 < len if len != 0
638            unsafe { self.get_unchecked(idx) }.into_static()
639        };
640        Scalar::new(self.dtype().clone(), av)
641    }
642
643    #[cfg(feature = "approx_unique")]
644    fn approx_n_unique(&self) -> PolarsResult<IdxSize> {
645        polars_bail!(opq = approx_n_unique, self._dtype());
646    }
647
648    /// Clone inner ChunkedArray and wrap in a new Arc
649    fn clone_inner(&self) -> Arc<dyn SeriesTrait>;
650
651    #[cfg(feature = "object")]
652    /// Get the value at this index as a downcastable Any trait ref.
653    fn get_object(&self, _index: usize) -> Option<&dyn PolarsObjectSafe> {
654        invalid_operation_panic!(get_object, self)
655    }
656
657    #[cfg(feature = "object")]
658    /// Get the value at this index as a downcastable Any trait ref.
659    ///
660    /// # Safety
661    /// This function doesn't do any bound checks.
662    unsafe fn get_object_chunked_unchecked(
663        &self,
664        _chunk: usize,
665        _index: usize,
666    ) -> Option<&dyn PolarsObjectSafe> {
667        invalid_operation_panic!(get_object_chunked_unchecked, self)
668    }
669
670    /// Get a hold of the [`ChunkedArray`], [`Logical`] or `NullChunked` as an `Any` trait
671    /// reference.
672    fn as_any(&self) -> &dyn Any;
673
674    /// Get a hold of the [`ChunkedArray`], [`Logical`] or `NullChunked` as an `Any` trait mutable
675    /// reference.
676    fn as_any_mut(&mut self) -> &mut dyn Any;
677
678    /// Get a hold of the [`ChunkedArray`] or `NullChunked` as an `Any` trait reference. This
679    /// pierces through `Logical` types to get the underlying physical array.
680    fn as_phys_any(&self) -> &dyn Any;
681
682    fn as_arc_any(self: Arc<Self>) -> Arc<dyn Any + Send + Sync>;
683
684    #[cfg(feature = "checked_arithmetic")]
685    fn checked_div(&self, _rhs: &Series) -> PolarsResult<Series> {
686        polars_bail!(opq = checked_div, self._dtype());
687    }
688
689    #[cfg(feature = "rolling_window")]
690    /// Apply a custom function over a rolling/ moving window of the array.
691    /// This has quite some dynamic dispatch, so prefer rolling_min, max, mean, sum over this.
692    fn rolling_map(
693        &self,
694        _f: &dyn Fn(&Series) -> PolarsResult<Series>,
695        _options: RollingOptionsFixedWindow,
696    ) -> PolarsResult<Series> {
697        polars_bail!(opq = rolling_map, self._dtype());
698    }
699}
700
701impl dyn SeriesTrait + '_ {
702    pub fn unpack<T: PolarsPhysicalType>(&self) -> PolarsResult<&ChunkedArray<T>> {
703        polars_ensure!(&T::get_static_dtype() == self.dtype(), unpack);
704        Ok(self.as_ref())
705    }
706}
polars_core/series/series_trait.rs

polars_core/series/
series_trait.rs
