Struct DdSketchAggregator 

pub struct DdSketchAggregator { /* private fields */ }

Available on crate feature metrics only.

DDSKetch quantile sketch algorithm

It can give q-quantiles with α-accurate for any 0<=q<=1.

Here the accurate is calculated based on relative-error rate. Thus, the error guarantee adapts the scale of the output data. With relative error guarantee, the histogram can be more accurate in the area of low data density. For example, the long tail of response time data.

For example, if the actual percentile is 1 second, and relative-error guarantee is 2%, then the value should within the range of 0.98 to 1.02 second. But if the actual percentile is 1 millisecond, with the same relative-error guarantee, the value returned should within the range of 0.98 to 1.02 millisecond.

In order to support both negative and positive inputs, DDSketchAggregator has two DDSketch store within itself to store the negative and positive inputs.

Implementations

impl DdSketchAggregator

pub fn new(config: &DdSketchConfig, kind: NumberKind) -> DdSketchAggregator

Create a new DDSKetchAggregator that would yield a quantile with relative error rate less than alpha

The input should have a granularity larger than key_epsilon

Trait Implementations

impl Aggregator for DdSketchAggregator

fn update(&self, number: &Number, descriptor: &Descriptor) -> Result<()>

Update receives a new measured value and incorporates it into the aggregation. Update calls may be called concurrently.

fn synchronized_move( &self, destination: &Arc<dyn Aggregator + Send + Sync>, descriptor: &Descriptor, ) -> Result<()>

This method is called during collection to finish one period of aggregation by atomically saving the currently-updating state into the argument Aggregator.

fn merge( &self, other: &(dyn Aggregator + Send + Sync), _descriptor: &Descriptor, ) -> Result<()>

This combines the checkpointed state from the argument Aggregator into this Aggregator. merge is not synchronized with respect to update or synchronized_move.

fn as_any(&self) -> &dyn Any

Returns the implementing aggregator as Any for downcasting.

impl Count for DdSketchAggregator

fn count(&self) -> Result<u64>

The count of the currently aggregated metrics

impl Debug for DdSketchAggregator

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

Formats the value using the given formatter.

impl Default for DdSketchAggregator

fn default() -> Self

Returns the “default value” for a type.

impl Max for DdSketchAggregator

fn max(&self) -> Result<Number>

The max of the currently aggregated metrics

impl Min for DdSketchAggregator

fn min(&self) -> Result<Number>

The min of the currently aggregated metrics

impl Sum for DdSketchAggregator

fn sum(&self) -> Result<Number>

The sum of the currently aggregated metrics

impl MinMaxSumCount for DdSketchAggregator