Trait rlink::api::data_stream::TWindowedStream

pub trait TWindowedStream {
    fn reduce<F>(self, reduce: F, parallelism: u16) -> DataStream
    where
        F: ReduceFunction + 'static;
}

Required methods

fn reduce<F>(self, reduce: F, parallelism: u16) -> DataStream where
    F: ReduceFunction + 'static, 

Loading content...

Implementors

impl TWindowedStream for WindowedStream

fn reduce<F>(self, reduce: F, parallelism: u16) -> DataStream where
    F: ReduceFunction + 'static, 

Loading content...