Trait rlink::core::data_stream::TKeyedStream

pub trait TKeyedStream {
    fn window<W>(self, window_assigner: W) -> WindowedStream
    where
        W: WindowAssigner + 'static;
    fn add_sink<O>(self, output_format: O) -> SinkStream
    where
        O: OutputFormat + 'static;
}

Required methods

fn window<W>(self, window_assigner: W) -> WindowedStream where
    W: WindowAssigner + 'static, 

fn add_sink<O>(self, output_format: O) -> SinkStream where
    O: OutputFormat + 'static, 

Implementors

impl TKeyedStream for KeyedStream