Struct timely::dataflow::channels::pushers::buffer::Session

pub struct Session<'a, T, C, P: Push<Bundle<T, C>> + 'a>
where
    T: Eq + Clone + 'a,
    C: 'a + Container,
{ /* private fields */ }

An output session for sending records at a specified time.

The Session struct provides the user-facing interface to an operator output, namely the Buffer type. A Session wraps a session of output at a specified time, and avoids what would otherwise be a constant cost of checking timestamp equality.

Implementations

impl<'a, T, C, P: Push<Bundle<T, C>> + 'a> Session<'a, T, C, P>

where T: Eq + Clone + 'a, C: 'a + Container,

pub fn give_container(&mut self, container: &mut C)

Provide a container at the time specified by the Session.

impl<'a, T, C, P: Push<Bundle<T, C>> + 'a> Session<'a, T, C, P>

where T: Eq + Clone + 'a, C: 'a + PushContainer,

pub fn give<D: PushInto<C>>(&mut self, data: D)

Provides one record at the time specified by the Session.

pub fn give_iterator<I: Iterator<Item = D>, D: PushInto<C>>(&mut self, iter: I)

Provides an iterator of records at the time specified by the Session.

impl<'a, T, D, P: Push<Bundle<T, Vec<D>>> + 'a> Session<'a, T, Vec<D>, P>

where T: Eq + Clone + 'a, D: 'a + Data,

pub fn give_vec(&mut self, message: &mut Vec<D>)

Provides a fully formed Content<D> message for senders which can use this type.

The Content type is the backing memory for communication in timely, and it can often be more efficient to reuse this memory rather than have timely allocate new backing memory.