Function mz_compute_client::as_of_selection::run

pub fn run<T: TimestampManipulation>(
    dataflows: &mut [DataflowDescription<Plan<T>, (), T>],
    read_policies: &BTreeMap<GlobalId, ReadPolicy<T>>,
    storage_collections: &dyn StorageCollections<Timestamp = T>,
    current_time: T,
) -> BTreeMap<GlobalId, ReadHold<T>>

Runs as-of selection for the given dataflows.

Assigns the selected as-of to the provided dataflow descriptions and returns a set of ReadHolds that must not be dropped nor downgraded until the dataflows have been installed with the compute controller.