execute_risingwave_plan

risingwave_frontend::handler::query

Function execute_risingwave_plan 

Source 
async fn execute_risingwave_plan(
    session: Arc<SessionImpl>,
    plan_fragmenter_result: BatchPlanFragmenterResult,
    formats: Vec<Format>,
) -> Result<RwPgResponse>