Struct datafusion::exec::ExecutionContext

pub struct ExecutionContext { /* fields omitted */ }

Methods

impl ExecutionContext

pub fn local(data_dir: String) -> Self

pub fn remote(etcd: String) -> Self

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

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

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

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

pub 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

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

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

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

pub fn write(
    &self,
    df: Box<DataFrame>,
    filename: &str
) -> Result<usize, DataFrameError>

pub fn execute(
    &self,
    physical_plan: &PhysicalPlan
) -> Result<ExecutionResult, ExecutionError>

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.