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.

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.