Enum datafusion::logical::LogicalPlan

pub enum LogicalPlan {
    Limit {
        limit: usize,
        input: Rc<LogicalPlan>,
        schema: Rc<Schema>,
    },
    Projection {
        expr: Vec<Expr>,
        input: Rc<LogicalPlan>,
        schema: Rc<Schema>,
    },
    Selection {
        expr: Expr,
        input: Rc<LogicalPlan>,
    },
    Aggregate {
        input: Rc<LogicalPlan>,
        group_expr: Vec<Expr>,
        aggr_expr: Vec<Expr>,
        schema: Rc<Schema>,
    },
    Sort {
        expr: Vec<Expr>,
        input: Rc<LogicalPlan>,
        schema: Rc<Schema>,
    },
    TableScan {
        schema_name: String,
        table_name: String,
        schema: Rc<Schema>,
        projection: Option<Vec<usize>>,
    },
    CsvFile {
        filename: String,
        schema: Rc<Schema>,
        has_header: bool,
        projection: Option<Vec<usize>>,
    },
    NdJsonFile {
        filename: String,
        schema: Rc<Schema>,
        projection: Option<Vec<usize>>,
    },
    ParquetFile {
        filename: String,
        schema: Rc<Schema>,
        projection: Option<Vec<usize>>,
    },
    EmptyRelation {
        schema: Rc<Schema>,
    },
}

The LogicalPlan represents different types of relations (such as Projection, Selection, etc) and can be created by the SQL query planner and the DataFrame API.

Variants

Limit

A relation that applies a row limit to its child relation

Fields of Limit

limit: usize
input: Rc<LogicalPlan>
schema: Rc<Schema>

Projection

A Projection (essentially a SELECT with an expression list)

Fields of Projection

expr: Vec<Expr>
input: Rc<LogicalPlan>
schema: Rc<Schema>

Selection

A Selection (essentially a WHERE clause with a predicate expression)

Fields of Selection

expr: Expr
input: Rc<LogicalPlan>

Aggregate

Represents a list of aggregate expressions with optional grouping expressions

Fields of Aggregate

input: Rc<LogicalPlan>
group_expr: Vec<Expr>
aggr_expr: Vec<Expr>
schema: Rc<Schema>

Sort

Represents a list of sort expressions to be applied to a relation

Fields of Sort

expr: Vec<Expr>
input: Rc<LogicalPlan>
schema: Rc<Schema>

TableScan

A table scan against a table that has been registered on a context

Fields of TableScan

schema_name: String
table_name: String
schema: Rc<Schema>
projection: Option<Vec<usize>>

CsvFile

Represents a CSV file with a provided schema

Fields of CsvFile

filename: String
schema: Rc<Schema>
has_header: bool
projection: Option<Vec<usize>>

NdJsonFile

Represents an ndjson file with a provided schema

Fields of NdJsonFile

filename: String
schema: Rc<Schema>
projection: Option<Vec<usize>>

ParquetFile

Represents a Parquet file that contains schema information

Fields of ParquetFile

filename: String
schema: Rc<Schema>
projection: Option<Vec<usize>>

EmptyRelation

An empty relation with an empty schema

Fields of EmptyRelation

schema: Rc<Schema>

Methods

impl LogicalPlan

pub fn schema(&self) -> &Rc<Schema>

Get a reference to the logical plan's schema

Trait Implementations

impl Clone for LogicalPlan

fn clone(&self) -> LogicalPlan

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LogicalPlan

fn fmt(&self, f: &mut Formatter) -> Result<(), Error>

Formats the value using the given formatter.