polars_cloud.LazyFrameRemote

class polars_cloud.LazyFrameRemote(

lf: LazyFrame,

context: ComputeContext | None = None,

plan_type: PlanTypePreference = 'dot',

n_retries: int = 0,

engine: Engine = 'auto',

)

The namespace accessed by LazyFrame.remote.

This will allow you to run a query remotely.

__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, ...])
await_and_scan()	Start executing the query and store a temporary result.
broadcast_over(over)	Run this query in parallel over the given source paths.
distributed(*[, shuffle_compression, ...])	Whether the query should run in a distributed fashion.
execute()	Start executing the query and store an intermediate 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_csv(uri, *[, include_bom, ...])	Start executing the query and write the result to csv.
sink_ipc(uri, *[, compression, ...])	Start executing the query and write the result to ipc.
sink_parquet(uri, *[, compression, ...])	Start executing the query and write the result to parquet.
vertical()	Run this query remotely on a single node.