Trait timely::dataflow::operators::broadcast::Broadcast

pub trait Broadcast<D: ExchangeData> {
    fn broadcast(&self) -> Self;
}

Broadcast records to all workers.

Required Methods

fn broadcast(&self) -> Self

Broadcast records to all workers.

Examples

use timely::dataflow::operators::{ToStream, Broadcast, Inspect};

timely::example(|scope| {
    (0..10).to_stream(scope)
           .broadcast()
           .inspect(|x| println!("seen: {:?}", x));
});

Implementors

• impl<G: Scope, D: ExchangeData> Broadcast<D> for Stream<G, D>