Struct DslBuilder

pub struct DslBuilder(pub DslPlan);

Available on crate feature lazy only.

Tuple Fields

0: DslPlan

Implementations

impl DslBuilder

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

pub fn scan_parquet( sources: ScanSources, n_rows: Option<usize>, cache: bool, parallel: ParallelStrategy, row_index: Option<RowIndex>, rechunk: bool, low_memory: bool, cloud_options: Option<CloudOptions>, use_statistics: bool, schema: Option<Arc<Schema<DataType>>>, hive_options: HiveOptions, glob: bool, include_file_paths: Option<PlSmallStr>, allow_missing_columns: bool, ) -> Result<DslBuilder, PolarsError>

Available on crate feature parquet only.

pub fn scan_ipc( sources: ScanSources, options: IpcScanOptions, n_rows: Option<usize>, cache: bool, row_index: Option<RowIndex>, rechunk: bool, cloud_options: Option<CloudOptions>, hive_options: HiveOptions, include_file_paths: Option<PlSmallStr>, ) -> Result<DslBuilder, PolarsError>

Available on crate feature ipc only.

pub fn scan_csv( sources: ScanSources, read_options: CsvReadOptions, cache: bool, cloud_options: Option<CloudOptions>, glob: bool, include_file_paths: Option<PlSmallStr>, ) -> Result<DslBuilder, PolarsError>

Available on crate feature csv only.

pub fn cache(self) -> DslBuilder

pub fn drop(self, to_drop: Vec<Selector>, strict: bool) -> DslBuilder

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

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

pub fn drop_nans(self, subset: Option<Vec<Expr>>) -> DslBuilder

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

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

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

pub fn with_context(self, contexts: Vec<DslPlan>) -> DslBuilder

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

Apply a filter

pub fn group_by<E>( self, keys: Vec<Expr>, aggs: E, apply: Option<(Arc<dyn DataFrameUdf>, Arc<Schema<DataType>>)>, maintain_order: bool, dynamic_options: Option<DynamicGroupOptions>, rolling_options: Option<RollingGroupOptions>, ) -> DslBuilder

where E: AsRef<[Expr]>,

pub fn build(self) -> DslPlan

pub fn from_existing_df(df: DataFrame) -> DslBuilder

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

pub fn explode(self, columns: Vec<Selector>, allow_empty: bool) -> DslBuilder

pub fn row_index(self, name: PlSmallStr, offset: Option<u32>) -> DslBuilder

pub fn distinct(self, options: DistinctOptionsDSL) -> DslBuilder

pub fn slice(self, offset: i64, len: u32) -> DslBuilder

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

pub fn map_private(self, function: DslFunction) -> DslBuilder

pub fn map<F>( self, function: F, optimizations: OptFlags, schema: Option<Arc<dyn UdfSchema>>, name: PlSmallStr, ) -> DslBuilder

where F: DataFrameUdf + 'static,

Trait Implementations

impl From<DslPlan> for DslBuilder

fn from(lp: DslPlan) -> DslBuilder

Converts to this type from the input type.