Trait InputQueue

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

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

Required Methods

fn accept_input(&mut self)

Accepts all available input into local queues.

fn drain_input(&mut self)

Drains all available input and empties the local queue.

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

Registers a frontier notification to be delivered.

Implementors

impl<T, D, C, P> InputQueue<T> for InputHandleQueue<T, D, C, P>

where T: Timestamp, D: Container, C: InputConnection<T> + 'static, P: Pull<Message<T, D>> + 'static,