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

pub struct Session<'a, T, CB, P> { /* 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: Container, P> Session<'a, T, CapacityContainerBuilder<C>, P>

where T: Eq + Clone + 'a, P: Push<Bundle<T, C>> + 'a,

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

Provide a container at the time specified by the Session.

impl<'a, T, CB, P> Session<'a, T, CB, P>

where T: Eq + Clone + 'a, CB: ContainerBuilder + 'a, P: Push<Bundle<T, CB::Container>> + 'a,

pub fn builder(&self) -> &CB

Access the builder. Immutable access to prevent races with flushing the underlying buffer.

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

where CB: PushInto<D>,

Provides one record at the time specified by the Session.

pub fn give_iterator<I>(&mut self, iter: I)

where I: Iterator, CB: PushInto<I::Item>,

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

Trait Implementations

impl<'a, T, CB, P, D> PushInto<D> for Session<'a, T, CB, P>

where T: Eq + Clone + 'a, CB: ContainerBuilder + PushInto<D> + 'a, P: Push<Bundle<T, CB::Container>> + 'a,

fn push_into(&mut self, item: D)

Push item into self.