Spark-Koalas错误:列赋值不支持类型元组

Question

我无法将kdf[c].factorize()分配给kdf[c]。

我试过了，但没有用：

ks.set_option('compute.ops_on_diff_frames', True)
kdf[response] = ks.Series(kdf[response].factorize())
ks.reset_option('compute.ops_on_diff_frames')

感谢您的帮助。

Answer 1

factorize返回一个元组(Series, Index)。您可以将元组的第一个元素分配给response列。它已经是一个系列，所以不需要使用ks.Series对其进行转换。尝试以下代码：

kdf[response] = kdf[response].factorize()[0]

PS不需要设置ops_on_diff_frames，因为您在这里只处理单个数据帧。