Struct datafusion::exec::ExecutionContext

pub struct ExecutionContext { /* fields omitted */ }

Methods

impl ExecutionContext

fn new(data_dir: String) -> Self

fn define_schema(&mut self, name: &str, schema: &Schema)

fn define_function(&mut self, func: &ScalarFunction)

fn create_logical_plan(
    &self,
    sql: &str
) -> Result<Box<LogicalPlan>, ExecutionError>

fn sql(&mut self, sql: &str) -> Result<Box<DataFrame>, ExecutionError>

fn load(
    &self,
    filename: &str,
    schema: &Schema
) -> Result<Box<DataFrame>, ExecutionError>

Open a CSV file TODO: this is building a relational plan not an execution plan so shouldn't really be here

fn register_table(&mut self, name: String, schema: Schema)

fn create_execution_plan(
    &self,
    plan: &LogicalPlan
) -> Result<Box<SimpleRelation>, ExecutionError>

fn udf(&self, name: &str, args: Vec<Expr>) -> Expr

Trait Implementations

impl Debug for ExecutionContext

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Clone for ExecutionContext

fn clone(&self) -> ExecutionContext

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.