LazyFrame#

This namespace becomes available by calling LazyFrame.remote(...).

LazyFrameExt(lf[, context, plan_type, n_retries])

LazyFrameExt.broadcast_over(over)

Run this queries in parallel over the given source paths.

LazyFrameExt.collect()

Start executing the query and store a temporary result.

LazyFrameExt.distributed(*[, ...])

Whether the query should run in a distributed fashion.

LazyFrameExt.labels(labels)

Add labels to the query.

LazyFrameExt.partition_by(key)

Partition this query by the given key.

LazyFrameExt.sink_parquet(uri, *[, ...])

Start executing the query and write the result to parquet.