Struct Ema 

pub struct Ema {
    pub period: usize,
}

Exponential Moving Average aggregation EMA = price * k + EMA(previous) * (1 - k) where k = 2 / (n + 1)

Fields

period: usize

Implementations

impl Ema

pub fn new(period: usize) -> Self

Trait Implementations

impl AggregateFunc for Ema

fn name(&self) -> &'static str

Returns the name of this aggregation function (e.g., “sum”, “avg”).

fn apply(&self, events: &[Event], field: Option<&str>) -> Value

Apply the aggregation to a slice of events.

fn apply_refs(&self, events: &[&Event], field: Option<&str>) -> Value

Apply aggregation to event references (internal helper)

fn apply_shared(&self, events: &[SharedEvent], field: Option<&str>) -> Value

Apply aggregation to shared events (avoids cloning in hot paths).

fn apply_columnar( &self, buffer: &mut ColumnarBuffer, field: Option<&str>, ) -> Value

Apply aggregation to columnar buffer (SIMD-optimized for numeric aggregations).

impl Debug for Ema

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

Formats the value using the given formatter.