Enum polars_lazy::logical_plan::LogicalPlan [−][src]
pub enum LogicalPlan {}Show variants
Selection { input: Box<LogicalPlan>, predicate: Expr, }, Cache { input: Box<LogicalPlan>, }, CsvScan { path: PathBuf, schema: SchemaRef, has_header: bool, delimiter: u8, ignore_errors: bool, skip_rows: usize, stop_after_n_rows: Option<usize>, with_columns: Option<Vec<String>>, predicate: Option<Expr>, aggregate: Vec<Expr>, cache: bool, low_memory: bool, }, ParquetScan { path: PathBuf, schema: SchemaRef, with_columns: Option<Vec<String>>, predicate: Option<Expr>, aggregate: Vec<Expr>, stop_after_n_rows: Option<usize>, cache: bool, }, DataFrameScan { df: Arc<DataFrame>, schema: SchemaRef, projection: Option<Vec<Expr>>, selection: Option<Expr>, }, LocalProjection { expr: Vec<Expr>, input: Box<LogicalPlan>, schema: SchemaRef, }, Projection { expr: Vec<Expr>, input: Box<LogicalPlan>, schema: SchemaRef, }, Aggregate { input: Box<LogicalPlan>, keys: Arc<Vec<Expr>>, aggs: Vec<Expr>, schema: SchemaRef, apply: Option<Arc<dyn DataFrameUdf>>, }, Join { input_left: Box<LogicalPlan>, input_right: Box<LogicalPlan>, schema: SchemaRef, how: JoinType, left_on: Vec<Expr>, right_on: Vec<Expr>, allow_par: bool, force_par: bool, }, HStack { input: Box<LogicalPlan>, exprs: Vec<Expr>, schema: SchemaRef, }, Distinct { input: Box<LogicalPlan>, maintain_order: bool, subset: Arc<Option<Vec<String>>>, }, Sort { input: Box<LogicalPlan>, by_column: Vec<Expr>, reverse: Vec<bool>, }, Explode { input: Box<LogicalPlan>, columns: Vec<String>, }, Slice { input: Box<LogicalPlan>, offset: i64, len: usize, }, Melt { input: Box<LogicalPlan>, id_vars: Arc<Vec<String>>, value_vars: Arc<Vec<String>>, schema: SchemaRef, }, Udf { input: Box<LogicalPlan>, function: Arc<dyn DataFrameUdf>, predicate_pd: bool, projection_pd: bool, schema: Option<SchemaRef>, },
Variants
Filter on a boolean mask
Show fields
Fields of Selection
input: Box<LogicalPlan>
predicate: Expr
Cache the input at this point in the LP
Show fields
Fields of Cache
input: Box<LogicalPlan>
Scan a CSV file
Show fields
Fields of CsvScan
This is supported on crate feature
parquet
only.Scan a Parquet file
Show fields
In memory DataFrame
Show fields
Show fields
Fields of LocalProjection
Column selection
Show fields
Fields of Projection
Groupby aggregation
Show fields
Join operation
Show fields
Adding columns to the table without a Join
Show fields
Fields of HStack
Remove duplicates from the table
Show fields
Sort the table
An explode operation
Show fields
Fields of Explode
input: Box<LogicalPlan>
columns: Vec<String>
Slice the table
Show fields
Fields of Slice
A Melt operation
Show fields
A User Defined Function
Show fields
Fields of Udf
input: Box<LogicalPlan>
function: Arc<dyn DataFrameUdf>
predicate_pd: bool
allow predicate pushdown optimizations
projection_pd: bool
allow projection pushdown optimizations
schema: Option<SchemaRef>
Implementations
Trait Implementations
Performs the conversion.
Performs the conversion.
Auto Trait Implementations
impl !RefUnwindSafe for LogicalPlan
impl Send for LogicalPlan
impl Sync for LogicalPlan
impl Unpin for LogicalPlan
impl !UnwindSafe for LogicalPlan
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V