Open Max-Meldrum opened 2 years ago
An Operator that both filters and maps.
Akin to Rust's own FilterMap but on a Stream rather than Iterator.
Stream
Iterator
let strings = ["1", "two", "NaN", "four", "5"]; let mut app = Application::default() .iterator(strings, |conf| { conf.set_arcon_time(ArconTime::Process); }) .filter_map(|s| s.parse().ok()) .build();
An Operator that both filters and maps.
Akin to Rust's own FilterMap but on a
Stream
rather thanIterator
.