Function mz_storage::render::build_storage_dataflow

pub fn build_storage_dataflow<A: Allocate>(
    timely_worker: &mut TimelyWorker<A>, 
    storage_state: &mut StorageState, 
    id: GlobalId, 
    description: IngestionDescription<CollectionMetadata>, 
    resume_upper: Antichain<Timestamp>
)

Assemble the “storage” side of a dataflow, i.e. the sources.

This method creates a new dataflow to host the implementations of sources for the dataflow argument, and returns assets for each source that can import the results into a new dataflow.