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