Struct polars_plan::plans::DslBuilder

pub struct DslBuilder(pub DslPlan);

Tuple Fields

0: DslPlan

Implementations

impl DslBuilder

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_options: HiveOptions, ) -> PolarsResult<Self>

Available on crate feature parquet only.

pub fn scan_ipc<P: Into<Arc<[PathBuf]>>>( paths: 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>, strict: bool) -> 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 with_context(self, contexts: Vec<DslPlan>) -> 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>, SchemaRef)>, maintain_order: bool, ) -> Self

pub fn build(self) -> DslPlan

pub fn from_existing_df(df: DataFrame) -> Self

pub fn sort( self, by_column: Vec<Expr>, sort_options: SortMultipleOptions, ) -> Self

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

pub fn unpivot(self, args: UnpivotArgs) -> 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: DslPlan, left_on: Vec<Expr>, right_on: Vec<Expr>, options: Arc<JoinOptions>, ) -> Self

pub fn map_private(self, function: DslFunction) -> 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<DslPlan> for DslBuilder

fn from(lp: DslPlan) -> Self

Converts to this type from the input type.