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>
Expand description

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.