Function dataflow::render::build_compute_dataflow[][src]

pub fn build_compute_dataflow<A: Allocate>(
    timely_worker: &mut TimelyWorker<A>,
    compute_state: &mut ComputeState,
    sources: BTreeMap<GlobalId, SourceBoundary>,
    dataflow: DataflowDescription<Plan>,
    sink_metrics: &SinkBaseMetrics
)
Expand description

Assemble the “compute” side of a dataflow, i.e. all but the sources.

This method imports sources from provided assets, and then builds the remaining dataflow using “compute-local” assets like shared arrangements, and producing both arrangements and sinks.