Trait tamar::WindowFactory

pub trait WindowFactory {
    type Processor<V>: WindowProcessor<V>
       where V: Send + 'static;
    type Aggregator<V>: WindowAggregator<V>
       where V: Send + 'static;

    // Required methods
    fn processor<V>(&self) -> Self::Processor<V>
       where V: Send + 'static;
    fn aggregator<V>(&self) -> Self::Aggregator<V>
       where V: Send + 'static;
}

Required Associated Types

type Processor<V>: WindowProcessor<V> where V: Send + 'static

type Aggregator<V>: WindowAggregator<V> where V: Send + 'static

Required Methods

fn processor<V>(&self) -> Self::Processor<V>where V: Send + 'static,

fn aggregator<V>(&self) -> Self::Aggregator<V>where V: Send + 'static,

Implementors

impl WindowFactory for EventTimeSessionWindowFactory

type Processor<V> where V: Send + 'static = EventTimeSessionWindowProcessor<V>

type Aggregator<V> where V: Send + 'static = EventTimeSessionWindowAggregator<V>