Pyspark说“在partitionBy（）上，行object没有属性''u get\uobject'u id'”

Question

考虑以下方案：

schemaRdd = hiveContext.sql(myQuery)

我尝试了以下方法，无法在上面使用partitionBy：

^{pr2}$

两者都给出“行”object has no attribute''u get_object_id'错误。在

那么我们如何用 -选定的分区 -特定的分区器-我还想提供第二个参数，它是在解决了\u get_object_id问题之后的分区器