Struct datafusion::logicalplan::LogicalPlanBuilder

pub struct LogicalPlanBuilder { /* fields omitted */ }

Builder for logical plans

Implementations

impl LogicalPlanBuilder

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

Create a builder from an existing plan

pub fn empty() -> Self

Create an empty relation

pub fn scan_csv(
    path: &str,
    options: CsvReadOptions,
    projection: Option<Vec<usize>>
) -> Result<Self>

Scan a CSV data source

pub fn scan_parquet(path: &str, projection: Option<Vec<usize>>) -> Result<Self>

Scan a Parquet data source

pub fn scan(
    schema_name: &str,
    table_name: &str,
    table_schema: &Schema,
    projection: Option<Vec<usize>>
) -> Result<Self>

Scan a data source

pub fn project(&self, expr: Vec<Expr>) -> Result<Self>

Apply a projection

pub fn filter(&self, expr: Expr) -> Result<Self>

Apply a filter

pub fn limit(&self, n: usize) -> Result<Self>

Apply a limit

pub fn sort(&self, expr: Vec<Expr>) -> Result<Self>

Apply a sort

pub fn aggregate(
    &self,
    group_expr: Vec<Expr>,
    aggr_expr: Vec<Expr>
) -> Result<Self>

Apply an aggregate

pub fn build(&self) -> Result<LogicalPlan>

Build the plan