Struct GenericDistinctBuffer 

pub struct GenericDistinctBuffer<T: ArrowPrimitiveType> {
    pub values: HashSet<Hashable<T::Native>, RandomState>,
    /* private fields */
}

Generic way to collect distinct values for accumulators.

The intermediate state is represented as a List of scalar values updated by merge_batch and a Vec of ArrayRef that are converted to scalar values in the final evaluation step so that we avoid expensive conversions and allocations during update_batch.

Fields

values: HashSet<Hashable<T::Native>, RandomState>

Implementations

impl<T: ArrowPrimitiveType> GenericDistinctBuffer<T>

pub fn new(data_type: DataType) -> Self

pub fn state(&self) -> Result<Vec<ScalarValue>>

Mirrors Accumulator::state.

pub fn update_batch(&mut self, values: &[ArrayRef]) -> Result<()>

Mirrors Accumulator::update_batch.

pub fn merge_batch(&mut self, states: &[ArrayRef]) -> Result<()>

Mirrors Accumulator::merge_batch.

pub fn size(&self) -> usize

Mirrors Accumulator::size.

Trait Implementations

impl<T: ArrowPrimitiveType> Debug for GenericDistinctBuffer<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.