Trait mz_compute::render::continual_task::StepForward

trait StepForward<G: Scope, D, R> {
    // Required method
    fn step_forward(&self, name: &str) -> Collection<G, D, R>;
}

Required Methods

fn step_forward(&self, name: &str) -> Collection<G, D, R>

Translates a collection one timestamp “forward” (i.e. T -> T+1 as defined by TimestampManipulation::step_forward).

This includes:

• The differential timestamps in each data.
• The capabilities paired with that data.
• (As a consequence of the previous) the output frontier is one step forward of the input frontier.

The caller is responsible for ensuring that all data and capabilities given to this operator can be stepped forward without panicking, otherwise the operator will panic at runtime.

Implementations on Foreign Types

impl<G, D, R> StepForward<G, D, R> for Collection<G, D, R>

where G: Scope<Timestamp = Timestamp>, D: Data, R: Semigroup + 'static,

fn step_forward(&self, name: &str) -> Collection<G, D, R>

Implementors