Struct datafusion::exec::ExecutionContext

pub struct ExecutionContext { /* fields omitted */ }

Methods

impl ExecutionContext

pub fn local() -> Self

pub fn register_scalar_function(&mut self, func: Rc<ScalarFunction>)

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

pub fn register(&mut self, table_name: &str, df: Rc<DataFrame>)

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

pub fn load_csv(     &self,     filename: &str,     schema: &Schema,     has_header: bool,     projection: Option<Vec<usize>> ) -> Result<Rc<DataFrame>>

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

pub fn load_ndjson(     &self,     filename: &str,     schema: &Schema,     projection: Option<Vec<usize>> ) -> Result<Rc<DataFrame>>

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

pub fn load_parquet(     &self,     filename: &str,     projection: Option<Vec<usize>> ) -> Result<Rc<DataFrame>>

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

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

load an aggregate function implementation

pub fn show(&self, df: &DataFrame, count: usize) -> Result<usize>

pub fn write_csv(&self, df: Rc<DataFrame>, filename: &str) -> Result<usize>

pub fn write_string(&self, df: Rc<DataFrame>) -> Result<String>

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

Trait Implementations

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.