LazyFrameRemote#

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

LazyFrameRemote(lf[, context, plan_type, ...])

LazyFrameRemote.broadcast_over(over)

Run this queries in parallel over the given source paths.

LazyFrameRemote.collect()

Start executing the query and store a temporary result.

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

Whether the query should run in a distributed fashion.

LazyFrameRemote.execute()

Start executing the query and store an intermediate result.

LazyFrameRemote.labels(labels)

Add labels to the query.

LazyFrameRemote.partition_by(key, *[, ...])

Partition this query by the given key.

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

Start executing the query and write the result to parquet.

LazyFrameRemote.sink_csv(uri, *[, ...])

Start executing the query and write the result to csv.

LazyFrameRemote.sink_ipc(uri, *[, ...])

Start executing the query and write the result to ipc.

LazyFrameRemote.show([n])

Start executing the query return the first n rows.