Function mz_compute::render::build_compute_dataflow
source · pub fn build_compute_dataflow<A: Allocate>(
timely_worker: &mut Worker<A>,
compute_state: &mut ComputeState,
dataflow: DataflowDescription<FlatPlan, CollectionMetadata>,
start_signal: StartSignal,
until: Antichain<Timestamp>,
dataflow_expiration: Antichain<Timestamp>,
)
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.