Trait rlink::core::data_stream::TConnectedStreams [−][src]
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,
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.