Struct UddSketchState 

pub struct UddSketchState {
    uddsketch: UDDSketch,
    error_rate: f64,
}

Fields

uddsketch: UDDSketch

error_rate: f64

Implementations

impl UddSketchState

pub fn new(bucket_size: u64, error_rate: f64) -> Self

pub fn state_udf_impl() -> AggregateUDF

pub fn merge_udf_impl() -> AggregateUDF

Create a UDF for the uddsketch_merge function.

uddsketch_merge accepts bucket size, error rate, and a binary column of states generated by uddsketch_state and merges them into a single state.

The bucket size and error rate must be the same as the original state.

fn update(&mut self, value: f64)

fn merge(&mut self, raw: &[u8]) -> DfResult<()>

Trait Implementations

impl Accumulator for UddSketchState

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

Updates the accumulator’s state from its input.

fn evaluate(&mut self) -> DfResult<ScalarValue>

Returns the final aggregate value, consuming the internal state.

fn size(&self) -> usize

Returns the allocated size required for this accumulator, in bytes, including Self.

fn state(&mut self) -> DfResult<Vec<ScalarValue>>

Returns the intermediate state of the accumulator, consuming the intermediate state.

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

Updates the accumulator’s state from an Array containing one or more intermediate values.

fn retract_batch( &mut self, _values: &[Arc<dyn Array>], ) -> Result<(), DataFusionError>

Retracts (removed) an update (caused by the given inputs) to accumulator’s state.

fn supports_retract_batch(&self) -> bool

Does the accumulator support incrementally updating its value by removing values.

impl Debug for UddSketchState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for UddSketchState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for UddSketchState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.