Struct AggregateOperator 

pub struct AggregateOperator<T, A>
where
    T: Send + Sync + Clone,
    A: Aggregator<Input = T> + Send + Sync,
{ /* private fields */ }

Aggregate operator - computes aggregations over windows

Example

use processor::pipeline::operator::AggregateOperator;
use processor::aggregation::{Aggregator, SumAggregator};

let aggregator = SumAggregator::new();
let operator = AggregateOperator::new("sum", aggregator);

Implementations

impl<T, A> AggregateOperator<T, A>

where T: Send + Sync + Clone, A: Aggregator<Input = T> + Send + Sync,

pub fn new<S: Into<String>>(name: S, aggregator: A) -> Self

Create a new aggregate operator

pub fn aggregator(&self) -> &Arc<Mutex<A>>

Get a reference to the aggregator

Trait Implementations

impl<T, A> Clone for AggregateOperator<T, A>

where T: Send + Sync + Clone, A: Aggregator<Input = T> + Send + Sync,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T, A> Debug for AggregateOperator<T, A>

where T: Send + Sync + Clone, A: Aggregator<Input = T> + Send + Sync,

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

Formats the value using the given formatter.

impl<T, A> StreamOperator for AggregateOperator<T, A>

where T: Send + Sync + Clone + DeserializeOwned + Serialize, A: Aggregator<Input = T, Output = T> + Send + Sync,

fn process<'life0, 'life1, 'async_trait>( &'life0 self, input: Vec<u8>, _ctx: &'life1 OperatorContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<u8>>>> + Send + 'async_trait>>

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

Process an event and return transformed events

fn name(&self) -> &str

Get the operator name

fn open<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when the operator is initialized

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when the operator is shut down