pub async fn execute_remote_plan_action(
        &mut self,
        job_id: String,
        plan: &PlanNode,
    ) -> Result<SendableDataBlockStream> {
        let action = DoGetAction::ExecutePlan(ExecutePlanAction {
            job_id: job_id.clone(),
            plan: plan.clone(),
        });
        self.do_get(&action).await
    }
/// Execute the plan in the remote action and get the block stream.
Execute the plan in the remote action and get the block stream.
Execute the plan in the remote action and get the block stream .
pub async fn execute_remote_plan_action(
        &mut self,
        job_id: String,
        plan: &PlanNode,
    ) -> Result<SendableDataBlockStream> {
        let action = DoGetAction::ExecutePlan(ExecutePlanAction {
            job_id: job_id.clone(),
            plan: plan.clone(),
        });
        self.do_get(&action).await
    }
pub async fn execute_remote_plan_action ( & mut self , job_id : String , plan : & PlanNode , ) -> Result < SendableDataBlockStream > { let action = DoGetAction :: ExecutePlan ( ExecutePlanAction { job_id : job_id . clone ( ) , plan : plan . clone ( ) , } ) ; self . do_get ( & action ) . await }
Execute the plan in the remote action and get the block stream.
Execute the plan in the remote action and get the block stream .
&mut self
job_id
String
plan
&PlanNode
&mut self
job_id
String
plan
&PlanNode