Trait rlink::api::data_stream::TConnectedStreams [−][src]
Required methods
fn key_by<F>(self, key_selector: F) -> KeyedStream where
F: KeySelectorFunction + 'static,
[src]
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,
[src]
O: OutputFormat + 'static,
Implementors
impl TConnectedStreams for ConnectedStreams
[src]
fn key_by<F>(self, key_selector: F) -> KeyedStream where
F: KeySelectorFunction + 'static,
[src]
F: KeySelectorFunction + 'static,
fn add_sink<O>(self, output_format: O) where
O: OutputFormat + 'static,
[src]
O: OutputFormat + 'static,