杂项#

DataFrame.collect_schema()

获取列名到其数据类型的有序映射。

DataFrame.corr(**kwargs)

返回列之间的成对皮尔逊积矩相关系数。

DataFrame.equals(other, *[, null_equal])

检查DataFrame是否等于另一个DataFrame。

DataFrame.lazy()

从这一点开始一个惰性查询。

DataFrame.map_rows(function[, return_dtype, ...])

在DataFrame的行上应用自定义/用户定义的函数(UDF)。

序列化#

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

从文件中读取一个序列化的DataFrame。

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

将此DataFrame序列化为JSON格式的文件或字符串。