polars_cloud.LazyFrameExt

class polars_cloud.LazyFrameExt(

lf: LazyFrame,

context: ComputeContext | None = None,

plan_type: PlanTypePreference = 'dot',

n_retries: int = 0,

engine: Engine = 'auto',

)

__init__(

lf: LazyFrame,

context: ComputeContext | None = None,

plan_type: PlanTypePreference = 'dot',

n_retries: int = 0,

engine: Engine = 'auto',

) → None

Methods

__init__(lf[, context, plan_type, ...])
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.
execute()	Start executing the query and store a temporary result.
labels(labels)	Add labels to the query.
partition_by(key, *[, shuffle_compression])	Partition this query by the given key.
show([n])	Start executing the query return the first n rows.
sink_parquet(uri, *[, compression, ...])	Start executing the query and write the result to parquet.