Function mz_storage_client::source::persist_source::persist_source_core

pub fn persist_source_core<'g, G, YFn>(
    scope: &mut Child<'g, G, (<G as ScopeParent>::Timestamp, u64)>,
    source_id: GlobalId,
    persist_clients: Arc<PersistClientCache>,
    metadata: CollectionMetadata,
    as_of: Option<Antichain<Timestamp>>,
    until: Antichain<Timestamp>,
    map_filter_project: Option<&mut MfpPlan>,
    flow_control: Option<FlowControl<Child<'g, G, (<G as ScopeParent>::Timestamp, u64)>>>,
    yield_fn: YFn
) -> (Stream<Child<'g, G, (<G as ScopeParent>::Timestamp, u64)>, (Result<Row, DataflowError>, (Timestamp, u64), Diff)>, Rc<dyn Any>)where
    G: Scope<Timestamp = Timestamp>,
    YFn: Fn(Instant, usize) -> bool + 'static,

Creates a new source that reads from a persist shard, distributing the work of reading data to all timely workers.

All times emitted will have been advanced by the given as_of frontier.