Struct GroupedAnalyzerWrapper 

pub struct GroupedAnalyzerWrapper<A: GroupedAnalyzer> { /* private fields */ }

Wrapper that adds grouping capability to any analyzer that implements GroupedAnalyzer.

Implementations

impl<A: GroupedAnalyzer> GroupedAnalyzerWrapper<A>

pub fn new(analyzer: A, config: GroupingConfig) -> Self

Creates a new grouped analyzer wrapper.

Trait Implementations

impl<A> Analyzer for GroupedAnalyzerWrapper<A>

where A: GroupedAnalyzer + Send + Sync + 'static, A::GroupedState: AnalyzerState + 'static,

type State = <A as GroupedAnalyzer>::GroupedState

The state type for incremental computation.

type Metric = MetricValue

The metric type produced by this analyzer.

fn compute_state_from_data<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, ) -> Pin<Box<dyn Future<Output = AnalyzerResult<Self::State>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Computes the state from the input data.

fn compute_metric_from_state( &self, state: &Self::State, ) -> AnalyzerResult<Self::Metric>

Computes the final metric from the accumulated state.

fn name(&self) -> &str

Returns the name of this analyzer.

fn description(&self) -> &str

Returns a description of what this analyzer computes.

fn metric_key(&self) -> String

Returns the metric key for storing results.

fn columns(&self) -> Vec<&str>

Returns the column(s) this analyzer operates on, if any.

fn merge_states(&self, states: Vec<Self::State>) -> AnalyzerResult<Self::State>

Merges multiple states into a single state.

fn is_combinable(&self) -> bool

Indicates whether this analyzer can be combined with others.

impl<A: GroupedAnalyzer> Debug for GroupedAnalyzerWrapper<A>

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

Formats the value using the given formatter.