Trait PlanExecutor 

pub trait PlanExecutor: Send + Sync {
    // Required method
    fn execute_plan(
        session: &dyn SparkSessionBackend,
        data: Vec<Vec<JsonValue>>,
        schema: Vec<(String, String)>,
        plan: &[JsonValue],
    ) -> Result<Box<dyn DataFrameBackend>, EngineError>;
}

Executes a logical plan (JSON list of ops) and returns a DataFrame.

Required Methods

fn execute_plan( session: &dyn SparkSessionBackend, data: Vec<Vec<JsonValue>>, schema: Vec<(String, String)>, plan: &[JsonValue], ) -> Result<Box<dyn DataFrameBackend>, EngineError>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors