Struct VecMaskGroupedReduction 

pub struct VecMaskGroupedReduction<R: Reducer> { /* private fields */ }

Trait Implementations

impl<R> GroupedReduction for VecMaskGroupedReduction<R>

where R: Reducer,

fn new_empty(&self) -> Box<dyn GroupedReduction>

Returns a new empty reduction.

fn reserve(&mut self, additional: usize)

Reserves space in this GroupedReduction for an additional number of groups.

fn resize(&mut self, num_groups: IdxSize)

Resizes this GroupedReduction to the given number of groups.

fn update_group( &mut self, values: &Column, group_idx: IdxSize, seq_id: u64, ) -> PolarsResult<()>

Updates the specified group with the given values.

unsafe fn update_groups_while_evicting( &mut self, values: &Column, subset: &[IdxSize], group_idxs: &[EvictIdx], seq_id: u64, ) -> PolarsResult<()>

Updates this GroupedReduction with new values. values[subset[i]] should be added to reduction self[group_idxs[i]]. For order-sensitive grouped reductions, seq_id can be used to resolve order between calls/multiple reductions. If the group_idxs[i] has its evict bit set the current value in the group should be evicted and reset before updating.

unsafe fn combine_subset( &mut self, other: &dyn GroupedReduction, subset: &[IdxSize], group_idxs: &[IdxSize], ) -> PolarsResult<()>

Combines this GroupedReduction with another. Group other[subset[i]] should be combined into group self[group_idxs[i]].

fn take_evictions(&mut self) -> Box<dyn GroupedReduction>

Take the accumulated evicted groups.

fn finalize(&mut self) -> PolarsResult<Series>

Returns the finalized value per group as a Series.

fn as_any(&self) -> &dyn Any

Returns this GroupedReduction as a dyn Any.

unsafe fn update_groups_subset( &mut self, values: &Column, subset: &[IdxSize], group_idxs: &[IdxSize], seq_id: u64, ) -> PolarsResult<()>

Updates this GroupedReduction with new values. values[subset[i]] should be added to reduction self[group_idxs[i]]. For order-sensitive grouped reductions, seq_id can be used to resolve order between calls/multiple reductions.