我有一个pyspark Dataframe,现在我想遍历每一行并插入/更新到mongoDB集合。当我试图在spark-dataframe上映射这个函数时,我得到了以下错误 #.....TypeError#AttributeError: 'TypeError' object has no attribute 'message'
我担心这可能不是做这件事的正确方式,所以欢迎任何其他想法。但是我有一个函数,它需要一个DataFrame来做一些计算。但是,现在我需要迭代另一个元组行,并将该行作为1元组DataFrame传递给该函数for u in df.iterrows():但是foo是一个元组。我可以执行几个步骤并转换为dataframe (也许),但是有没有一种简单的(或者比它更好的)遍历行</em