Trait RemoteExecutor 

pub trait RemoteExecutor: Send + Sync {
    // Required method
    fn execute_remote(
        &self,
        node_id: &str,
        target: &RemoteTarget,
        input: Option<&Value>,
    ) -> Result<Value>;
}

Trait for executing plan nodes on remote workers.

When set on Context, ExecutionPlan::Remote nodes delegate to this instead of executing locally. The implementation sends the sub-plan to a worker and returns the result.

Required Methods

fn execute_remote( &self, node_id: &str, target: &RemoteTarget, input: Option<&Value>, ) -> Result<Value>

Execute a sub-plan remotely and return the output value.

Implementors