Trait rlink::api::data_stream::TKeyedStream[−][src]

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, [src]

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

Loading content...

Implementors

impl TKeyedStream for KeyedStream[src]

Loading content...