Open Max-Meldrum opened 2 years ago
Non-blocking pipeline operators such as map, filter, and flat_map do not have to implement Arcon's Operator trait. They can simply be Rust functions that can be chained/composed together (#246).
map, filter, and flat_map
Operator
Non-blocking pipeline operators such as
map, filter, and flat_mapdo not have to implement Arcon'sOperatortrait. They can simply be Rust functions that can be chained/composed together (#246).