[−][src]Trait timely::dataflow::operators::filter::Filter
Extension trait for filtering.
Required methods
fn filter(&self, predicate: impl Fn(&D) -> bool + 'static) -> Self
Returns a new instance of self
containing only records satisfying predicate
.
Examples
use timely::dataflow::operators::{ToStream, Filter, Inspect}; timely::example(|scope| { (0..10).to_stream(scope) .filter(|x| *x % 2 == 0) .inspect(|x| println!("seen: {:?}", x)); });