Trait rlink::core::data_stream::TConnectedStreams

pub trait TConnectedStreams {
    fn key_by<F>(self, key_selector: F) -> KeyedStream
    where
        F: KeySelectorFunction + 'static;
    fn add_sink<O>(self, output_format: O)
    where
        O: OutputFormat + 'static;
}

Required methods

fn key_by<F>(self, key_selector: F) -> KeyedStream where
    F: KeySelectorFunction + 'static, 

Unlike flink, the key_by that receives only one KeySelector, that is, CoProcessFunction method output must have the same schema or with special flag.

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

Implementors

impl TConnectedStreams for ConnectedStreams