Struct polars_plan::logical_plan::LogicalPlanBuilder

pub struct LogicalPlanBuilder(_);

Implementations

impl LogicalPlanBuilder

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

pub fn scan_parquet<P: Into<PathBuf>>(
    path: P,
    n_rows: Option<usize>,
    cache: bool,
    parallel: ParallelStrategy,
    row_count: Option<RowCount>,
    rechunk: bool,
    low_memory: bool,
    cloud_options: Option<CloudOptions>
) -> PolarsResult<Self>

Available on crate features parquet or parquet_async only.

pub fn scan_ipc<P: Into<PathBuf>>(
    path: P,
    options: IpcScanOptions
) -> PolarsResult<Self>

Available on crate feature ipc only.

pub fn scan_csv<P: Into<PathBuf>>(
    path: P,
    delimiter: u8,
    has_header: bool,
    ignore_errors: bool,
    skip_rows: usize,
    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>,
    eol_char: u8,
    null_values: Option<NullValues>,
    infer_schema_length: Option<usize>,
    rechunk: bool,
    skip_rows_after_header: usize,
    encoding: CsvEncoding,
    row_count: Option<RowCount>,
    parse_dates: bool
) -> PolarsResult<Self>

Available 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 with_context(self, contexts: Vec<LogicalPlan>) -> Self

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

Apply a filter

pub fn groupby<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>,
    reverse: Vec<bool>,
    null_last: bool
) -> Self

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

pub fn melt(self, args: Arc<MeltArgs>) -> 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: JoinOptions
) -> Self

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

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

Trait Implementations

impl From<LogicalPlan> for LogicalPlanBuilder

fn from(lp: LogicalPlan) -> Self

Converts to this type from the input type.