Trait mz_timely_util::builder_async::InputQueue

source ·
trait InputQueue<T: Timestamp> {
    // Required methods
    fn accept_input(&mut self);
    fn drain_input(&mut self);
    fn notify_progress(&mut self, upper: Antichain<T>);
}
Expand description

A helper trait abstracting over an input handle. It facilitates keeping around type erased handles for each of the operator inputs.

Required Methods§

source

fn accept_input(&mut self)

Accepts all available input into local queues.

source

fn drain_input(&mut self)

Drains all available input and empties the local queue.

source

fn notify_progress(&mut self, upper: Antichain<T>)

Registers a frontier notification to be delivered.

Implementors§

source§

impl<T, D, C, P> InputQueue<T> for InputHandleQueue<T, D, C, P>
where T: Timestamp, D: Container, C: InputConnection<T> + 'static, P: Pull<Bundle<T, D>> + 'static,