Trait timely::dataflow::operators::filter::Filter

pub trait Filter<D: Data> {
    fn filter<P: FnMut(&D) -> bool + 'static>(&self, predicate: P) -> Self;
}

Extension trait for filtering.

Required methods

fn filter<P: FnMut(&D) -> bool + 'static>(&self, predicate: P) -> 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));
});

Loading content...

Implementors

impl<G: Scope, D: Data> Filter<D> for Stream<G, D>

fn filter<P: FnMut(&D) -> bool + 'static>(&self, predicate: P) -> Stream<G, D>

Loading content...