Struct polars_plan::logical_plan::LogicalPlanBuilder

pub struct LogicalPlanBuilder(pub LogicalPlan);

Tuple Fields

0: LogicalPlan

Implementations

impl LogicalPlanBuilder

pub fn anonymous_scan( function: Arc<dyn AnonymousScan>, schema: Option<SchemaRef>, infer_schema_length: Option<usize>, skip_rows: Option<usize>, n_rows: Option<usize>, name: &'static str ) -> PolarsResult<Self>

pub fn scan_parquet<P: Into<Arc<[PathBuf]>>>( paths: P, n_rows: Option<usize>, cache: bool, parallel: ParallelStrategy, row_index: Option<RowIndex>, rechunk: bool, low_memory: bool, cloud_options: Option<CloudOptions>, use_statistics: bool, hive_partitioning: bool ) -> PolarsResult<Self>

Available on crate features parquet or parquet_async only.

pub fn scan_ipc<P: Into<PathBuf>>( path: P, options: IpcScanOptions, n_rows: Option<usize>, cache: bool, row_index: Option<RowIndex>, rechunk: bool, cloud_options: Option<CloudOptions> ) -> PolarsResult<Self>

Available on crate feature ipc only.

pub fn cache(self) -> Self

pub fn drop(self, to_drop: PlHashSet<String>) -> Self

pub fn project(self, exprs: Vec<Expr>, options: ProjectionOptions) -> Self

pub fn fill_null(self, fill_value: Expr) -> Self

pub fn drop_nulls(self, subset: Option<Vec<Expr>>) -> Self

pub fn fill_nan(self, fill_value: Expr) -> Self

pub fn with_columns(self, exprs: Vec<Expr>, options: ProjectionOptions) -> Self

pub fn add_err(self, err: PolarsError) -> Self

pub fn with_context(self, contexts: Vec<LogicalPlan>) -> Self

pub fn filter(self, predicate: Expr) -> Self

Apply a filter

pub fn group_by<E: AsRef<[Expr]>>( self, keys: Vec<Expr>, aggs: E, apply: Option<Arc<dyn DataFrameUdf>>, maintain_order: bool ) -> Self

pub fn build(self) -> LogicalPlan

pub fn from_existing_df(df: DataFrame) -> Self

pub fn sort( self, by_column: Vec<Expr>, descending: Vec<bool>, null_last: bool, maintain_order: bool ) -> Self

pub fn explode(self, columns: Vec<Expr>) -> Self

pub fn melt(self, args: Arc<MeltArgs>) -> Self

pub fn row_index(self, name: &str, offset: Option<IdxSize>) -> Self

pub fn distinct(self, options: DistinctOptions) -> Self

pub fn slice(self, offset: i64, len: IdxSize) -> Self

pub fn join( self, other: LogicalPlan, left_on: Vec<Expr>, right_on: Vec<Expr>, options: Arc<JoinOptions> ) -> Self

pub fn map_private(self, function: FunctionNode) -> Self

pub fn map_python( self, function: PythonFunction, optimizations: AllowedOptimizations, schema: Option<SchemaRef>, validate_output: bool ) -> Self

Available on crate feature python only.

pub fn map<F>( self, function: F, optimizations: AllowedOptimizations, schema: Option<Arc<dyn UdfSchema>>, name: &'static str ) -> Self

where F: DataFrameUdf + 'static,

Trait Implementations

impl From<LogicalPlan> for LogicalPlanBuilder

fn from(lp: LogicalPlan) -> Self

Converts to this type from the input type.