distribute_execute

risingwave_frontend::handler::query

Function distribute_execute 

Source 
pub async fn distribute_execute(
    session: Arc<SessionImpl>,
    query: Query,
    can_timeout_cancel: bool,
) -> Result<DistributedQueryStream>