Function dataflow::render::build_storage_dataflow

pub fn build_storage_dataflow<A: Allocate>(
    timely_worker: &mut TimelyWorker<A>, 
    storage_state: &mut StorageState, 
    dataflow: &DataflowDescription<Plan>, 
    now: NowFn, 
    source_metrics: &SourceBaseMetrics
) -> BTreeMap<GlobalId, SourceBoundary>

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.