Module dsl

Source
Expand description

Domain specific language for the Lazy API.

Re-exports§

pub use udf::UserDefinedFunction;
pub use crate::plans::lit;
pub use cat::*;dtype-categorical
pub use function_expr::*;
pub use functions::*;

Modules§

binary
catdtype-categorical
deletion
dttemporal
function_expr
functions
Functions
named_serdeserde
python_datasetpython
python_dslpython
stringstrings
udf

Structs§

AnonymousScanOptions
ArrayNameSpacedtype-array
Specialized expressions for Series of DataType::Array.
CastColumnsPolicy
Used by scans.
ChainedThen
Utility struct for the when-then-otherwise expression.
ChainedWhen
Utility struct for the when-then-otherwise expression.
DistinctOptionsDSL
DslBuilder
ExprNameNameSpace
Specialized expressions for modifying the name of existing expressions.
FileSinkOptions
FileSinkType
GroupbyOptions
HConcatOptions
JoinOptions
JoinOptionsIR
ListNameSpace
Specialized expressions for Series of DataType::List.
LogicalPlanUdfOptions
MatchToSchemaPerColumn
MetaNameSpacemeta
Specialized expressions for Categorical dtypes.
NDJsonReadOptionsjson
PartitionSinkType
PartitionSinkTypeIR
PartitionTargetContext
PartitionTargetContextKey
PythonDatasetProviderVTablepython
RollingCovOptions
ScanFlags
ScanSourceIter
An iterator for ScanSources
SinkFinishContext
SinkOptions
Options that apply to all sinks.
SinkWritten
SortColumn
SortColumnIR
SpecialEq
Wrapper type that has special equality properties depending on the inner type specialization
StrptimeOptions
StructNameSpacedtype-struct
Specialized expressions for Struct dtypes.
Then
Utility struct for the when-then-otherwise expression.
UnifiedScanArgs
Scan arguments shared across different scan types.
UnionArgs
UnionOptions
UnpivotArgsDSL
When
Utility struct for the when-then-otherwise expression.

Enums§

AggExpr
DataTypeExpr
DslPlan
Engine
EvalVariant
Excluded
Expr
Expressions that can be used in various contexts.
ExtraColumnsPolicy
FileScan
FileType
JoinTypeOptionsIR
LazySerde
MissingColumnsPolicy
MissingColumnsPolicyOrExpr
NestedType
Operator
PartitionTargetCallback
PartitionVariant
PartitionVariantIR
RenameAliasFn
ScanSource
A single source to scan from
ScanSourceRef
A reference to a single item in ScanSources
ScanSources
Set of sources to scan from
Selector
SinkFinishCallback
SinkTarget
SinkType
SinkTypeIR
UpcastOrForbid
WindowMapping
WindowType

Statics§

DATASET_PROVIDER_VTABLEpython
This is for polars-python to inject so that the implementation can be done there:
DSL_VERSION

Traits§

BinaryUdfOutputField
ColumnBinaryUdf
A wrapper trait for any binary closure Fn(Column, Column) -> PolarsResult<Column>
ColumnsUdf
A wrapper trait for any closure Fn(Vec<Series>) -> PolarsResult<Series>
FunctionOutputField

Functions§

apply_multiple
Apply a function/closure over the groups of multiple columns. This should only be used in a group_by aggregation.
binary_expr
Compute op(l, r) (or equivalently l op r). l and r must have types compatible with the Operator.
first
First column in a DataFrame.
last
Last column in a DataFrame.
len
Return the number of rows in the context.
map_multiple
Apply a function/closure over multiple columns once the logical plan get executed.
nth
Nth column in a DataFrame.
ternary_expr
when
Start a when-then-otherwise expression.

Type Aliases§

FieldsNameMapperdtype-struct
GetOutput
OpaqueColumnUdf
RenameAliasRustFn