LazyFrame

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

LazyFrameExt(lf[, context, plan_type, ...])
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.execute()	Start executing the query and store a temporary result.
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.
LazyFrameExt.sink_csv(uri, *[, include_bom, ...])	Start executing the query and write the result to csv.
LazyFrameExt.sink_ipc(uri, *[, compression, ...])	Start executing the query and write the result to ipc.
LazyFrameExt.show([n])	Start executing the query return the first n rows.