pub fn compile_flow(
catalog: &Catalog,
txn: &mut AdminTransaction,
plan: QueryPlan,
sink: Option<&ViewDef>,
flow_id: FlowId,
) -> Result<FlowDag>Expand description
Public API for compiling logical plans to Flows with an existing flow ID.