Struct mz_dataflow_types::client::controller::compute::CollectionState

pub struct CollectionState<T> {
    pub read_capabilities: MutableAntichain<T>,
    pub implied_capability: Antichain<T>,
    pub read_policy: ReadPolicy<T>,
    pub storage_dependencies: Vec<GlobalId>,
    pub compute_dependencies: Vec<GlobalId>,
    pub write_frontier: MutableAntichain<T>,
}

State maintained about individual collections.

Fields

read_capabilities: MutableAntichain<T>

Accumulation of read capabilities for the collection.

This accumulation will always contain self.implied_capability, but may also contain capabilities held by others who have read dependencies on this collection.

implied_capability: Antichain<T>

The implicit capability associated with collection creation.

read_policy: ReadPolicy<T>

The policy to use to downgrade self.implied_capability.

storage_dependencies: Vec<GlobalId>

Storage identifiers on which this collection depends.

compute_dependencies: Vec<GlobalId>

Compute identifiers on which this collection depends.

write_frontier: MutableAntichain<T>

Reported progress in the write capabilities.

Importantly, this is not a write capability, but what we have heard about the write capabilities of others. All future writes will have times greater than or equal to write_frontier.frontier().

Implementations

impl<T: Timestamp> CollectionState<T>

pub fn new(
    since: Antichain<T>,
    storage_dependencies: Vec<GlobalId>,
    compute_dependencies: Vec<GlobalId>
) -> Self

Creates a new collection state, with an initial read policy valid from since.

pub fn read_capability(&self) -> &Antichain<T>

Reports the current read capability.

Trait Implementations

impl<T: Debug> Debug for CollectionState<T>

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

Formats the value using the given formatter.