Enum polars::prelude::LogicalPlan [−][src]
pub enum LogicalPlan {}Show variants
Selection { input: Box<LogicalPlan, Global>, predicate: Expr, }, Cache { input: Box<LogicalPlan, Global>, }, CsvScan { path: PathBuf, schema: Arc<Schema>, has_header: bool, delimiter: u8, ignore_errors: bool, skip_rows: usize, stop_after_n_rows: Option<usize>, with_columns: Option<Vec<String, Global>>, predicate: Option<Expr>, aggregate: Vec<Expr, Global>, cache: bool, low_memory: bool, }, ParquetScan { path: PathBuf, schema: Arc<Schema>, with_columns: Option<Vec<String, Global>>, predicate: Option<Expr>, aggregate: Vec<Expr, Global>, stop_after_n_rows: Option<usize>, cache: bool, }, DataFrameScan { df: Arc<DataFrame>, schema: Arc<Schema>, projection: Option<Vec<Expr, Global>>, selection: Option<Expr>, }, LocalProjection { expr: Vec<Expr, Global>, input: Box<LogicalPlan, Global>, schema: Arc<Schema>, }, Projection { expr: Vec<Expr, Global>, input: Box<LogicalPlan, Global>, schema: Arc<Schema>, }, Aggregate { input: Box<LogicalPlan, Global>, keys: Arc<Vec<Expr, Global>>, aggs: Vec<Expr, Global>, schema: Arc<Schema>, apply: Option<Arc<dyn DataFrameUdf + 'static>>, }, Join { input_left: Box<LogicalPlan, Global>, input_right: Box<LogicalPlan, Global>, schema: Arc<Schema>, how: JoinType, left_on: Vec<Expr, Global>, right_on: Vec<Expr, Global>, allow_par: bool, force_par: bool, }, HStack { input: Box<LogicalPlan, Global>, exprs: Vec<Expr, Global>, schema: Arc<Schema>, }, Distinct { input: Box<LogicalPlan, Global>, maintain_order: bool, subset: Arc<Option<Vec<String, Global>>>, }, Sort { input: Box<LogicalPlan, Global>, by_column: Vec<Expr, Global>, reverse: Vec<bool, Global>, }, Explode { input: Box<LogicalPlan, Global>, columns: Vec<String, Global>, }, Slice { input: Box<LogicalPlan, Global>, offset: i64, len: usize, }, Melt { input: Box<LogicalPlan, Global>, id_vars: Arc<Vec<String, Global>>, value_vars: Arc<Vec<String, Global>>, schema: Arc<Schema>, }, Udf { input: Box<LogicalPlan, Global>, function: Arc<dyn DataFrameUdf + 'static>, predicate_pd: bool, projection_pd: bool, schema: Option<Arc<Schema>>, },
Variants
Filter on a boolean mask
Show fields
Fields of Selection
input: Box<LogicalPlan, Global>
predicate: Expr
Cache the input at this point in the LP
Show fields
Fields of Cache
input: Box<LogicalPlan, Global>
Scan a CSV file
Show fields
Fields of CsvScan
path: PathBuf
schema: Arc<Schema>
has_header: bool
delimiter: u8
ignore_errors: bool
skip_rows: usize
stop_after_n_rows: Option<usize>
with_columns: Option<Vec<String, Global>>
predicate: Option<Expr>
Filters at the scan level
aggregate: Vec<Expr, Global>
Aggregations at the scan level
cache: bool
low_memory: bool
Scan a Parquet file
Show fields
In memory DataFrame
Show fields
Show fields
Column selection
Show fields
Groupby aggregation
Show fields
Join operation
Show fields
Adding columns to the table without a Join
Show fields
Remove duplicates from the table
Show fields
Sort the table
Show fields
An explode operation
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, Global>
function: Arc<dyn DataFrameUdf + 'static>
predicate_pd: bool
allow predicate pushdown optimizations
projection_pd: bool
allow projection pushdown optimizations
schema: Option<Arc<Schema>>
Implementations
Trait Implementations
Returns the “default value” for a type. Read more
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