Enum LogicalPlan 

pub enum LogicalPlan {
    Scan {
        source: DataFrame,
    },
    Filter {
        input: Box<LogicalPlan>,
        predicate: DExpr,
    },
    GroupBy {
        input: Box<LogicalPlan>,
        keys: Vec<String>,
    },
    Aggregate {
        input: Box<LogicalPlan>,
        keys: Vec<String>,
        aggs: Vec<(String, DExpr)>,
    },
    Project {
        input: Box<LogicalPlan>,
        columns: Vec<String>,
    },
    InnerJoin {
        left: Box<LogicalPlan>,
        right: Box<LogicalPlan>,
        left_on: String,
        right_on: String,
    },
    LeftJoin {
        left: Box<LogicalPlan>,
        right: Box<LogicalPlan>,
        left_on: String,
        right_on: String,
    },
    CrossJoin {
        left: Box<LogicalPlan>,
        right: Box<LogicalPlan>,
    },
}

A logical query plan node.

Variants

Scan

Scan a source DataFrame.

Fields

source: DataFrame

Filter

Filter rows by predicate.

Fields

input: Box<LogicalPlan>

predicate: DExpr

GroupBy

Group by one or more columns.

Fields

input: Box<LogicalPlan>

keys: Vec<String>

Aggregate

Aggregate with named expressions.

Fields

input: Box<LogicalPlan>

keys: Vec<String>

aggs: Vec<(String, DExpr)>

Project

Select/project specific columns.

Fields

input: Box<LogicalPlan>

columns: Vec<String>

InnerJoin

Inner join: rows matching on both sides.

Fields

left: Box<LogicalPlan>

right: Box<LogicalPlan>

left_on: String

right_on: String

LeftJoin

Left join: all left rows, matching right rows or null.

Fields

left: Box<LogicalPlan>

right: Box<LogicalPlan>

left_on: String

right_on: String

CrossJoin

Cross join: cartesian product.

Fields

left: Box<LogicalPlan>

right: Box<LogicalPlan>

Implementations

impl LogicalPlan

pub fn referenced_columns(&self) -> Vec<String>

Collect the column names referenced by this plan (for pruning).

Trait Implementations

impl Clone for LogicalPlan

fn clone(&self) -> LogicalPlan

Returns a duplicate 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

Formats the value using the given formatter.