Struct polars_lazy::logical_plan::LogicalPlanBuilder

pub struct LogicalPlanBuilder(_);

This is supported on crate feature compile only.

Implementations

impl LogicalPlanBuilder

pub fn scan_parquet<P: Into<PathBuf>>(
    path: P,
    stop_after_n_rows: Option<usize>,
    cache: bool
) -> Self

This is supported on crate feature parquet only.

pub fn scan_csv<P: Into<PathBuf>>(
    path: P,
    delimiter: u8,
    has_header: bool,
    ignore_errors: bool,
    skip_rows: usize,
    stop_after_n_rows: Option<usize>,
    cache: bool,
    schema: Option<Arc<Schema>>,
    schema_overwrite: Option<&Schema>,
    low_memory: bool,
    comment_char: Option<u8>,
    quote_char: Option<u8>,
    null_values: Option<NullValues>
) -> Self

This is supported on crate feature csv-file only.

pub fn cache(self) -> Self

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

pub fn project_local(self, exprs: Vec<Expr>) -> Self

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

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

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

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

Apply a filter

pub fn groupby<E: AsRef<[Expr]>>(
    self,
    keys: Arc<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>, reverse: Vec<bool>) -> Self

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

pub fn melt(
    self,
    id_vars: Arc<Vec<String>>,
    value_vars: Arc<Vec<String>>
) -> Self

pub fn drop_duplicates(
    self,
    maintain_order: bool,
    subset: Option<Vec<String>>
) -> Self

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

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

pub fn map<F>(
    self,
    function: F,
    optimizations: AllowedOptimizations,
    schema: Option<SchemaRef>
) -> Self where
    F: DataFrameUdf + 'static, 

Trait Implementations

impl From<LogicalPlan> for LogicalPlanBuilder

fn from(lp: LogicalPlan) -> Self

Performs the conversion.