polars_cloud.ExecuteRemote

class polars_cloud.ExecuteRemote(

lf: LazyFrame,

context: ComputeContext | None,

plan_type: PlanTypePreference,

n_retries: int,

engine: Engine,

labels: list[str] | None,

partition_by: None | str | list[str] = None,

broadcast_over: None | list[list[list[Path]]] = None,

shuffle_compression: ShuffleCompression = 'auto',

distributed_settings: DistributionSettings | None = None,

)

The namespace accessed by choosing a remote execution method in a LazyFrameRemote.

__init__(

lf: LazyFrame,

context: ComputeContext | None,

plan_type: PlanTypePreference,

n_retries: int,

engine: Engine,

labels: list[str] | None,

partition_by: None | str | list[str] = None,

broadcast_over: None | list[list[list[Path]]] = None,

shuffle_compression: ShuffleCompression = 'auto',

distributed_settings: DistributionSettings | None = None,

) → None

Methods

__init__(lf, context, plan_type, n_retries, ...)
await_and_scan()	Start executing the query and store a temporary result.
execute()	Start executing the query and store an intermediate result.
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.