Trait rlink::core::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]
W: WindowAssigner + 'static,
fn add_sink<O>(self, output_format: O) -> SinkStream where
O: OutputFormat + 'static,
[src]
O: OutputFormat + 'static,
Implementors
impl TKeyedStream for KeyedStream
[src]
impl TKeyedStream for KeyedStream
[src]fn window<W>(self, window_assigner: W) -> WindowedStream where
W: WindowAssigner + 'static,
[src]
W: WindowAssigner + 'static,
fn add_sink<O>(self, output_format: O) -> SinkStream where
O: OutputFormat + 'static,
[src]
O: OutputFormat + 'static,