FilterMap Operator
Max-Meldrum opened this issue · 0 comments
Max-Meldrum commented
An Operator that both filters and maps.
Akin to Rust's own FilterMap but on a Stream
rather than 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();