Struct datafusion::execution::context::ExecutionContext

pub struct ExecutionContext { /* fields omitted */ }

Execution context for registering data sources and executing queries

Methods

impl ExecutionContext

pub fn new() -> Self

Create a new excution context for in-memory queries

pub fn sql(
    &mut self,
    sql: &str,
    batch_size: usize
) -> Result<Rc<RefCell<dyn Relation>>>

Execute a SQL query and produce a Relation (a schema-aware iterator over a series of RecordBatch instances)

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

Creates a logical plan

pub fn register_csv(
    &mut self,
    name: &str,
    filename: &str,
    schema: &Schema,
    has_header: bool
)

Register a CSV file as a table so that it can be queried from SQL

pub fn register_table(&mut self, name: &str, provider: Rc<dyn TableProvider>)

Register a table so that it can be queried from SQL

pub fn table(&mut self, table_name: &str) -> Result<Arc<dyn Table>>

Get a table by name

pub fn execute(
    &mut self,
    plan: &LogicalPlan,
    batch_size: usize
) -> Result<Rc<RefCell<dyn Relation>>>

Execute a logical plan and produce a Relation (a schema-aware iterator over a series of RecordBatch instances)