Enum polars::prelude::LogicalPlan
source · [−]pub enum LogicalPlan {
Show 21 variants
AnonymousScan {
function: Arc<dyn AnonymousScan + 'static>,
schema: Arc<Schema>,
predicate: Option<Expr>,
aggregate: Vec<Expr, Global>,
options: AnonymousScanOptions,
},
Selection {
input: Box<LogicalPlan, Global>,
predicate: Expr,
},
Cache {
input: Box<LogicalPlan, Global>,
id: usize,
count: usize,
},
CsvScan {
path: PathBuf,
schema: Arc<Schema>,
options: CsvParserOptions,
predicate: Option<Expr>,
aggregate: Vec<Expr, Global>,
},
ParquetScan {
path: PathBuf,
schema: Arc<Schema>,
predicate: Option<Expr>,
aggregate: Vec<Expr, Global>,
options: ParquetOptions,
},
IpcScan {
path: PathBuf,
schema: Arc<Schema>,
options: IpcScanOptionsInner,
predicate: Option<Expr>,
aggregate: Vec<Expr, Global>,
},
DataFrameScan {
df: Arc<DataFrame>,
schema: Arc<Schema>,
output_schema: Option<Arc<Schema>>,
projection: Option<Arc<Vec<String, 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>>,
maintain_order: bool,
options: GroupbyOptions,
},
Join {
input_left: Box<LogicalPlan, Global>,
input_right: Box<LogicalPlan, Global>,
schema: Arc<Schema>,
left_on: Vec<Expr, Global>,
right_on: Vec<Expr, Global>,
options: JoinOptions,
},
HStack {
input: Box<LogicalPlan, Global>,
exprs: Vec<Expr, Global>,
schema: Arc<Schema>,
},
Distinct {
input: Box<LogicalPlan, Global>,
options: DistinctOptions,
},
Sort {
input: Box<LogicalPlan, Global>,
by_column: Vec<Expr, Global>,
args: SortArguments,
},
Explode {
input: Box<LogicalPlan, Global>,
columns: Vec<String, Global>,
schema: Arc<Schema>,
},
Slice {
input: Box<LogicalPlan, Global>,
offset: i64,
len: u32,
},
Melt {
input: Box<LogicalPlan, Global>,
args: Arc<MeltArgs>,
schema: Arc<Schema>,
},
MapFunction {
input: Box<LogicalPlan, Global>,
function: FunctionNode,
},
Union {
inputs: Vec<LogicalPlan, Global>,
options: UnionOptions,
},
Error {
input: Box<LogicalPlan, Global>,
err: Arc<Mutex<Option<PolarsError>>>,
},
ExtContext {
input: Box<LogicalPlan, Global>,
contexts: Vec<LogicalPlan, Global>,
schema: Arc<Schema>,
},
}
Variants
AnonymousScan
Selection
Filter on a boolean mask
Cache
Cache the input at this point in the LP
CsvScan
Scan a CSV file
ParquetScan
Scan a Parquet file
IpcScan
DataFrameScan
Fields
In memory DataFrame
LocalProjection
Projection
Column selection
Aggregate
Fields
input: Box<LogicalPlan, Global>
apply: Option<Arc<dyn DataFrameUdf + 'static>>
maintain_order: bool
options: GroupbyOptions
Groupby aggregation
Join
Join operation
HStack
Adding columns to the table without a Join
Distinct
Remove duplicates from the table
Sort
Sort the table
Explode
An explode operation
Slice
Slice the table
Melt
A Melt operation
MapFunction
A (User Defined) Function
Union
Error
Catches errors and throws them later
ExtContext
This allows expressions to access other tables
Implementations
sourceimpl LogicalPlan
impl LogicalPlan
Trait Implementations
sourceimpl Clone for LogicalPlan
impl Clone for LogicalPlan
sourcefn clone(&self) -> LogicalPlan
fn clone(&self) -> LogicalPlan
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresourceimpl Debug for LogicalPlan
impl Debug for LogicalPlan
sourceimpl Default for LogicalPlan
impl Default for LogicalPlan
sourcefn default() -> LogicalPlan
fn default() -> LogicalPlan
Returns the “default value” for a type. Read more
sourceimpl From<LogicalPlan> for LazyFrame
impl From<LogicalPlan> for LazyFrame
sourcefn from(plan: LogicalPlan) -> LazyFrame
fn from(plan: LogicalPlan) -> LazyFrame
Converts to this type from the input type.
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
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more