Trait timely::dataflow::operators::broadcast::Broadcast[−][src]

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

Broadcast records to all workers.

Required methods

fn broadcast(&self) -> Self[src]

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));
});
Loading content...

Implementors

impl<G: Scope, D: ExchangeData> Broadcast<D> for Stream<G, D>[src]

Loading content...