Struct timely::dataflow::channels::pushers::exchange::Exchange

pub struct Exchange<T, C: PushPartitioned, P: Push<Bundle<T, C>>, H>
where
    for<'a> H: FnMut(&C::Item<'a>) -> u64,
{ /* private fields */ }

Distributes records among target pushees according to a distribution function.

Implementations

impl<T: Clone, C: PushPartitioned, P: Push<Bundle<T, C>>, H> Exchange<T, C, P, H>

where for<'a> H: FnMut(&C::Item<'a>) -> u64,

pub fn new(pushers: Vec<P>, key: H) -> Exchange<T, C, P, H>

Allocates a new Exchange from a supplied set of pushers and a distribution function.

Trait Implementations

impl<T: Eq + Data, C, P: Push<Bundle<T, C>>, H> Push<Bincode<Message<T, C>>> for Exchange<T, C, P, H>

where C: PushPartitioned + Container, for<'a> H: FnMut(&C::Item<'a>) -> u64,

fn push(&mut self, message: &mut Option<Bundle<T, C>>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.