杂项#

LazyFrame.cache()

一旦物理计划的执行到达此节点,就缓存结果。

LazyFrame.collect(*[, type_coercion, ...])

将此LazyFrame具体化为DataFrame。

LazyFrame.collect_async(*[, gevent, ...])

在线程池中异步收集DataFrame。

LazyFrame.collect_schema()

解析此LazyFrame的模式。

LazyFrame.lazy()

返回惰性表示,即其本身。

LazyFrame.map_batches(function, *[, ...])

应用自定义函数。

LazyFrame.pipe(function, *args, **kwargs)

提供了一种结构化的方式来应用一系列用户定义的函数(UDFs)。

LazyFrame.profile(*[, type_coercion, ...])

分析一个LazyFrame。

序列化#

LazyFrame.deserialize(source, *[, format])

从文件中读取逻辑计划以构建LazyFrame。

LazyFrame.serialize([文件, 格式])

将此LazyFrame的逻辑计划序列化为JSON格式的文件或字符串。