Struct Aggregate 

pub struct Aggregate {
    pub key_field: String,
    pub value_field: String,
    pub op: AggregationKind,
    /* private fields */
}

Simple aggregate that maintains a per-minute count per key_field. Simple aggregate that maintains a per-minute count per key_field.

Example

use pulse_ops::Aggregate;
let agg = Aggregate::count_per_window("key", "word");

Fields

key_field: String

value_field: String

op: AggregationKind

Implementations

impl Aggregate

pub fn count_per_window( key_field: impl Into<String>, value_field: impl Into<String>, ) -> Self

Trait Implementations

impl Operator for Aggregate

fn on_element<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 mut dyn Context, rec: Record, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn on_watermark<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut dyn Context, _wm: Watermark, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn on_timer<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut dyn Context, _when: EventTime, _key: Option<Vec<u8>>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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