Struct InputHandleCore

pub struct InputHandleCore<T: Timestamp, C, P: Pull<Message<T, C>>> { /* private fields */ }

Handle to an operator’s input stream.

Implementations

impl<T: Timestamp, C: Accountable, P: Pull<Message<T, C>>> InputHandleCore<T, C, P>

pub fn activate(&mut self) -> InputSession<'_, T, C, P>

Activates an input handle with a session that reorders inputs and must be drained.

pub fn next(&mut self) -> Option<(InputCapability<T>, &mut C)>

Reads the next input buffer (at some timestamp t) and a corresponding capability for t. The timestamp t of the input buffer can be retrieved by invoking .time() on the capability. Returns None when there’s no more data available.

pub fn for_each<F>(&mut self, logic: F)

where F: FnMut(InputCapability<T>, &mut C),

Iterates through pairs of capability and container.

The for_each_time method is equivalent, but groups containers by capability and is preferred, in that it often leads to grouping work by capability, including the creation of output sessions.

pub fn for_each_time<F>(&mut self, logic: F)

where F: FnMut(InputCapability<T>, IterMut<'_, C>), C: Default,

Iterates through distinct capabilities and the lists of containers associated with each.