Struct StreamProcessorBuilder 

pub struct StreamProcessorBuilder<T, A> { /* private fields */ }

Builder for creating stream processors

Implementations

impl<T, A> StreamProcessorBuilder<T, A>

where A: Aggregator<Input = f64, Output = f64> + Clone + Send + Sync + 'static,

pub fn new() -> Self

Create a new builder

pub fn with_config(self, config: StreamProcessorConfig) -> Self

Set configuration

pub fn allow_late_events(self, allow: bool, threshold: Duration) -> Self

Allow late events

pub fn watermark_interval(self, interval: Duration) -> Self

Set watermark interval

pub fn build_tumbling<F>( self, window_size: Duration, aggregator_factory: F, ) -> StreamProcessor<T, A, TumblingWindowAssigner, OnWatermarkTrigger>

where F: Fn(&str) -> A + Send + Sync + 'static,

Build with tumbling windows

pub fn build_sliding<F>( self, window_size: Duration, slide: Duration, aggregator_factory: F, ) -> StreamProcessor<T, A, SlidingWindowAssigner, OnWatermarkTrigger>

where F: Fn(&str) -> A + Send + Sync + 'static,

Build with sliding windows

pub fn build_session<F>( self, gap: Duration, aggregator_factory: F, ) -> StreamProcessor<T, A, SessionWindowAssigner, OnWatermarkTrigger>

where F: Fn(&str) -> A + Send + Sync + 'static,

Build with session windows

Trait Implementations

impl<T, A> Default for StreamProcessorBuilder<T, A>

where A: Aggregator<Input = f64, Output = f64> + Clone + Send + Sync + 'static,

fn default() -> Self

Returns the “default value” for a type.