polars_cloud.LazyFrameExt

class polars_cloud.LazyFrameExt(

lf: LazyFrame,

context: ComputeContext | None = None,

plan_type: PlanTypePreference = 'dot',

n_retries: int = 0,

)

__init__(

lf: LazyFrame,

context: ComputeContext | None = None,

plan_type: PlanTypePreference = 'dot',

n_retries: int = 0,

) → None

Methods

__init__(lf[, context, plan_type, n_retries])
broadcast_over(over)	Run this queries in parallel over the given source paths.
collect()	Start executing the query and store a temporary result.
distributed(*[, shuffle_compression])	Whether the query should run in a distributed fashion.
labels(labels)	Add labels to the query.
partition_by(key)	Partition this query by the given key.
sink_parquet(uri, *[, compression, ...])	Start executing the query and write the result to parquet.