Struct mz_coord::coord::indexes::ComputeInstanceIndexOracle

pub struct ComputeInstanceIndexOracle<'a, T> {
    catalog: &'a CatalogState,
    compute: ComputeController<'a, T>,
}

Answers questions about the indexes available on a particular compute instance.

Fields

catalog: &'a CatalogState

compute: ComputeController<'a, T>

Implementations

impl<T: CoordTimestamp> ComputeInstanceIndexOracle<'_, T>

pub fn sufficient_collections<'a, I>(&self, ids: I) -> CollectionIdBundle where
    I: IntoIterator<Item = &'a GlobalId>, 

Identifies a bundle of storage and compute collection ids sufficient for building a dataflow for the identifiers in ids out of the indexes available in this compute instance.

pub fn indexes_on(
    &self,
    id: GlobalId
) -> impl Iterator<Item = (GlobalId, &Index)>

Trait Implementations

impl<'a, T: Debug> Debug for ComputeInstanceIndexOracle<'a, T>

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

Formats the value using the given formatter.

impl<T: CoordTimestamp> IndexOracle for ComputeInstanceIndexOracle<'_, T>

fn indexes_on(&self, id: GlobalId) -> Box<dyn Iterator<Item = &[MirScalarExpr]>>

Returns an iterator over the indexes that exist on the identified collection.