Struct mz_dataflow_types::client::ComputeCommandHistory

struct ComputeCommandHistory<T> {
    commands: Vec<ComputeCommand<T>>,
}

Fields

commands: Vec<ComputeCommand<T>>

Implementations

impl<T: Timestamp> ComputeCommandHistory<T>

pub fn push(&mut self, command: ComputeCommand<T>)

pub fn reduce<V>(&mut self, peeks: &HashMap<Uuid, V>) -> usize

Reduces self.history to a minimal form.

This action not only simplifies the issued history, but importantly reduces the instructions to only reference inputs from times that are still certain to be valid. Commands that allow compaction of a collection also remove certainty that the inputs will be available for times not greater or equal to that compaction frontier.

The peeks argument should contain those peeks that have yet to be resolved, either through response or cancellation.

Returns the number of distinct commands that remain.

pub fn iter(&self) -> impl Iterator<Item = &ComputeCommand<T>>

Iterate through the contained commands.

pub fn len(&self) -> usize

Report the number of commands.

Importantly, each command can be arbitrarily complicated, so this number could be small even while we have few commands that cause many actions to be taken.

Trait Implementations

impl<T: Debug> Debug for ComputeCommandHistory<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for ComputeCommandHistory<T>

fn default() -> Self

Returns the “default value” for a type.