Struct datafusion::execution::table_impl::TableImpl

pub struct TableImpl { /* fields omitted */ }

Implementation of Table API

Implementations

impl TableImpl

pub fn new(plan: &LogicalPlan) -> Self

Create a new Table based on an existing logical plan

Trait Implementations

impl Table for TableImpl

fn select_columns(&self, columns: Vec<&str>) -> Result<Arc<dyn Table>>

Apply a projection based on a list of column names

fn select(&self, expr_list: Vec<Expr>) -> Result<Arc<dyn Table>>

Create a projection based on arbitrary expressions

fn filter(&self, expr: Expr) -> Result<Arc<dyn Table>>

Create a selection based on a filter expression

fn aggregate(
    &self,
    group_expr: Vec<Expr>,
    aggr_expr: Vec<Expr>
) -> Result<Arc<dyn Table>>

Perform an aggregate query

fn limit(&self, n: usize) -> Result<Arc<dyn Table>>

Limit the number of rows

fn col(&self, name: &str) -> Result<Expr>

Return an expression representing a column within this table

fn min(&self, expr: &Expr) -> Result<Expr>

Create an expression to represent the min() aggregate function

fn max(&self, expr: &Expr) -> Result<Expr>

Create an expression to represent the max() aggregate function

fn sum(&self, expr: &Expr) -> Result<Expr>

Create an expression to represent the sum() aggregate function

fn avg(&self, expr: &Expr) -> Result<Expr>

Create an expression to represent the avg() aggregate function

fn count(&self, expr: &Expr) -> Result<Expr>

Create an expression to represent the count() aggregate function

fn to_logical_plan(&self) -> LogicalPlan

Convert to logical plan

fn collect(
    &self,
    ctx: &mut ExecutionContext,
    batch_size: usize
) -> Result<Vec<RecordBatch>>

Collects the result as a vector of RecordBatch.

fn schema(&self) -> &Schema

Returns the schema from the logical plan